2. JEECG集成MQTT

1、整合jeecg 依赖

<!--mqtt依赖-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-integration</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-stream</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-mqtt</artifactId>
</dependency>

2、配置TT连接

hxx:
mqtt:
clientId: client-2
defaultTopic: mqtt_test_topic
# serverClientId: server-2
servers: tcp://192.168.7.110:1883
pwd: guest
username: guest

3、发送消息

@RequestMapping("/testMqtt")
@ResponseBody
public String sendMqtt(@RequestParam(value = "topic") String topic, @RequestParam(value = "message") String message) {
mqttGateway.sendMessage2Mqtt(message);
return "SUCCESS";
}

4、接收消息

@Bean
@ServiceActivator(inputChannel = "iotMqttInputChannel")
public MessageHandler handlerTest() {
return message -> {
try {
String string = message.getPayload().toString();
System.out.println("接收到消息：" + string);
} catch (MessagingException ex) {
//logger.info(ex.getMessage());
}
};

}
} catch (MessagingException ex) {
//logger.info(ex.getMessage());
}
};
}
} catch (MessagingException ex) {
//logger.info(ex.getMessage());
}
};
}