mqtt 服务端 java

MQTT 是一种轻量级的通信协议，它适用于物联网和其他低带宽、高延迟或不可靠网络的应用。在 Java 中，你可以使用 Eclipse Paho 提供的 MQTT 客户端库来实现 MQTT 服务端。

以下是一个简单的 MQTT 服务端示例，它可以监听客户端的连接并接收客户端发送的消息：

import org.eclipse.paho.mqtt.server.*;
import org.eclipse.paho.mqtt.server.persistence.MemorySubscriptionPersistence;

public class MqttServer {
    public static void main(String[] args) throws Exception {
        // 创建 MQTT 服务端
        MqttServer mqttServer = new MqttServer();

        // 创建 MQTT 服务端配置
        MemorySubscriptionPersistence subscriptionPersistence = new MemorySubscriptionPersistence();
        MqttDefaultFilePersistence dataStore = new MqttDefaultFilePersistence("mqtt-data");
        MqttServerPersistence persistence = new MemoryMqttServerPersistence(subscriptionPersistence, dataStore);
        MqttServerConfig config = new MqttServerConfig();
        config.setPersistence(persistence);

        // 启动 MQTT 服务端
        IMqttServer server = new MqttServerWrapper(config);
        server.start();

        // 监听客户端连接
        server.addConnectionListener(new ConnectionListener() {
            @Override
            public void onConnected(MqttServerConnection connection) {
                System.out.println("Client connected: " + connection.getClientId());
            }

            @Override
            public void onDisconnected(MqttServerConnection connection) {
                System.out.println("Client disconnected: " + connection.getClientId());
            }
        });

        // 监听客户端消息
        server.addPublishListener(new PublishListener() {
            @Override
            public void onPublish(MqttServerConnection connection, String topic, byte[] payload, MqttQoS qos) {
                System.out.println("Received message from client " + connection.getClientId() + ": " + new String(payload));
            }
        });

        // 等待 MQTT 服务端关闭
        server.awaitTermination();
    }
}

在上面的示例中，我们创建了一个 `MqttServer` 类来启动 MQTT 服务端，并使用 `MqttServerConfig` 对象配置了服务端的持久化存储和订阅存储。然后，我们添加了一个 `ConnectionListener` 监听客户端连接和断开事件，并添加了一个 `PublishListener` 监听客户端发送的消息。最后，我们等待 MQTT 服务端关闭。

请注意，此示例使用了 Eclipse Paho 提供的默认持久化存储和订阅存储实现。如果你需要更复杂的存储需求，你可以实现自己的存储接口并将其传递给 `MqttServerConfig` 对象。