Java 维护一个持久的 TCP 连接

Question

我正在尝试使用 TCP 从服务器向客户端发送多个数据。我只想为整个会话创建一个 TCP 连接。我该怎么做呢？

我尝试了以下流程的代码，但程序在收到第一个响应后停止。

客户端

1.create sockets and streams
2.send request for first data
3.wait for response from server
4.send next request <----------- server doesn't seem to handle this request
5.get next response from server

服务器端

1.Create server socket and wait for incoming connections
2.Parse incoming request
3.Send response
4.Parse next request
5.Send next response

当会话处于活动状态时，我不会关闭双方的套接字和流。

更新 这是我的代码sn-p： 客户

public void processRequest() throws Exception {

    Socket tempSocket = new Socket("0.0.0.0", 6782);

    String requestLine = "This is request message 1" + CRLF;

    DataOutputStream outToServer = new DataOutputStream(tempSocket.getOutputStream());            
    BufferedReader inFromServer = new BufferedReader(new InputStreamReader(tempSocket.getInputStream())); 

    outToServer.writeBytes(requestLine + CRLF);

    String serverResponse = inFromServer.readLine();
    System.out.println(serverResponse);

    requestLine = "This is request message 2" + CRLF;

    outToServer.writeBytes(requestLine + CRLF);

    serverResponse = inFromServer.readLine();
    System.out.println(serverResponse);

    outToServer.close();
    inFromServer.close();
    tempSocket.close();
}

服务器

public void processRequest() throws Exception {

    createConnections();

    String requestLine = inFromClient.readLine();
    System.out.println(requestLine);

    String responseLine = "This is the response to messsage 1";
    outToClient.writeBytes(responseLine + CRLF);

    requestLine = inFromClient.readLine();
    System.out.println(requestLine);

    responseLine = "This is the response to message 2";
    outToClient.writeBytes(responseLine + CRLF);
}

输出

客户：

This is the response to messsage 1
This is the response to message 2
BUILD SUCCESSFUL (total time: 1 second)

服务器：

This is request message 1

null
java.net.SocketException: Broken pipe

Answer 1

我认为问题出在您的客户端代码中。你写道：

    String requestLine = "This is request message 1" + CRLF;
    .....
    outToServer.writeBytes(requestLine + CRLF);

您将CRLF添加到requestLine，并在将其发送到服务器时再次添加。确保每条要发送的消息只添加一次 CRLF，它将按照您的意愿运行。