Java网络编程实现客户端向服务器端上传文件

╰+哭是因爲堅強的太久メ 2023-01-07 10:18 155阅读 0赞

服务器端：

package client;
    
    import java.io.File;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class Server {
    
    	private static FileOutputStream fileOutputStream;
    	private static InputStream inputStream;
    
    	public static void main(String[] args) {
    
    		try {
    			// 创建服务器对象并指定端口
    			ServerSocket serverSocket = new ServerSocket(8888);
    			// 接收客户端连接(阻塞式等待)
    			Socket socket = serverSocket.accept();
    			inputStream = socket.getInputStream();
    			fileOutputStream = new FileOutputStream(new File(
    					"transcript/poem-c.txt"));
    			int len = 0;
    			byte byteArr[] = new byte[1024];
    			while ((len = inputStream.read(byteArr)) != -1) {
    				fileOutputStream.write(byteArr, 0, len);
    			}
    		} catch (IOException e) {
    			e.printStackTrace();
    		} finally {
    			try {
    				fileOutputStream.close();
    				inputStream.close();
    			} catch (IOException e) {
    				e.printStackTrace();
    			}
    		}
    
    	}
    
    }

客户端：

package client;
    
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.IOException;
    import java.io.OutputStream;
    import java.net.Socket;
    import java.net.UnknownHostException;
    
    /**
     * 客户端
     * 
     * @author WanAkiko
     * 
     */
    public class Client {
    
    	private static FileInputStream fileInputStream;
    	private static OutputStream outputStream;
    
    	public static void main(String[] args) {
    
    		try {
    			// 创建客户端并指定IP和端口
    			Socket socket = new Socket("127.0.0.1", 8888);
    			// 字节输出流执行功能代码
    			outputStream = socket.getOutputStream();
    			fileInputStream = new FileInputStream(new File("original/poem.txt"));
    			int len = 0;
    			byte byteArr[] = new byte[1024];
    			while ((len = fileInputStream.read(byteArr)) != -1) {
    				outputStream.write(byteArr, 0, len);
    			}
    			System.out.println("提示：文件已上传！");
    		} catch (UnknownHostException e) {
    			e.printStackTrace();
    		} catch (IOException e) {
    			e.printStackTrace();
    		} finally {
    			try {
    				fileInputStream.close();
    				outputStream.close();
    			} catch (IOException e) {
    				e.printStackTrace();
    			}
    		}
    
    	}
    
    }

运行示例：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTY1Mzkz_size_16_color_FFFFFF_t_70]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTY1Mzkz_size_16_color_FFFFFF_t_70]: /images/20221119/92749161e50a4ec5a455f09c2f1b6323.png