【Socket 通信编程】【TCP双向通信多线程】

旧城等待， 2022-02-20 16:28 268阅读 0赞

/* 服务器端，引入多线程 */
    import java.io.*;
    import java.net.*;
    class ServerThread extends Thread {
    	private Socket socket = null;
    	private int no;
    	public ServerThread (Socket socket, int no) {
    		this.socket = socket;
    		this.no = no;
    	}
    	@Override
    	public void run() {
    		String line = null;
    		InputStream input = null;
    		OutputStream output = null;
    		BufferedReader bf = null;
    		PrintWriter out = null;
    		try {
    			// 向客户端发送消息
    			output = socket.getOutputStream();
    			input = socket.getInputStream();
    			bf = new BufferedReader(new InputStreamReader(input));
    			out = new PrintWriter(output);
    			while((line=bf.readLine())!=null) {
    				System.out.println("来自客户端" + no + "的消息: " + line);
    				// 向客户端发送确认消息
    				out.println(line);
    				out.flush();
    			}
    		} catch (IOException e) {
    			// e.printStackTrace();
    			System.out.println("客户端" + no + "已断开与服务器的连接");
    		} finally {
    			try {
    				if (input != null)
    				    input.close();
    				if (output != null)
    					output.close();
    				if (bf != null)
    					bf.close();
    				if (out != null)
    					out.close();
    				if (socket != null)
    					socket.close();
    			} catch (IOException e) {
    				e.printStackTrace();
    			}	
    		}
    	}
    }
    public class MultiThreadServer {
    	static int port = 2019;
    	 public static void main(String[] args) throws Exception {
    		ServerSocket listenSocket = new ServerSocket(port);
            Socket socket = null;
            int count = 0;
            System.out.println("服务器正在监听端口号<" + port + ">");		
            while(true){
                socket = listenSocket.accept();
    			count++;
    			System.out.println("已连接到客户端" + count + "...");
                ServerThread serverThread = new ServerThread(socket, count);
                serverThread.start();
            }
        }
    }
    
    /* 客户端 */
    import java.net.*;
    import java.io.*;
    public class Client {
    	// 定义端口和IP地址
    	static int port = 2019; 
    	static String IP = "127.0.0.1"; 
    	public static void main(String args[]) throws Exception {
    		// 定义客户端输入和服务器响应
    		String userInput = null; 
    		String echoMessage = null;
    		
    		// 将键盘输入读入缓冲区stdIn
    		BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));
    		// 定义客户端套接字
    		Socket socket = new Socket(IP, port);
    		System.out.println("已连接到服务器...");
    		
    		// 客户端套接字上的getInputStream方法得到的输入流是从服务器端发回的数据
    		InputStream inStream = socket.getInputStream();
    		// 客户端套接字上的getOutputStream方法得到的输出流是发给服务器端的数据
    		OutputStream outStream = socket.getOutputStream();
    		
    		// 将服务器端发回的数据读入缓冲区in
    		BufferedReader in = new BufferedReader(new InputStreamReader(inStream));
    		// 定义向服务器发送数据流的对象out
    		PrintWriter out = new PrintWriter(outStream);
    		while((userInput = stdIn.readLine())!=null) {
    			// 向服务器打印数据
                out.println(userInput);
    			// flush方法的作用是刷新缓冲区
    			out.flush();
    			echoMessage = in.readLine();
    			System.out.println("服务器已收到消息: " + echoMessage);
    		}
    		socket.close();
    	}
    }

测试结果

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0RYSDkyNA_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0RYSDkyNA_size_16_color_FFFFFF_t_70 1][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0RYSDkyNA_size_16_color_FFFFFF_t_70]: /images/20220220/ad3152fcbe504c11bee6a255aecfa7d3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0RYSDkyNA_size_16_color_FFFFFF_t_70 1]: /images/20220220/684d61e9e45747d38fd4d6032a76f7a4.png