网站建设 发布腾讯企业邮箱登录入口

目录

案例要求：

实现思路：

代码：

User类：用户端

Client类：服务端

ServerReader类：多线程通信类

总结：

---

案例要求：

TCP通信下,正常的写法只能单个服务器和单个客户端进行通信，那该怎么解决这个问题呢？

实现思路：

有客户端进行通信就创建一个线程即可,用多线程解决单通信问题

代码：

User类：用户端

import java.io.DataOutputStream;
import java.io.OutputStream;
import java.net.*;
import java.util.Scanner;public class User {public static void main(String[] args) throws Exception {Socket socket = new Socket("127.0.0.1", 8888);System.out.println("客户端启动");OutputStream out = socket.getOutputStream();DataOutputStream dos = new DataOutputStream(out);Scanner sc = new Scanner(System.in);while (true) {System.out.println("请说:");String msg= sc.nextLine();if(msg.equals("exit")){dos.close();socket.close();break;}dos.writeUTF(msg);}}
}

Client类：服务端

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.ServerSocket;
import java.net.Socket;public class Client {public static void main(String[] args) throws  Exception{System.out.println("服务端启动了...");ServerSocket serverSocket = new ServerSocket(8888);Socket socket = null;while (true) {socket = serverSocket.accept();System.out.println("一个客户端上线了:"+socket.getInetAddress().getHostAddress());new ServerReader(socket).start();}}
}

ServerReader类：多线程通信类

import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;public class ServerReader extends  Thread{private Socket socket;public ServerReader(Socket socket) {this.socket = socket;}@Overridepublic void run() {try {InputStream in = socket.getInputStream() ;DataInputStream dis = new DataInputStream(in);while (true) {String msg=dis.readUTF();System.out.println("收到用户端的消息:"+msg);String ip=socket.getInetAddress().getHostAddress();String port=socket.getPort()+"";System.out.println("ip:"+ip+" port:"+port);}} catch (Exception e) {System.out.println("一个客户端下线了："+socket.getInetAddress().getHostAddress());}}
}

总结：

摘要：本文介绍了使用多线程解决TCP单通信问题的方案。通过创建User类作为客户端，Client类作为服务端主程序，以及ServerReader类作为多线程处理类，实现了服务端同时处理多个客户端连接。当新客户端连接时，服务端会为每个连接创建独立线程来处理通信，从而突破单客户端限制。该方案有效解决了传统TCP通信中服务端只能处理单个连接的问题，实现了多客户端并发通信的功能。