网络编程_多线程改进多个客户端上传文件案例

绝地灬酷狼 2022-06-17 01:29 187阅读 0赞

package cn.itcast_15;
    
    import java.io.IOException;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class UploadServer {
    	public static void main(String[] args) throws IOException {
    		// 创建服务器对象
    		ServerSocket ss = new ServerSocket(9527);
    
    		// 启动线程
    		while (true) {
    			// 监听客户链接
    			Socket s = ss.accept();
    			new Thread(new UserThread(s)).start();
    		}
    	}
    }

package cn.itcast_15;
    
    import java.io.BufferedReader;
    import java.io.BufferedWriter;
    import java.io.FileWriter;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.OutputStreamWriter;
    import java.net.Socket;
    
    public class UserThread implements Runnable {
    	private Socket s;
    
    	public UserThread(Socket s) {
    		this.s = s;
    	}
    
    	@Override
    	public void run() {
    		try {
    			// 封装通道内流
    			BufferedReader br = new BufferedReader(new InputStreamReader(
    					s.getInputStream()));
    			// 封装文本文件
    			// BufferedWriter bw = new BufferedWriter(new
    			// FileWriter("Copy.java"));
    			String newName = System.currentTimeMillis() + ".java";
    			BufferedWriter bw = new BufferedWriter(new FileWriter(newName));
    
    			String line = null;
    			while ((line = br.readLine()) != null) {
    				bw.write(line);
    				bw.newLine();
    				bw.flush();
    			}
    
    			// 给出反馈
    			BufferedWriter bwServer = new BufferedWriter(
    					new OutputStreamWriter(s.getOutputStream()));
    			bwServer.write("文件上传成功");
    			bwServer.newLine();
    			bwServer.flush();
    
    			// 释放资源
    			bw.close();
    			s.close();
    		} catch (IOException e) {
    			e.printStackTrace();
    		}
    	}
    
    }

package cn.itcast_15;
    
    import java.io.BufferedReader;
    import java.io.BufferedWriter;
    import java.io.FileReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.OutputStreamWriter;
    import java.net.Socket;
    
    public class UploadClient {
    	public static void main(String[] args) throws IOException {
    		// 创建客户端Socket对象
    		Socket s = new Socket("127.0.0.1", 9527);
    
    		// 封装文本文件
    		BufferedReader br = new BufferedReader(new FileReader(
    				"InetAddressDemo.java"));
    		// 封装通道内流
    		BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
    				s.getOutputStream()));
    
    		String line = null;
    		while ((line = br.readLine()) != null) {
    			bw.write(line);
    			bw.newLine();
    			bw.flush();
    		}
    
    		// Socket提供了一个终止,它会通知服务器你别等了,我没有数据过来了
    		s.shutdownOutput();
    
    		// 接收反馈
    		BufferedReader brClient = new BufferedReader(new InputStreamReader(
    				s.getInputStream()));
    		String client = brClient.readLine();
    		System.out.println(client);
    
    		// 释放资源
    		br.close();
    		s.close();
    	}
    }