如何改进与多个客户端的java聊天

Question

对于一个学校项目，我不得不用java与多个用户聊天。我做到了，它有效，但我不认为是完美的。将来我想添加一个GUI，但在此之前我想纠正它。所以我的问题是如何改进它？我能做得更好吗？。这是我的密码。在客户端，我使用主线程等待用户输入，另一个线程监听服务器，等待来自另一个客户端的消息。在服务器端，我使用主线程接受来自客户端和管理N个客户端的N个线程的新连接请求。请帮帮我。

客户端：

import java.net.*;
import java.io.*;
class listener implements Runnable{
private Socket connection;
private static boolean running;
listener(Socket connection){
this.connection=connection;
running=true;
}
public void run(){
InputStreamReader in;
BufferedReader sIN;
String msgToRecv;
try{
in=new InputStreamReader(connection.getInputStream());
sIN=new BufferedReader(in);
}
catch(IOException e){
System.out.println(e);
return;
}
while(running){
try{
msgToRecv=sIN.readLine();
}
catch(IOException e){
System.out.println("Connection closed: "+e);
return;
}
System.out.println(msgToRecv);
}
return;
}
public static void stopListening(){
running=false;
return;
}
}
class Client
{
public static void main(String[] args)
{
String ipAddServer="127.0.0.1";
int port=8080;
Socket connection=null;
String msgToSend;
String username;
InputStreamReader input=new InputStreamReader(System.in);
BufferedReader tastiera=new BufferedReader(input);
OutputStream out;
PrintWriter sOUT;
System.out.println("Enter a username");
try{
connection=new Socket(ipAddServer, port);
out=connection.getOutputStream();
sOUT=new PrintWriter(out);
username=tastiera.readLine();
}
catch(IOException e){
System.out.println(e);
return;
}
System.out.println("User: "+username);
System.out.println("Chat Joined");
Thread t=new Thread(new listener(connection));
t.start();
do{
try{
msgToSend=tastiera.readLine();
}
catch(IOException e){
System.out.println(e);
return;
}
sOUT.println(username+": "+msgToSend);
sOUT.flush();
}while(!msgToSend.equals("EXIT"));
listener.stopListening();
try
{
connection.close();
}
catch(IOException e)
{
System.out.println(e);
}
return;
}
}

服务器端：

import java.net.*;
import java.io.*;
import java.util.ArrayList;
class clientHandler implements Runnable{
private ServerSocket sSocket;
private Socket connection;
private ArrayList<Socket> sockets;
public clientHandler(ServerSocket sSocket, Socket connection, ArrayList<Socket> sockets) {
this.sSocket=sSocket;
this.connection=connection;
this.sockets=sockets;
}
public void run(){
InputStreamReader in, input;
BufferedReader sIN, tastiera;
OutputStream out;
PrintWriter sOUT;
String msgToRecv;
try{
out=connection.getOutputStream();
sOUT=new PrintWriter(out);
in=new InputStreamReader(connection.getInputStream());
sIN=new BufferedReader(in);
}
catch(Exception e){
System.out.println(e);
return;
}
sockets.add(connection);
do{
try{
msgToRecv=sIN.readLine();
}
catch(IOException e){
System.out.println(e);
return;
}
for(int i=0;i<sockets.size();++i){
Socket temp=sockets.get(i);
if(!connection.equals(temp)&&!msgToRecv.equals("null")){
OutputStream tmpOut;
PrintWriter tmpSOUT;
try{
tmpOut=temp.getOutputStream();
tmpSOUT=new PrintWriter(tmpOut);
}
catch(IOException e){
System.out.println(e);
return;
}
tmpSOUT.println(msgToRecv);
tmpSOUT.flush();
}
}
}while(msgToRecv!=null);
sockets.remove(sOUT);
return;
}
}
class Server
{
public static void main(String[] args)
{
int port=8080;
ServerSocket sSocket;
ArrayList<Socket> sockets=new ArrayList<Socket>();
Thread t;
try{
sSocket=new ServerSocket(port);
}
catch(IOException e){
System.out.println(e);
return;
}
while(true){
try{
t=new Thread(new clientHandler(sSocket, sSocket.accept(), sockets));
}
catch(IOException e){
System.out.println(e);
return;
}
t.start();
}
}
}

Answer 1

当您开发聊天服务器(更好地说是软实时服务器(时，有一些重要的事情：

1.管理资源

2.低延迟

3.可扩展性

4.耐久性

5.可用性

6.存储数据(聊天、文件和…(

当你为学校开发这个服务器时，你可以跳过第2、3、4和5节。

第1节：管理任何程序中的资源都太重要了，在聊天服务器中也是如此。你有N个客户端，你需要N个线程？不，这不是一个好主意，有一种很好的方法可以用无阻塞套接字来处理它，它将帮助您在一个线程中处理多个连接。记住不要在服务器上创建太多线程，也不要浪费CPU和内存。有时，您必须知道如何更好地重用已分配的缓冲区，而不是创建导致CPU和内存资源浪费的新缓冲区。

第6节：将数据存储在聊天服务器中，需要管理每秒接收许多请求的数据。有时需要对数据进行批处理，然后将它们推送到数据存储中。这将使它比逐个推送数据更快，当然数据库及其驱动程序库将在其层中处理这些事情，但在应用程序层内进行批处理太重要了。聊天服务器中有许多好的数据库可供使用，但最好的是ApacheCassandra。

注意 ：它与开发聊天服务器无关，但更好的是使您的代码更易于理解和编程事件驱动(UserConnect、UserDisconnect、MessageRecived和…(。一个好的做法是通过定义接口(例如：AbstractServer、AbstractDataBase和…(创建程序逻辑抽象，然后直接使用该接口的程序的可运行部分，独立于该接口的功能，然后实现该接口。有了这个模型，您可以将程序划分为更小的部分，并使实现程序更加容易。