提交粮情测试协议和流程

jiazx0107@163.com

2023-11-08 768308ab47041062d9e97745099784acf297286b

 src/main/java/com/fzzy/mqtt/MqttConsumerConfig.java

@@ -14,6 +14,9 @@

    @Autowired
    private MqttProperties mqttProperties;
    @Autowired
    private MqttConsumerCallBack mqttConsumerCallBack;

    /**
     * 客户端对象
     */
@@ -50,7 +53,8 @@
            //设置遗嘱消息的话题，若客户端和服务器之间的连接意外断开，服务器将发布客户端的遗嘱信息
            options.setWill("willTopic", (mqttProperties.getClientInId() + "与服务器断开连接").getBytes(), 0, false);
            //设置回调
            client.setCallback(new MqttConsumerCallBack());
            // client.setCallback(new MqttConsumerCallBack());
            client.setCallback(mqttConsumerCallBack);
            client.connect(options);
            //订阅主题
            //消息等级，和主题数组一一对应，服务端将按照指定等级给订阅了主题的客户端推送消息