mqtt 接收到json字符串消息打印，并将字符串作为参数传给json读取函数

当接收到 MQTT 消息后，你可以将其解析为 JSON 字符串，并将该字符串作为参数传递给 JSON 读取函数来处理。下面是一个示例代码：

import org.eclipse.paho.client.mqttv3.*;
import org.json.JSONObject;

public class MqttExample {
    public static void main(String[] args) {
        String broker = "tcp://mqtt.example.com:1883";  // MQTT 服务器地址
        String clientId = "your-client-id";  // 客户端ID
        String topic = "your-topic";  // 主题

        try {
            MqttClient client = new MqttClient(broker, clientId);
            client.connect();

            // 订阅消息
            client.subscribe(topic, (topic, message) -> {
                String payload = new String(message.getPayload());
                System.out.println("Received message: " + payload);

                // 将消息解析为 JSON 对象
                JSONObject json = new JSONObject(payload);

                // 调用 JSON 读取函数处理 JSON 对象
                processJson(json);
            });

            client.disconnect();
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }

    private static void processJson(JSONObject json) {
        // 在这里处理 JSON 对象，根据需要读取其中的字段值
        // 示例：读取名为 "name" 的字段
        String name = json.getString("name");
        System.out.println("Name: " + name);
    }
}

在上述示例代码中，我们使用了一个 Lambda 表达式来定义订阅消息时的回调函数。在回调函数中，我们首先将收到的 MQTT 消息转换为字符串 `payload`，然后将其解析为 JSON 对象 `json`。

接下来，我们调用 `processJson` 函数来处理 JSON 对象。你可以在该函数中根据需要读取和操作 JSON 中的字段。

请记得将示例中的 `broker`、`clientId` 和 `topic` 替换为你实际使用的值。另外，为了成功解析 JSON，你可能需要添加 JSON 解析库的依赖，比如 `org.json` 或者其他更常用的 JSON 解析库，具体取决于你的项目需求。