6

我有一个 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 客户端执行类似于 socket.shutdownOutput(); 的操作。(ruby: socket.shutdown 1) 在调用 puts 之后。我改变了java-client-code：

out.write(msg);
socket.shutdownOutput();

它有效！

正如@Charly 所说：我必须定义一个“协议”。在我的情况下，我不允许更改任何与通信相关的代码（在服务器和 ruby​​ 客户端中），因为该功能被另一组研究人员使用。因此，我必须以这种方式修改我的 java-client，使其在与 ruby​​-client完全相同的时间执行完全相同的操作（类似于协议）。

4

3 回答 3

2

PrintWriter 缓冲区（当 autoflush 为 true 时）仅通过调用 println 或 printf 来刷新。调用 print 可能不会刷新缓冲区 ( Javadoc )。尝试调用 println 或直接使用 OutputStreamWriter 和 flush()。请注意使用正确的字符集（您可以在 OutputStreamWriter 构造函数中设置它）。

于 2013-04-10T15:23:38.310 回答
0

分别关闭流以如下方式刷新它：

DataOutputStream dataOut = new DataOutputStream(socket.getOutputStream());
dataOut.writeUTF(s);
dataOut.flush();
于 2013-04-09T13:19:25.667 回答
0 
while ((recv_count = recv(SocketFD, buffer, sizeof(buffer) - 1, 0)) > 0) {
      if (recv_count == -1) {

我不知道你的问题是什么，但这段代码肯定是无稽之谈。内测是不可能成功的。

于 2013-04-10T10:45:42.610 回答