mqtt服务器群发给客户端代码 java

以下是Java中使用 Eclipse Paho MQTT 客户端库向多个客户端群发消息的示例代码：

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

public class MqttServer {
    private static final String BROKER_URL = "tcp://localhost:1883";
    private static final String TOPIC = "test";
    private static final String MESSAGE = "Hello, clients!";

    public static void main(String[] args) {
        MemoryPersistence persistence = new MemoryPersistence();

        try {
            // 创建 MQTT 客户端实例
            MqttClient client = new MqttClient(BROKER_URL, MqttClient.generateClientId(), persistence);

            // 创建 MQTT 连接选项
            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setCleanSession(true);

            // 连接到 MQTT 代理
            System.out.println("连接到 MQTT 代理: " + BROKER_URL);
            client.connect(connOpts);
            System.out.println("已连接");

            // 创建消息
            MqttMessage message = new MqttMessage(MESSAGE.getBytes());
            message.setQos(2);

            // 发布消息给所有订阅者
            MqttTopic topic = client.getTopic(TOPIC);
            MqttDeliveryToken[] deliveryTokens = topic.publish(message, null);
            for (MqttDeliveryToken token : deliveryTokens) {
                token.waitForCompletion();
            }

            // 断开 MQTT 连接
            client.disconnect();
            System.out.println("已断开连接");
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }
}

在上述代码中，我们首先创建了一个 MQTT 客户端实例，然后使用连接选项连接到 MQTT 代理。然后，我们创建了要发送的消息，将其发布到指定的主题，然后将其发送给所有订阅该主题的客户端。最后，我们断开了与 MQTT 代理的连接。

请注意，此代码仅用于演示目的，并且需要根据您的实际需求进行修改。在实际应用中，您需要根据实际情况处理各种异常，并确保消息的安全传输。