客户端再起一个线程来负责等待不就行了，多线程处理。还有服务端想高效处理客户端消息，建议用NIO机制来处理，否则客户端很快，服务端不能很快处理，也没意义
垦利网站制作公司哪家好，找创新互联建站！从网页设计、网站建设、微信开发、APP开发、响应式网站开发等网站项目制作，到程序开发，运营维护。创新互联建站于2013年成立到现在10年的时间，我们拥有了丰富的建站经验和运维经验，来保证我们的工作的顺利进行。专注于网站建设就选创新互联建站。
将
Socket Socket=ServerSocket.accept();
System.out.println("IP地址"+Socket.getInetAddress()+"端口"+Socket.getPort()+"已经连接到本机");
BufferedReader read = new BufferedReader(new InputStreamReader(Socket.getInputStream(),"UTF-8"));
PrintWriter pw =new PrintWriter(Socket.getOutputStream(),true);
拿到while循环外面，这样服务器端只为第一个连接的客服端服务，程序会正常。或者将Socket=ServerSocket.accept();返回的sock交给宁一个线程处理，然后循环调用String st=read.readLine();读取数据，这样就是一个比较标准的服务器端了，为每一个连进来的客服端，开一个单独的线程为之服务。
主要要理解Socket=ServerSocket.accept();这句代码，返回的Socket是针对单独的一个客户端的，当没有客户端连接时，这句代码会阻塞，直到有客户端连接进来生成的与之对应的客户端。
现在报错是因为，与客户端相对应Socket，读了一行数据，就销毁了，然后又循环到Socket=ServerSocket.accept();去等待一个新的连接。而客户端还往已经销毁的socket发数据，当然客户端会抛Connection reset。
有两个类，服务器和客户端、
服务器类代码：
package chat;
import java.io.*;
import java.net.*;
import java.util.*;
/*服务器类*/
public class Server {
public ListSocket socketList = new ArrayListSocket();//存放所有连接的客户端的集合
public ServerSocket server;//服务器
public int portNum;//端口号
public Server(int portNum){
this.portNum = portNum;
}
public void innit(){
try {
server = new ServerSocket(portNum);
System.out.println("服务器开启成功！");
int socketNum = 0;
while(true){
Socket socket = server.accept();//被动等待客户端的连接
socketNum++;
System.out.println("第"+socketNum+"个客户端连接成功！！");
socketList.add(socket);//连接的客户端存放到集合里面
new RWThread(socket).start();
}
} catch (IOException e) {
e.printStackTrace();
}
}
class RWThread extends Thread{//接收和发送消息的线程
public Socket socket;
public RWThread(Socket socket){
this.socket = socket;
}
public void run() {
super.run();
try {
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
while(true){
String message = br.readLine();
System.out.println(message);//接收客户端发来的消息
for(int i=0;isocketList.size();i++){//发送给所有连接的客户端
PrintWriter pw = new PrintWriter(new OutputStreamWriter(socketList.get(i).getOutputStream()));
pw.println(message);
pw.flush();
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
public static void main(String[] args) {
int portNum = 8888;//创建服务器的端口号
Server server = new Server(portNum);
server.innit();
}
}
客户端类：
package chat;
import java.io.*;
import java.net.*;
import java.util.*;
/*客户端类*/
public class Client {
public Socket socket;
public Client(){
Scanner sca = new Scanner(System.in);
try {
socket = new Socket("127.0.0.1",8888);//创建客户端
new ReadThread(socket).start();//开启读取从服务器端发来的信息
while(true){
PrintWriter pw = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));
String message = sca.nextLine();
pw.println(message);//向服务器发送信息
pw.flush();
}
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
System.out.println("错误：服务器未开启！！！");
}
}
class ReadThread extends Thread{//读取服务器发来信息的线程
public Socket socket;
public ReadThread(Socket socket){
this.socket = socket;
}
public void run() {
super.run();
try {
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
while(true){
String message = br.readLine();
System.out.println(message);//输出信息
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
public static void main(String[] args) {
Client client = new Client();
}
}
现打开服务器类，然后可以打开多个客户端进行聊天
