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