问题描述
我有一个简单的客户端/服务器应用程序，该应用程序将2个客户端进行分组，并使它们彼此通信，如果连接了第三个客户端，它将无法与其他2个客户端通信，但是它将创建另一组2个客户端，并且依此类推...但是，当我从客户端发送消息时，并没有立即将其发送到其他客户端，而是等待第一个客户端输入，并且还等待第二个客户端输入，并且仅当两者都出现时，才会出现问题客户已输入输入，将其发送给彼此。任何帮助都非常有用。
服务器：
public class ChatServer {
Socket prevIoUsSocket = null;
public static void main(String[] args) throws Exception {
ServerSocket serverSocket = new ServerSocket(9001);
System.out.println("The chat server is running.");
Socket prevIoUsSocket = null;
while (true) {
Socket newSocket = serverSocket.accept();
/**
* if (prevIoUsSocket == null) occurs if only 1 client is connected and its being set as a prevIoUsSocket
* and we wait for a second client to connect so meanwhile nothing happens
*
* if second clients joins in we can start communicating in groups of 2
*/
if (prevIoUsSocket == null) {
prevIoUsSocket = newSocket;
} else {
new Handler(prevIoUsSocket,newSocket).start();
new Handler(newSocket,prevIoUsSocket).start();
prevIoUsSocket = null;
}
}
}
private static class Handler extends Thread {
private String name;
private Socket socket;
private Socket peerSocket;
private DataInputStream in;
private DataOutputStream out;
public Handler(Socket socket,Socket peerSocket) {
this.socket = socket;
this.peerSocket = peerSocket;
}
public void run() {
try {
while (true) {
in = new DataInputStream(socket.getInputStream());
out = new DataOutputStream(peerSocket.getoutputStream());
try {
String input = in.readUTF();
out.writeUTF(input);
} catch (IOException e) {
// Todo Auto-generated catch block
e.printstacktrace();
}
}
} catch (IOException e) {
// Todo Auto-generated catch block
e.printstacktrace();
}
}
}
}
客户：
public class ChatClient {
public static void main(String[] args) throws UnkNownHostException,IOException {
new ChatClient();
}
public ChatClient() throws UnkNownHostException,IOException {
Socket socket = new Socket("127.0.0.1",9001);
System.out.println("You can start typing:");
while(true) {
Scanner scanner = new Scanner(system.in);
Thread input = new Thread() {
@Override
public void run() {
while(true) {
try {
DataInputStream inputStream = new DataInputStream(socket.getInputStream());
while(scanner.hasNextLine()) {
String message = scanner.nextLine();
System.out.println(message);
//reading messages from server
String received = inputStream.readUTF();
System.out.println(received);
}
} catch (IOException e) {
e.printstacktrace();
}
}
}
};
input.start();
Thread output = new Thread() {
public void run() {
try {
DataOutputStream outputStream = new DataOutputStream(socket.getoutputStream());
while(scanner.hasNextLine()) {
String message = scanner.nextLine();
if(message.equalsIgnoreCase("quit")) {
socket.close();
break;
}
outputStream.writeUTF(message);
}
} catch (IOException e) {
e.printstacktrace();
}
};
};
output.start();
}
}
}
解决方法
在客户端中从服务器读取数据时，删除顶级Promise循环并删除HttpClient。
我已经在下面更新了您的客户代码，这应该可以正常工作。
while您需要将客户端中的输入和输出流分成两个单独的线程。问题是您的客户端在读取输入之前正在等待扫描仪的输入。扫描程序是一个阻止调用，因此它需要自己的线程。
此外，您应该将循环中数据流的创建移至构造函数中……这将提高效率。