MQTT 须知

## MQTT 须知
经过优化，mqtt添加或修改订阅不需要找后端人员添加配置，也不需要重启docker或tomcat，具体如下：

------------

1. 程序启动时自动初始化mqtt连接自动订阅等,请参考 MQTT项目配置
2. 实时初始化mqtt，等同于程序启动一样的效果，请手动调用接口： http[s]://域名:端口/mqtt/init?pn=xxx/xxx
```java
  /**
   * 初始化
   * @param mqttContext 上下文
   * @throws Exception
   */
  public void initializer(MqttContext mqttContext) throws Exception {
      //调用后端初始化环境及订阅
      MqttUtil.initializer(getSubMqttConfig());
      //初始化发布客户端
      MqttUtil.createMqttClient(getPubMqttConfig(),true);
  }
```

3. 实时添加订阅主题，请手动调用接口：http[s]://域名:端口/mqtt/reload?pn=xxx/xxx
```java
/**
     * 重新加载(一般用来动态实时订阅)
     * @throws Exception
     */
    public void reload(MqttContext context) {
        //获取mqtt订阅配置(可以与初始化的配置一样，也可以单独只处理新的主题订阅)
        MqttItemConfig mqttConfig = getSubMqttConfig();
        //调用后端动态实时加载订阅主题
        MqttUtil.reload(mqttConfig);
    }
```

4.实时取消订阅主题或关闭客户端，请手动调用接口： http[s]://域名:端口/mqtt/close?pn=xxx/xxx&&clientId=mqtt1-9750557815017626eb98c47b37fba102

------------

这里clientId来自于mqtt服务端的控制台，如图：

![](/media/202405/2024-05-07_160835_077171.png)