怎么在SpringBoot2.0中使用MQTT实现一个消息推送功能

今天就跟大家聊聊有关怎么在SpringBoot2.0中使用MQTT实现一个消息推送功能，可能很多人都不太了解，为了让大家更加了解，小编给大家总结了以下内容，希望大家根据这篇文章可以有所收获。

springboot是什么

springboot一种全新的编程规范，其设计目的是用来简化新Spring应用的初始搭建以及开发过程，SpringBoot也是一个服务于框架的框架，服务范围是简化配置文件。

 第一，pom配置，我们需要引入相关jar：        

<dependency>    <groupId>org.springframework.integration</groupId>    <artifactId>spring-integration-stream</artifactId></dependency><dependency>   <groupId>org.springframework.integration</groupId>   <artifactId>spring-integration-mQtt</artifactId></dependency>

        第二，配置MQTT服务器基本信息，在springBoot配置文件application.properties中配置，添加如下：

#MQTT配置信息#MQTT-用户名spring.mqtt.username=admin#MQTT-密码spring.mqtt.passWord=password#MQTT-服务器连接地址，如果有多个，用逗号隔开，如：tcp://127.0.0.1:61613，tcp://192.168.2.133:61613spring.mqtt.url=tcp://127.0.0.1:61613#MQTT-连接服务器默认客户端IDspring.mqtt.client.id=mqttId#MQTT-默认的消息推送主题，实际可在调用接口时指定spring.mqtt.default.topic=topic

    第三，配置MQTT消息推送配置类，

@Configuration@IntegrationComponentScanpublic class MqttSenderConfig {     @Value("${spring.mqtt.username}")    private String username;     @Value("${spring.mqtt.password}")    private String password;     @Value("${spring.mqtt.url}")    private String hostUrl;     @Value("${spring.mqtt.client.id}")    private String clientId;     @Value("${spring.mqtt.default.topic}")    private String defaultTopic;     @Bean    public MqttConnectOptions getMqttConnectOptions(){        MqttConnectOptions mqttConnectOptions=new MqttConnectOptions();        mqttConnectOptions.setUserName(username);        mqttConnectOptions.setPassword(password.toCharArray());        mqttConnectOptions.setServerURIs(new String[]{hostUrl});        mqttConnectOptions.seTKEepAliveInterval(2);        return mqttConnectOptions;    }    @Bean    public MqttPahoClientFactory mqttClientFactory() {        DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();        factory.setConnectionOptions(getMqttConnectOptions());        return factory;    }    @Bean    @ServiceActivator(inputChannel = "mqttOutboundChannel")    public MessageHandler mqttOutbound() {        MqttPahoMessageHandler messageHandler =  new MqttPahoMessageHandler(clientId, mqttClientFactory());        messageHandler.setAsync(true);        messageHandler.setDefaultTopic(defaultTopic);        return messageHandler;    }    @Bean    public MessageChannel mqttOutboundChannel() {        return new DirectChannel();    }}

        第四，配置MqttGateway消息推送接口类，在sendToMqtt(String data,@Header(MqttHeaders.TOPIC)String topic)接口中，data为发送的消息内容，topic为主题。指定topic，则我们的接口可以根据需要，向不同的主题发送消息，方便灵活应用。如果不指定，则使用默认配置的主题。

@MessagingGateway(defaultRequestChannel = "mqttOutboundChannel")public interface MqttGateway {    void sendToMqtt(String data,@Header(MqttHeaders.TOPIC) String topic);}

        最后，写个接口类测试下功能，用Postman调用sendMqtt.do接口，往hello主题发送消息，用MQTTLens订阅hello主题，从下面截图，可以看出可以正常往MQTT服务发送消息了，而且可以订阅到。

@RestController@RequestMapping("/test")public class TestController {     @Autowired    private MqttGateway mqttGateway;     @RequestMapping("/sendMqtt.do")    public String sendMqtt(String  sendData){        mqttGateway.sendToMqtt(sendData,"hello");        return "OK";    }}

看完上述内容，你们对怎么在SpringBoot2.0中使用MQTT实现一个消息推送功能有进一步的了解吗？如果还想了解更多知识或者相关内容，请关注编程网精选频道，感谢大家的支持。