如何从插座上阅读JSON？爪哇

Question

我正在做服务器/客户端网络。消息作为JSON对象发送。 我有一种编写JSON-Object的方法，但是我读取JSON-Object的方法无效。我没有任何例外，但是没有像挖掘的输出。 BufferedReader一定有问题。我不知道如何从发送它的插座上获取JSON-OBJECT。 写作方法：

public void writeMessage(JSONObject json) {
        try {
            PrintWriter printWriter = new PrintWriter(
                    new OutputStreamWriter(
                            socket.getOutputStream())); 
            printWriter.print(json);
            printWriter.flush();

        } catch (IOException writeMessageException) {
            System.out.println("!");

        }
    }

阅读消息/接收消息的方法：

private static void readMessageFromServer(Socket socket) {
        try (BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()))) 
    {
         StringBuilder sb = new StringBuilder();
            String readLine;
            while ((readLine = br.readLine()) != null) {
                sb.append(readLine);
            }
            JSONObject js = new JSONObject(sb.toString());
        String action1 = (String) js.get("action1");
    System.out.println(action1);
    } catch(IOException e) {
        System.out.println("!");
    }
    }

谢谢:)

Answer 1

1. 考虑使用Javax Websocket。

.并指定您期望使用pojos接收的类型参数。

    @Override
public void onOpen(Session session, EndpointConfig config) {
    session.addMessageHandler(new MessageHandler.Whole<MyJsonObject>() {

        @Override
        public void onMessage(MyJsonObject message) {
        //do something
        }
    });
}

这样，您就可以创建一个侦听器（@OnMessage）并在收到的每条消息后立即处理。您还可以使用字符串类型参数来实现MessageHandler，并在onMessage方法中处理自己的JSON自己解析；

@Override
public void onOpen(Session session, EndpointConfig config) {
    session.addMessageHandler(new MessageHandler.Whole<String>() {

        @Override
        public void onMessage(String message) {
            MyJsonObject jObj = new ObjectMapper().readValue(message, MyJsonObject.class);
        }
    });
}

2. 如果您想坚持使用Java Net插座，请考虑切换到杰克逊对象映射器从jsonobject中，这样您就可以将输入流转换为任何对象：

    私有静态void readmessageFromServer（套接字插座）{
           inputStream in = socket.getInputStream（）;
           myObject obj = new ObjectMapper（）。readValue（in，MyObject.Class）; 
        }
    

更多javax websocket 示例

Answer 2

读取字节中的数据时，我们需要定义自己的协议，以进行服务器和客户端之间的通信。最简单的协议
我们可以定义称为TLV（类型长度值）。这意味着每个
*写入套接字的消息是类型长度值的形式 *。

因此，我们将发送的每个消息定义为：

代表数据类型的1个字节字符，例如字符串a
4指示数据长度的字节整数，然后
实际数据，其长度仅表示

DataInputStream in = new DataInputStream(new BufferedInputStream(socket.getInputStream()));
char dataType = in.readChar();
int length = in.readInt();
    if(dataType == 's') {
        byte[] messageByte = new byte[length];
        boolean end = false;
        StringBuilder dataString = new StringBuilder(length);
        int totalBytesRead = 0;
        while(!end) {
            int currentBytesRead = in.read(messageByte);
            totalBytesRead = currentBytesRead + totalBytesRead;
            if(totalBytesRead <= length) {
                dataString
                  .append(new String(messageByte, 0, currentBytesRead, StandardCharsets.UTF_8));
            } else {
                dataString
                  .append(new String(messageByte, 0, length - totalBytesRead + currentBytesRead, 
                  StandardCharsets.UTF_8));
            }
            if(dataString.length()>=length) {
                end = true;
            }
        }
    }

更多的详细信息可以在此处找到
https://wwwww.baeldung.com/java-input--inputstream-server-server-server-server-server-server-server-server-server-server-server-sercock