JavaSocket TCP多线程上传文件到服务器

一、服务端 1、创建 ServerSocket 套接字对象,while(true)死循环监听端口 2 […]

2019年5月18日

一、服务端

  • 1、创建 ServerSocket 套接字对象,while(true)死循环监听端口
  • 2、accept() 方法获取客户端的连接对象,有新客户端就开辟新线程
  • 3、客户端连接对象获取字节输入流,读取客户端发送的图片
  • 4、创建 File 对象,绑定上传文件夹
  • 5、创建字节输出流
  • 6、字节流得到图片,将图片写进写到文件夹中
  • 7、发送消息给客户端

代码:

public class TCPServer {
    public static void main(String[] args) throws IOException {
        ServerSocket server = new ServerSocket(8888);
        System.out.println("服务器开启成功:端口号8888 ");
        while (true) {

            Socket socket = server.accept();
            System.out.println("有新客户端连接:" + socket.getRemoteSocketAddress());
            new Thread(new Runnable() {
                @Override
                public void run() {
                    try {
                        InputStream is = socket.getInputStream();
                        File file = new File("d:\\upload");
                        if (!file.exists()) {
                            file.mkdirs();
                        }
                        String fileName = System.currentTimeMillis() + (new Random(99999).nextInt() + ".png");
                        FileOutputStream fos = new FileOutputStream(file + "\\" + fileName);
                        int len = 0;
                        byte[] bytes = new byte[1024];
                        while ((len = is.read(bytes)) != -1) {
                            fos.write(bytes, 0, len);
                        }

                        socket.getOutputStream().write("上传成功".getBytes());
                        fos.close();
                        socket.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }).start();

        }

    }

}

二、客户端

  • 1、Socket 套接字连接服务器
  • 2、通过 Socket 获取字节输出流,进行写图片
  • 3、使用字节流对象读取图片流资源
  • 4、读取图片,使用字节输出流将图片写到服务器,采用字节数组进行缓冲
  • 5、通过 Socket 套接字获取字节输入流,最后给服务器写终止序列
  • 6、获取服务器端的反馈回来的信息
  • 7、关闭流资源

代码:

public class TCPClient {
    public static void main(String[] args) throws IOException {
        FileInputStream fis = new FileInputStream("d:\\bkg1.png");
        Socket socket = new Socket("127.0.0.1", 8888);
        OutputStream os = socket.getOutputStream();

        int len = 0;
        byte[] bytes = new byte[1024];
        while ((len = fis.read(bytes)) != -1) {
            os.write(bytes, 0, len);
        }

        socket.shutdownOutput();
        InputStream is = socket.getInputStream();

        while ((len = is.read(bytes)) != -1) {
            System.out.println(new String(bytes, 0, len));

        }
        fis.close();
        socket.close();
    }
}
打赏 0

共有 0 条评论