mqtt 单对单发消息

使用 MQTT 协议进行单对单消息传递，需要在 MQTT 客户端连接到 MQTT 服务器，并且订阅接收消息的主题（topic）。然后，客户端可以通过发布消息到特定主题来向其他客户端发送消息。以下是实现 MQTT 单对单消息传递的示例代码：

1. 连接到 MQTT 服务器

String clientId = "client_id";  // 客户端标识符，可以自己定义
MqttClient mqttClient = new MqttClient("tcp://mqtt_server_ip:1883", clientId);
mqttClient.connect();

2. 订阅接收消息的主题

String topic = "my/topic";  // 订阅的主题名称
mqttClient.subscribe(topic);

3. 发布消息到指定主题

String message = "hello, world";  // 待发送的消息内容
MqttMessage mqttMessage = new MqttMessage(message.getBytes());
mqttClient.publish(topic, mqttMessage);

4. 处理接收到的消息

mqttClient.setCallback(new MqttCallback() {
    @Override
    public void connectionLost(Throwable cause) {
        // 连接丢失处理
    }

    @Override
    public void messageArrived(String topic, MqttMessage message) throws Exception {
        // 处理接收到的消息
        String content = new String(message.getPayload());
        System.out.println("Received message: " + content);
    }

    @Override
    public void deliveryComplete(IMqttDeliveryToken token) {
        // 消息传递完成处理
    }
});

注意：在实际应用中，需要根据具体需求进行适当的调整，例如，设置 QoS 等级来确保消息传递的可靠性，同时还需要考虑消息的格式和内容等问题。