spring和mqtt集成


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 消息發送

  


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM