java - 向 TCP 服务器指示 Java TCP 客户端已完成写入流

Question

我正在编写一个连接到 Golang TCP 服务器的 Java TCP 客户端。

服务器使用以下代码从客户端读取消息:

func (tcpHandler TCPHandler) getClientMsgBytes(connection *net.TCPConn) ([]byte, error) {
    clientMsgBytes, err := ioutil.ReadAll(connection)
    if err != nil {            
        return nil, err
    }       

    return clientMsgBytes, nil
}

我的客户端使用以下代码向服务器发送消息:

try (Socket socket = new Socket("localhost", 9000)) {
    byte[] message = getMessage();

    DataOutputStream outputStream = new DataOutputStream(socket.getOutputStream());

    outputStream.write(commandMessage);     

    // Read message from the sever...          
}

我的问题是服务器一直在等待客户端写入它的消息，即使在消息的所有字节都已写入流之后也是如此。这似乎是因为 ioutil.ReadAll 函数正在等待 io.EOF 错误作为停止从流读取的信号。

我如何告诉 Go 我已完成从 Java 写入 TCP 流？如果有帮助，我可以更改 Java TCP 客户端和 Golang TCP 服务器代码。

注意:服务器是这样写的，因为我们的 Go TCP 客户端使用以下代码:

func writeToConnection(connection *net.TCPConn, tcpCommand structs.TCPCommand) error {
    messageBytes, err := json.Marshal(tcpCommand)
    if err != nil {
        err = merry.Wrap(err)
        return err
    }

    _, err = connection.Write(messageBytes)
    if err != nil {
        err = merry.Wrap(err)
        return err
    }

    err = connection.CloseWrite()
    if err != nil {
        err = merry.Wrap(err)
        return err
    }

    return nil
}

Answer 1

调用shutdownOputput以匹配 Go 客户端中的代码。