java/mx_charging_pile.git

			@@ -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;
			}
			/**

	ruoyi-service/ruoyi-jianguan/src/main/java/com/ruoyi/jianguan/governmentCloud/SiteController.java	29 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	ruoyi-service/ruoyi-jianguan/src/main/java/com/ruoyi/jianguan/mqtt/util/MqttPushUtil.java	17 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史