Java使用FileInputStream&&FileOutputStream模拟客户端向服务器端上传文件(单线程)

简介: Java使用FileInputStream&&FileOutputStream模拟客户端向服务器端上传文件(单线程)
客户端代码
import java.io.FileInputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class Client {
    public static void main(String[] args) throws Exception {
        //创建客户端对象,指定服务器端IP和端口号(host是服务器名称或IP地址,port是端口号)
        Socket client = new Socket("192.168.0.100", 8973);
        //使用socket中的方法创建输出流对象,向服务器端传送数据
        OutputStream outputStream = client.getOutputStream();

        //读取本地数据写进输出流中,传送给服务器端
        //创建输入流,关联数据源文件
        FileInputStream fileInputStream = new FileInputStream("client.txt");
        int len;
        byte[] bytes = new byte[8192];
        while ((len = fileInputStream.read(bytes)) != -1) {
            outputStream.write(bytes, 0, len);
        }

        //解决阻塞问题
        client.shutdownOutput();

        //创建输入流,获取服务器端传送回来的回执信息并且打印
        InputStream inputStream = client.getInputStream();
        while ((len = inputStream.read(bytes)) != -1){
            System.out.println(new String(bytes,0,len));
        }

        //关闭流
        client.close();
        outputStream.close();
        inputStream.close();
    }
}

服务器端
public class Server {
    public static void main(String[] args) throws Exception{
        //创建服务器端对象,指定服务器使用的端口号
        ServerSocket server = new ServerSocket(8973);
        //使用accpet方法接收客户端发送来的数据
        Socket accpet = server.accept();
        //使用socket中的方法创建输入流对象,获取客户端发送来的数据
        InputStream inputStream = accpet.getInputStream();

        //将客户端发送来的数据写入到服务器端的本地文件中
        //创建输出流,关联目的地文件
        FileOutputStream fileOutputStream = new FileOutputStream("server.txt");
        int len;
        byte[] bytes= new byte[8192];
        while((len = inputStream.read(bytes))!= -1){
            fileOutputStream.write(bytes,0,len);
        }

        //创建输出流,给客户端发送回执信息
        OutputStream outputStream = accpet.getOutputStream();
        outputStream.write("文件上传成功".getBytes());

        //关闭流
        //实际开发中,不会关闭服务器端的Socket对象
        accpet.close();
        outputStream.close();
    }
}

细节1:应该先启动服务器端,再启动客户端


细节2:client.shutdownOutput()方法是解决线程阻塞问题. 客户端while()循环中的结束条件为不等于-1,所以会发送结束符之前的信息.服务器端在接收数据进行while()循环读取的时候读取不到结束符,所以会一直运行陷入死循环.我们使用shutdownOutput()方法加入一个结束符,可以解决这个问题.

目录
相关文章
|
12天前
|
安全 Java 调度
Java编程时多线程操作单核服务器可以不加锁吗?
Java编程时多线程操作单核服务器可以不加锁吗?
32 2
|
1天前
|
Java 关系型数据库 MySQL
如何用java的虚拟线程连接数据库
本文介绍了如何使用Java虚拟线程连接数据库,包括设置JDK版本、创建虚拟线程的方法和使用虚拟线程连接MySQL数据库的示例代码。
15 6
如何用java的虚拟线程连接数据库
|
10天前
|
Java Linux
java读取linux服务器下某文档的内容
java读取linux服务器下某文档的内容
25 3
java读取linux服务器下某文档的内容
|
5天前
|
Java 数据库 UED
Java的多线程有什么用
Java的多线程技术广泛应用于提升程序性能和用户体验,具体包括:提高性能,通过并行执行充分利用多核CPU;保持响应性,使用户界面在执行耗时操作时仍流畅交互;资源共享,多个线程共享同一内存空间以协同工作;并发处理,高效管理多个客户端请求;定时任务,利用`ScheduledExecutorService`实现周期性操作;任务分解,将大任务拆分以加速计算。多线程尤其适用于高并发和并行处理场景。
|
1天前
|
Java 调度
Java一个线程的生命周期详解
Java中,一个线程的生命周期分为五个阶段:NEW(新建),RUNNABLE(可运行),BLOCKED(阻塞),WAITING(等待),TERMINATED(终止)。线程创建后处于新建状态,调用start方法进入可运行状态,执行中可能因等待资源进入阻塞或等待状态,正常完成或异常终止后进入终止状态。各状态间可相互转换,构成线程的生命周期。
|
1天前
|
Java 开发者
农行1面:Java如何保证线程T1,T2,T3 顺序执行?
本文探讨了如何保证线程T1、T2、T3的顺序执行,这是农行面试中的一道题目,旨在考察候选人对多线程基础、同步机制、线程间通信及Java并发包的掌握情况。文章详细介绍了六种方法:`join()`、`CountDownLatch`、`Semaphore`、单线程池、`synchronized` 和 `CompletableFuture`,并通过示例代码展示了每种方法的具体实现。这些方法不仅适用于面试备考,还能帮助开发者更好地理解和掌握线程同步技术。
20 2
|
1天前
|
Java API 调度
Java 多线程编程详解
《Java多线程编程详解》深入浅出地讲解了Java平台下的多线程核心概念、API使用及最佳实践。从基础理论到实战案例,本书帮助读者掌握并发编程技巧,提升软件开发中的效率与性能,是Java开发者不可或缺的参考指南。
|
12天前
|
Java
java小工具util系列5:java文件相关操作工具,包括读取服务器路径下文件,删除文件及子文件,删除文件夹等方法
java小工具util系列5:java文件相关操作工具,包括读取服务器路径下文件,删除文件及子文件,删除文件夹等方法
26 4
|
14天前
|
Java 调度
Java-Thread多线程的使用
这篇文章介绍了Java中Thread类多线程的创建、使用、生命周期、状态以及线程同步和死锁的概念和处理方法。
Java-Thread多线程的使用
|
12天前
|
Java 数据中心 微服务
Java高级知识:线程池隔离与信号量隔离的实战应用
在Java并发编程中,线程池隔离与信号量隔离是两种常用的资源隔离技术,它们在提高系统稳定性、防止系统过载方面发挥着重要作用。
13 0