码迷,mamicode.com
首页 > 编程语言 > 详细

spring和mqtt集成

时间:2018-09-21 15:04:54      阅读:352      评论:0      收藏:0      [点我收藏+]

标签:方法   ESS   www   框架   abs   str   odi   bst   发送   

spring框架和mqtt集成的方式

  借鉴网络上部分开发文档

  配置文件: spring-mtqq.xml

  

  • <?xml version="1.0" encoding="UTF-8"?>
  • <beans xmlns="http://www.springframework.org/schema/beans"
  • xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:int="http://www.springframework.org/schema/integration"
  • xmlns:context="http://www.springframework.org/schema/context"
  • xmlns:int-mqtt="http://www.springframework.org/schema/integration/mqtt"
  • xsi:schemaLocation="
  • http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration-4.1.xsd
  • http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.1.xsd
  • http://www.springframework.org/schema/integration/mqtt http://www.springframework.org/schema/integration/mqtt/spring-integration-mqtt-4.1.xsd
  • http://www.springframework.org/schema/context
  • http://www.springframework.org/schema/context/spring-context-4.1.xsd">
  • <bean id="clientFactory"
  • class="org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory">
  • <property name="userName" value="username"/>
  • <property name="password" value="password"/>
  • <property name="connectionTimeout" value="10"/>
  • <property name="keepAliveInterval" value="20"/>
  • <property name="serverURIs">
  • <array>
  • <value>url</value>
  • </array>
  • </property>
  • </bean>
  • <bean id="mqttHandler" class="org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler">
  • <constructor-arg name="clientId" value="cilentId"/>
  • <constructor-arg name="clientFactory" ref="clientFactory"/>
  • <property name="defaultQos" value="1"/>
  • <property name="defaultRetained" value="true"/>
  • </bean>
  • </beans>

  点击查询DefaultMqttPahoClientFactory类将需要的属性配置;

  点击查询MqttPahoMessageHandler、AbstractMqttMessageHandler将需要的属性配置;

  代码调用:

  引入 mqttHandler 调用其handlerMessage(message)方法将Message 消息发送

  

spring和mqtt集成

标签:方法   ESS   www   框架   abs   str   odi   bst   发送   

原文地址:https://www.cnblogs.com/1024ToAdmin/p/9686115.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!