【发布时间】:2020-02-16 11:46:19
【问题描述】:
我正在用 C# 编写多个客户端之间的聊天应用程序,这些客户端连接单个 Java 服务器。
所以我向服务器发送了一个用户的消息,服务器将这条消息发送给所有其他连接的用户。
每个客户端在服务器中都有不同的线程,在我的线程中;
public class ServerThread extends Thread {
private Server server;
private Socket sck;
InputStream receive;
OutputStream send;
public ServerThread(Server server, Socket s) {
this.server = server;
sck = s;
}
public void run() {
try {
handleClient();
} catch (IOException e) {
e.printStackTrace();
}
}
private void handleClient() throws IOException {
receive = sck.getInputStream();
send = sck.getOutputStream();
byte[] b = new byte[1024];
receive.read(b);
System.out.print(new String(b));
BufferedReader reader = new BufferedReader(new InputStreamReader(receive, "UTF-8"));
String line;
while((line = reader.readLine()) != null) {
if(line.equalsIgnoreCase("quit"))break;
List<ServerThread> clients = server.getClients();
for(ServerThread allClients : clients) {
allClients.send(line);
}
}
}
private void send(String message) {
try {
send.write(message.getBytes());
} catch (IOException e) {
e.printStackTrace();
}
}
}
而我的问题是:
当客户端向服务器发送一些东西时,我可以读取它;
byte[] b = new byte[1024];
receive.read(b);
System.out.print(new String(b));
我得到了我发送的正确字符串,但 BufferedReader 没有收到任何东西。 程序永远不会进入 while 循环,因为
line = reader.readLine();
没有读过任何东西,所以我不知道出了什么问题。为什么“InputStream#read(byte)”有效但“BufferedReader#readLine()”无效..?
这是我通过 C# 应用程序发送的内容;
byte[] text = System.Text.Encoding.UTF-8.GetBytes("test1212");
sck.Send(text);
这条消息有问题吗? :v
编辑: 即使在消息末尾有“\r\n”,我发送的缓冲也没有阅读它。我应该如何在消息中添加回车符?
希望有人能找出问题所在。
感谢您尝试帮助我。 (对不起,如果我犯了错误,我是法国人:l)
【问题讨论】:
-
我不知道 C# 部分到底是做什么的,但
readLine需要一行,即一些文本后跟一个换行符(或流的结尾) - Doc: "Reads a文本行。行被视为由换行符 ('\n')、回车符 ('\r')、回车符后紧跟换行符或到达末尾中的任何一个终止文件 (EOF)"
标签: java c# socket.io inputstream bufferedreader