我正在尝试使用Java插座构建一个简单的多客户聊天应用程序。我执行此操作的方式是,将客户类类连接到等待客户端连接并创建一个新线程来处理该客户端的服务器类(其中读取套接字连接并写入插座(。客户端还从读取并写入与此线程的套接字连接。但是,当客户端写入套接字的输出流时,服务器不会响应。这里发布了一个类似的问题:
您可以同时写入插座输入和输出流吗?
这里的答案之一说,只要在单独的线程上完成插座的读数,您就可以同时读取并写入插座。
这是我的客户端应用程序:
public class Client {
Socket socket;
public static void main(String[] args) {
new Client();
}
public Client() {
try {
socket = new Socket("localhost", 4444);
new Thread() {
@Override
public void run() { //read from the input stream
try(
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
) {
String line;
while( (line = in.readLine()) != null ) {
System.out.println("Server said: " + line);
}
} catch(IOException e) {
}
}
}.start();
//write to output stream
try(
PrintWriter out = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));
Scanner userInput = new Scanner(System.in);
){
System.out.println("Enter Something: ");
if(userInput.hasNextLine()) {
out.println(userInput.nextLine());
}
} catch (IOException e) {
}
} catch(IOException e) {
}
}
}
和我的服务器应用程序:
public class Server {
ServerSocket ss;
public static void main(String[] args) {
new Server();
}
public Server() {
System.out.println("Server Running...");
try {
ss = new ServerSocket(4444);
while(true) {
Socket socket = ss.accept();
new Thread() { //create new thread connection to client
@Override
public void run() {
new Thread() { //thread that reads inputstream
@Override
public void run() {
try(
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
) {
String line;
while( (line = in.readLine()) != null ) {
System.out.println("Client said: " + line);
//The problem seems to lie here.
}
} catch(IOException e) {
}
}
}.start();
//write to outputstream
try (
PrintWriter out = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));
) {
String sendToClient = "Hey, my name is Server007 B)";
out.println(sendToClient);
} catch(IOException e) {
}
}
}.start();
}
} catch (IOException e) {}
}
}
我将运行服务器,然后运行客户端,在客户端上输出为
Server said: Hey, my name is Server007
Enter something:
Hello! <- enter anything
但是服务器不打印"客户端说:你好!"就像我期望的那样。我希望我的问题足够清楚,谢谢。
好吧,所以我想出了,我会回答自己的问题,以防有人犯同样的错误。印刷作者的构造函数应该是:
PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
不是这个:
PrintWriter out = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));
另外,我本可以这样做:
BufferedWriter out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
我一定只是在BufferedWriter和PrintWriter之间感到困惑:P