我有一个C ++服务器和两个客户端(红宝石和Java)。一切都在64位linux机器(java

1.7.0_17)上运行。ruby客户端可以正常工作，但是java版本会出现问题。

在Java中，我尝试将字符串从客户端发送到服务器。实际上，服务器收到了整个字符串，但是服务器认为还有更多东西要接收。

红宝石客户端看起来像这样：

socket = TCPSocket.open(@options[:host],@options[:port])

test = "Hello, World"

socket.puts test

socket.shutdown 1

response = socket.gets

这里的一切工作正常。红宝石客户端发送一个字符串。服务器接收该字符串并发送答复。

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();

客户端无法收到服务器的回复。因为套接字是关闭的。

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做类似socket.shutdownOutput();的事情。(红宝石：socket.shutdown

1)在看跌期权调用之后。我更改了java-client-code：

out.write(msg);

socket.shutdownOutput();

而且有效！

正如@Charly所说：我必须定义一个“协议”。就我而言，我不允许更改任何与通信相关的代码(在服务器和ruby客户端中)，因为另一组研究人员使用了此功能。所以我修改这样我的Java客户端，它确实的

确切 同样的事情在 精确的 同时红宝石客户端(如协议的东西)。