使用mqtt协议，如何根据配置信息，分别建立监听程序和发布程序，java实现

在Java中使用MQTT协议进行客户端通信通常会涉及两个部分：一个用于订阅主题以接收消息（监听程序），另一个用于发送消息到特定主题（发布程序）。以下是一个简化的步骤：

**1. 添加依赖**
首先，你需要添加一个MQTT库，如`org.eclipse.paho.mqtt.client`或`com.hivemq.mqtt-client`。例如，如果你选择Paho MQTT客户端库，可以在Maven项目中加入相应的依赖：

<dependency>
    <groupId>org.eclipse.paho</groupId>
    <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
    <version>1.2.5</version>
</dependency>

**2. 创建监听程序 (Subscriber)**
创建一个监听主题的类，比如`MqttMessageListener`：

import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;

public class MqttSubscriber {
    private MqttClient client;

    public void connectAndSubscribe(String clientId, String brokerUrl, String topic, MqttCallback callback) {
        try {
            // 连接到MQTT服务器
            client = new MqttClient(brokerUrl, clientId);
            MqttConnectOptions options = new MqttConnectOptions();
            options.setCleanSession(true); // 是否清空连接后遗留的消息
            client.connect(options);

            // 订阅主题
            client.subscribe(topic, 0); // QoS level 0是最简单的方式

            // 设置回调处理接收到的消息
            client.setCallback(callback);
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }

    // ...其他必要的关闭连接等操作
}

在这个类中，你可以提供自定义的`MqttCallback`实现来处理接收到的消息。

**3. 创建发布程序 (Publisher)**
创建一个用于发送消息的类，比如`MqttPublisher`：

import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;

public class MqttPublisher {
    private MqttClient client;

    public void connectAndPublish(String clientId, String brokerUrl, String topic, String message) {
        try {
            // 连接到MQTT服务器
            client = new MqttClient(brokerUrl, clientId);
            MqttConnectOptions options = new MqttConnectOptions();
            options.setCleanSession(true);
            client.connect(options);

            // 发布消息
            client.publish(topic, message.getBytes(), 0, false); // QoS level 0, no retain flag

            // 关闭连接
            client.disconnect();
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }
}

现在，你可以根据需要配置不同的`clientId`、`brokerUrl`和`topic`，创建实例并调用相应的方法。

**