Java多线程通过mqtt发送消息

可以使用 Eclipse Paho Java 客户端库来实现Java多线程通过MQTT发送消息的功能。以下是一个简单的示例代码：

import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

public class MqttThread extends Thread {
    private String topic;
    private String content;
    private MqttClient client;

    public MqttThread(String topic, String content) {
        this.topic = topic;
        this.content = content;
    }

    @Override
    public void run() {
        String broker = "tcp://localhost:1883";
        String clientId = "JavaThreadClient";
        MemoryPersistence persistence = new MemoryPersistence();

        try {
            client = new MqttClient(broker, clientId, persistence);
            client.connect();
            MqttMessage message = new MqttMessage(content.getBytes());
            message.setQos(2);
            client.publish(topic, message);
            client.disconnect();
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }
}

在这个示例中，我们创建了一个 `MqttThread` 类，它包含了要发送的消息的主题和内容。当我们调用 `start()` 方法时，它会连接到本地 MQTT 代理，并将消息发布到指定的主题。请注意，这个示例中使用了 QoS 为 2 的消息发布。

可以通过以下方式来使用这个示例：

MqttThread thread1 = new MqttThread("topic1", "message1");
MqttThread thread2 = new MqttThread("topic2", "message2");
thread1.start();
thread2.start();

这里我们创建了两个 `MqttThread` 实例，并将它们分别启动，从而实现了多线程发送 MQTT 消息的功能。