政务云数据上传

xuhy

2025-05-06 be652e7453938c7537dbb73f3caff336e8325b8d

 ruoyi-service/ruoyi-jianguan/src/main/java/com/ruoyi/jianguan/mqtt/util/MqttPushUtil.java

@@ -30,8 +30,6 @@
     */
    public R<String> pushChargePileData(String topic, String message){
        try {
//            MqttPushUtil mqttConnect = new MqttPushUtil();
//            mqttConnect.start();
            //发布消息
            this.publish(topic,message);
            return R.ok("["+topic+"]-推送成功;内容为:["+message+"]");
@@ -43,18 +41,17 @@
    /**
     * 测试订阅消息
     */
    public static void main(String[] args) throws Exception {
        MqttPushUtil mqttConnect = new MqttPushUtil();
        mqttConnect.start();
        //订阅消息
        mqttConnect.publish("/cmt/IoT/pub/8/6700/status/silent","message11消息");
    }
//    public static void main(String[] args) throws Exception {
//        MqttPushUtil mqttConnect = new MqttPushUtil();
//        mqttConnect.start();
//        //订阅消息
//        mqttConnect.publish("/cmt/IoT/pub/8/6700/status/silent","message11消息");
//    }

    @Bean
    public MqttPushUtil getMqttPushClient() {
        //连接至mqtt服务器，获取mqtt连接
        MqttPushUtil mqttConnect = new MqttPushUtil();
        mqttConnect.start();
        this.start();
        return this;
    }
    /**