Socket网络编程-文件上传

package com.example.thinkinjava.inetwork; import com.example.thinkinjava.inetwork.util.StreamUtils; import java.io.*; import java.net.InetAddress; import java.net.ServerSocket; import java.net.Socket; import java.net.UnknownHostException; /** * <p> * 客户端：发送一直图片给服务端 * 服务端：接收客户端发送来的图片，保存到src目录下，并回复“图片已收到” * 客户端 服务器端 * Socket.getOutputStream Socket.getInputStream * c1.把磁盘图片用一个文件字节数组读取， s1.通过输入流读取文件字节数组 * c2.字节数组 流入到Socket.OutputStream流里面 s2.存放路径src目录下 * s3.获取Socket.getOutputStream * c3.获取Socket.getInputStream s4.发送消息“图片已收到” //使用字符流写入 * 读取服务器端发来的消息【图片已收到】 * * @deprecated 注意点: 字符流才需要flush手动刷新缓冲区，字节流不需要手动刷新 * </p> * @date 2022年12月7日 * @author xiaoxpai */ public class SocketTest3 { } //客户端 class Client3{ public static void main(String[] args) throws IOException { //1.连接服务端，得到一个Socket对象 Socket socket = new Socket(InetAddress.getLocalHost(), 9092); //2.创建读取磁盘的文件的输入流 BufferedInputStream bufferedInputStream = new BufferedInputStream(new FileInputStream("G:\\2ha.png")); //3.文件缓冲区在字节数组里面 byte[] bytes = StreamUtils.streamToByteArray(bufferedInputStream); //4.获取输出流,使用缓冲流BufferedOutputStream BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(socket.getOutputStream()); //4.1将文件的字节数组内容，写入到socket数据通道 bufferedOutputStream.write(bytes); //回写内容给服务端socket.getInputStream //5.关闭流 bufferedInputStream.close(); //设置写入数据的结束标志 socket.shutdownOutput(); bufferedOutputStream.close(); socket.close(); } } //服务器 class Server3{ public static void main(String[] args) throws IOException { //1.监听端口 ServerSocket serverSocket = new ServerSocket(9092); System.out.println("服务端在9092端口监听......^_^"); //2.等待客户端连接 Socket socket = serverSocket.accept(); //3.读取客户端发送的文件 //得到socket.getInputStream， BufferedInputStream bufferedInputStream = new BufferedInputStream(socket.getInputStream()); byte[] bytes = StreamUtils.streamToByteArray(bufferedInputStream); //4.将得到的字节数组（文件），写入到指定的路径 BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(new FileOutputStream("F:\\IdeaProjects\\_test-projects\\think-in-java-01\\src\\main\\resources\\upload\\s22.png")); bufferedOutputStream.write(bytes); bufferedOutputStream.close(); //关闭流 bufferedInputStream.close(); socket.close(); serverSocket.close(); } public static byte[] streamToByteArray(InputStream is) throws IOException { //创建输出流对象 ByteArrayOutputStream bos = new ByteArrayOutputStream(); byte[] buffer = new byte[1024]; int len; while ((len = is.read(buffer))!=-1){ bos.write(buffer,0,len); } //把读取到的文件内容（文本或图片或媒体或其他）转成一个字节数组 byte[] array = bos.toByteArray(); bos.close(); return array; } }