2022年在Springboot中使用MQTT收发不同主题的消息归类 .pdf

《2022年在Springboot中使用MQTT收发不同主题的消息归类 .pdf》由会员分享，可在线阅读，更多相关《2022年在Springboot中使用MQTT收发不同主题的消息归类 .pdf（4页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、在 SprintBoot 使用 MQTT 2018.4.7 在 Sprintboot 中使用 MQTT 分为三步：第一步定义一个收发数据的类给程序的其他类使用。public class XRemoteDevice private static XRemoteDevice instance = new XRemoteDevice(); public static XRemoteDevice getInstance() return instance; public void receive(Object topic, Object message) System.out.println(Topi

2、c: + topic); System.out.println(Payload + message); public boolean send(String topic, String message) try XServerContext.getGateway().sendToMqtt(message, topic); catch (Exception e) XLogger.getInstance().debug(Error When Sending + e); return false; return true; /* * Created by Lenovo on 2018/4/4. */

3、 MessagingGateway (defaultRequestChannel = mqttOutboundChannel) public interface MyGateway void sendToMqtt(String data,Header (MqttHeaders.TOPIC) String topic); 名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 1 页，共 4 页 - - - - - - - - - Component public class XServerC

4、ontext implements ApplicationContextAware private static ApplicationContext applicationContext = null ; Override public void setApplicationContext(ApplicationContext applicationContext) throws BeansException if (XServerContext.applicationContext = null ) XServerContext.applicationContext = applicati

5、onContext; public static MyGateway getGateway() return applicationContext.getBean(MyGateway. class ); 第二步在 pom 文件中引入 MQTT 。 org.springframework.boot spring-boot-starter-integration org.springframework.integration spring-integration-stream org.springframework.integration spring-integration-mqtt 第三步在

6、springboot主程序 main函数类中定义 MQTT 的 BEAN Bean public MqttPahoClientFactory mqttClientFactory() DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory(); factory.setServerURIs(config .getServer(); factory.setUserName(config .getName(); factory.setPassword(config .getPassword(); 名师资料总结 -

7、- -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 2 页，共 4 页 - - - - - - - - - return factory; / / The bean function （inbound）/ Bean public MessageChannel mqttInputChannel() return new DirectChannel(); Bean public MessageProducer inbound() MqttPahoMessageDrivenChannelAdapter adap

8、ter = new MqttPahoMessageDrivenChannelAdapter(config .getClientId(), mqttClientFactory(); adapter.setCompletionTimeout(5000); adapter.setConverter(new DefaultPahoMessageConverter(); adapter.setOutputChannel(mqttInputChannel(); for (String s : config .getTopics() adapter.addTopic(s, config .getQos();

9、 return adapter; Bean ServiceActivator(inputChannel = mqttInputChannel) public MessageHandler handler() return new MessageHandler() Override public void handleMessage(Message message) throws MessagingException XRemoteDevice.getInstance().receive(message.getHeaders().get(mqtt_topic), message.getPaylo

10、ad(); ; / / The bean function （outbound）/ Bean 名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 3 页，共 4 页 - - - - - - - - - ServiceActivator(inputChannel = mqttOutboundChannel) public MessageHandler mqttOutbound() MqttPahoMessageHandler messageHandler = new MqttPahoMes

11、sageHandler( config .getClientId(), mqttClientFactory(); messageHandler.setAsync(true ); messageHandler.setDefaultTopic(testTopic); return messageHandler; Bean public MessageChannel mqttOutboundChannel() return new DirectChannel(); 名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 4 页，共 4 页 - - - - - - - - -