我有一个C++服务器和两个客户端（Ruby和Java）。 所有东西都运行在64位的Linux机器上（Java 1.7.0_17）。 Ruby客户端完全正常，但是Java版本出现了问题。
在Java中，我尝试从客户端向服务器发送一个字符串。实际上，服务器接收到了整个字符串，但是服务器认为还有更多内容需要接收。
Ruby客户端看起来有点像这样：
socket = TCPSocket.open(@options[:host],@options[:port])
test = "Hello, World"
socket.puts test
socket.shutdown 1
response = socket.gets
这里的一切都正常工作。Ruby客户端发送一个字符串，服务器接收该字符串并回复。
Java版本如下：
String ip = "127.0.0.1";
int port = 6686;
java.net.Socket socket = new java.net.Socket(ip,port);
OutputStreamWriter out = new OutputStreamWriter(socket.getOutputStream());
InputStreamReader in = new InputStreamReader(socket.getInputStream());
String msg = "Hello, world!";
//send
PrintWriter pw = new PrintWriter(out, true);
pw.print(msg);
pw.flush();
// I also tried: out.write(msg); out.flush(); nothing changed
//receive the reply
BufferedReader br = new BufferedReader(in);
char[] buffer = new char[300];
int count = br.read(buffer, 0, 300);
String reply = new String(buffer, 0, count);
System.out.println(reply);
socket.close();
另一方面，有一个C++服务器：
string receive(int SocketFD) {
char buffer[SOCKET_BUFFER_SIZE];
int recv_count;
// empty messagestring
string message = "";
// empty buffer
memset(buffer, 0, sizeof(buffer));
while ((recv_count = recv(SocketFD, buffer, sizeof(buffer) - 1, 0)) > 0) {
/*if (recv_count == -1) {
cout << "failed." << endl;
break;
}*/
cout << recv_count << endl;
if (ECHO_SOCKETS) cout << "received: " << buffer << endl;
message.append(buffer);
memset(buffer, 0, sizeof(buffer));
if (ECHO_SOCKETS) cout << "message is now: " << message << endl;
}
return message;
}
Java消息的服务器输出为：
13
received: Hello, world!
message is now: Hello, world!
然后什么也没有发生。 问题在于：
recv(SocketFD, buffer, sizeof(buffer) - 1, 0)
如果程序陷入无限循环（或类似情况），则可以终止Java客户端进程，或输入如下内容：
pw.print(msg);
out.close();
服务器端的输出为：
_sending reply: "Request unrecognized/invalid" request="Hello, world!"
send reply success
now close connection
这个输出是正确的（除了“发送回复成功”），但如果添加以下内容：
out.close();
客户端无法接收服务器的回复，因为Socket已关闭。
java.net.SocketException: Socket is closed
at java.net.Socket.getInputStream(Socket.java:864)
at MyServer.writeMessage(MyServer.java:56)
at MyServer.test(MyServer.java:42)
at MyServer.main(MyServer.java:30)
编辑
我尝试了调用 pw.flush() 以及不同的分隔符如 "\n"、"\r"、"\r\n" 和 "\n\r"，但服务器仍然认为还有数据需要读取。我还尝试使用 DatagramSockets：
java.net.DatagramSocket dSocket = new java.net.DatagramSocket();
InetAddress address = InetAddress.getByName("localhost");
String msg = "Hello, world!";
byte[] buf = msg.getBytes();
java.net.DatagramPacket packet = new DatagramPacket(buf, buf.length, address, 6686);
但是服务器无法接受数据包。
解决方案
ruby-client在调用puts后会执行像socket.shutdownOutput()这样的操作（ruby: socket.shutdown 1）。我修改了java-client代码：
out.write(msg);
socket.shutdownOutput();
而且它还可以正常工作！
就像@Charly所说的那样：我必须定义一个“协议”。在我的情况下，我不能改变任何与通信相关的代码（服务器和ruby客户端）因为这个功能被另一组研究人员使用。因此，我必须修改我的java客户端，使其在确切相同的时间内执行确切相同的操作，就像一个协议一样。