可是程序一执行到同步块，就会connectionLost

如果在回调函数的同步块内出现了 `connectionLost` 的问题，可能是由于同步块中的代码执行时间过长，导致 MQTT 客户端的连接在同步块执行期间超时并断开。

为了避免这个问题，你可以将耗时操作移到同步块之外，或者使用异步处理方式。以下是对示例代码进行修改的建议：

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

public class MqttExample {
    private static Object lock = new Object();  // 同步锁

    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.setCallback(new MqttCallback() {
                @Override
                public void connectionLost(Throwable cause) {
                    System.out.println("Connection lost: " + cause.getMessage());
                }

                @Override
                public void messageArrived(String topic, MqttMessage message) throws Exception {
                    String payload = new String(message.getPayload());
                    System.out.println("Received message: " + payload);

                    // 异步处理 JSON 解析
                    new Thread(() -> {
                        synchronized (lock) {
                            // 在同步块中执行同步操作
                            processJson(payload);
                        }
                    }).start();
                }

                @Override
                public void deliveryComplete(IMqttDeliveryToken token) {
                    // 消息发布完成回调
                }
            });

            client.subscribe(topic);

            // 保持主线程运行，避免程序退出
            while (true) {
                Thread.sleep(1000);
            }
        } catch (MqttException | InterruptedException e) {
            e.printStackTrace();
        }
    }

    private static void processJson(String jsonString) {
        // 将 JSON 字符串解析为 JSON 对象
        JSONObject json = new JSONObject(jsonString);

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

在修改后的示例代码中，我们将 JSON 解析操作放在一个新的线程中进行，以避免阻塞回调函数的执行。在接收到 MQTT 消息后，我们创建一个新的线程，并在该线程中进行 JSON 解析操作。通过这种方式，可以使 JSON 解析操作与回调函数的执行异步进行，避免了阻塞回调函数导致连接丢失的问题。

同时，我们在主线程中添加了一个循环，以保持程序运行。这样可以避免主线程退出导致程序终止。

请注意，由于异步处理方式，可能会导致处理的顺序发生变化。如果需要保证消息的顺序性，你可以根据实际情况选择使用队列等数据结构来保存接收到的消息，并在适当的时机进行处理。

希望这次的修改能够解决你遇到的问题。如有其他疑问，请随时提出。