0

我是 Java 套接字和进程的新手。我正在尝试从 TCP 套接字读取信息,但是当我收到数据时,某些信息未正确显示。(我认为这可能是一个编码问题,我正在读取的进程是 Genivi DLT 守护进程)。

这是我的代码示例:

try (Socket socket = new Socket(hostname, port)) {

            InputStream input = socket.getInputStream();
            InputStreamReader reader = new InputStreamReader(input);

            BufferedReader br1 = new BufferedReader(reader);         

            String line;


            while((line = br1.readLine())!=null) {
                String s = br1.readLine();
                byte[] utf8Bytes = s.getBytes("UTF-8");
                if(s.contains("SYS"))
                    System.out.println(s);
            }

这是一张应该如何显示数据的照片。

这是它实际显示到控制台的方式:

ÒWAVAè5ÓrQSYS ² (PathologyCollectorCPU.cpp: getLoad(...)@69): {"Name": "Core", "cpuName": "cpu0", "percent": 33, "totalUser": 1533306, "totalNice:" 0, "totalSys": 1216838, "totalIdle": 5681926}

有没有人知道为什么会这样,或者我应该采取一些方法来解决我的问题?

编辑:经过一番挖掘,我想我已经找到了一些关于协议的信息,在这里:https ://www.autosar.org/fileadmin/user_upload/standards/foundation/1-0/AUTOSAR_PRS_DiagnosticLogAndTraceProtocol.pdf第16页。如果你有进一步的建议,将不胜感激。

4

1 回答 1

-1

您正在使用 TCP(传输控制协议),它通过流通过网络发送数据。所以你需要为你发送的每个包定义“数据长度”。

当客户端/服务接收到该数据流时,它会根据“数据长度”值准确读取包的字节数。

您可以查看以下示例以获取更多详细信息:

private void __updateRecvHeaderData(byte[] bytes) {
    if (bytes.length >= Constants.HEADER_BYTES) { // header length
        byte[] header = Arrays.copyOfRange(bytes, 0, Constants.HEADER_BYTES);
        __dataSize = MessagePacker.byteToShort(header); // network to host short
        __recvHeader = false;
        // package = |2 bytes header| <content bytes> |
        byte[] data = Arrays.copyOfRange(bytes, Constants.HEADER_BYTES, __dataSize + Constants.HEADER_BYTES);
        __onRecvData(data); // recursion
    }
}

文件类可以在这里找到:TCP接收和分割流数据按数据长度

于 2020-03-11T05:53:38.740 回答