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()方法加入一个结束符,可以解决这个问题.

目录
相关文章
|
5月前
|
JSON 网络协议 安全
【Java】(10)进程与线程的关系、Tread类;讲解基本线程安全、网络编程内容;JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念,进程是处于运行过程中的程序,并且具有一定的独立功能,进程是系统进行资源分配和调度的一个独立单位一般而言,进程包含如下三个特征。独立性动态性并发性。
295 1
|
5月前
|
JSON 网络协议 安全
【Java基础】(1)进程与线程的关系、Tread类;讲解基本线程安全、网络编程内容;JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念,进程是处于运行过程中的程序,并且具有一定的独立功能,进程是系统进行资源分配和调度的一个独立单位一般而言,进程包含如下三个特征。独立性动态性并发性。
313 1
|
6月前
|
数据采集 存储 弹性计算
高并发Java爬虫的瓶颈分析与动态线程优化方案
高并发Java爬虫的瓶颈分析与动态线程优化方案
Java 数据库 Spring
286 0
|
6月前
|
算法 Java
Java多线程编程:实现线程间数据共享机制
以上就是Java中几种主要处理多线程序列化资源以及协调各自独立运行但需相互配合以完成任务threads 的技术手段与策略。正确应用上述技术将大大增强你程序稳定性与效率同时也降低bug出现率因此深刻理解每项技术背后理论至关重要.
463 16
|
7月前
|
缓存 并行计算 安全
关于Java多线程详解
本文深入讲解Java多线程编程,涵盖基础概念、线程创建与管理、同步机制、并发工具类、线程池、线程安全集合、实战案例及常见问题解决方案,助你掌握高性能并发编程技巧,应对多线程开发中的挑战。
|
7月前
|
数据采集 存储 前端开发
Java爬虫性能优化:多线程抓取JSP动态数据实践
Java爬虫性能优化:多线程抓取JSP动态数据实践
|
8月前
|
Java API 调度
从阻塞到畅通:Java虚拟线程开启并发新纪元
从阻塞到畅通:Java虚拟线程开启并发新纪元
447 83
|
8月前
|
安全 算法 Java
Java 多线程:线程安全与同步控制的深度解析
本文介绍了 Java 多线程开发的关键技术,涵盖线程的创建与启动、线程安全问题及其解决方案,包括 synchronized 关键字、原子类和线程间通信机制。通过示例代码讲解了多线程编程中的常见问题与优化方法,帮助开发者提升程序性能与稳定性。
370 0
|
8月前
|
存储 Java 调度
Java虚拟线程:轻量级并发的革命性突破
Java虚拟线程:轻量级并发的革命性突破
477 83

热门文章

最新文章