InputStream 和 BufferedReader
InputStream and BufferedReader
我正在用 C# 在连接单个 Java 服务器的多个客户端之间创建一个聊天应用程序。
所以我通过其中一个用户向服务器发送一条消息,服务器将这条消息发送给所有其他连接的用户。
每个客户端在服务端有不同的Thread,在我有的线程中;
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”,我发送的 Buffered 也没有读取它。我应该如何将回车符 return 添加到消息中?
希望有人能找出问题所在。
感谢您的帮助。
(对不起,如果我犯了错误,我是法国人:l)
阅读 javadoc:BufferedReader.readLine()
"... 读取一行文本。一行被认为是由换行符 ('\n')、回车 return ('\r')、或一个回车符 return 后紧跟一个换行符。 ..."
您的行没有行尾。 BufferedReader 等待它。
我正在用 C# 在连接单个 Java 服务器的多个客户端之间创建一个聊天应用程序。
所以我通过其中一个用户向服务器发送一条消息,服务器将这条消息发送给所有其他连接的用户。
每个客户端在服务端有不同的Thread,在我有的线程中;
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”,我发送的 Buffered 也没有读取它。我应该如何将回车符 return 添加到消息中?
希望有人能找出问题所在。
感谢您的帮助。 (对不起,如果我犯了错误,我是法国人:l)
阅读 javadoc:BufferedReader.readLine()
"... 读取一行文本。一行被认为是由换行符 ('\n')、回车 return ('\r')、或一个回车符 return 后紧跟一个换行符。 ..."
您的行没有行尾。 BufferedReader 等待它。