springboot集成mqtt的實踐開發(fā)
更新時間：2017年08月18日 09:24:43 作者：xixicat
本篇文章主要介紹了springboot集成mqtt的實踐開發(fā)，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
序
MQTT（Message Queuing Telemetry Transport）是基于二進制消息的發(fā)布/訂閱編程模式的消息協(xié)議，非常適合需要低功耗和網(wǎng)絡(luò)帶寬有限的IoT場景。這里簡單介紹一下如何在springboot中集成。
maven
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-integration</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-stream</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-mqtt</artifactId>
</dependency>
配置client factory
@Bean
public MqttPahoClientFactory mqttClientFactory() {
DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();
factory.setServerURIs("tcp://demo:1883");
// factory.setUserName("guest");
// factory.setPassword("guest");
return factory;
}
配置consumer
@Bean
public IntegrationFlow mqttInFlow() {
return IntegrationFlows.from(mqttInbound())
.transform(p -> p + ", received from MQTT")
.handle(logger())
.get();
}
private LoggingHandler logger() {
LoggingHandler loggingHandler = new LoggingHandler("INFO");
loggingHandler.setLoggerName("siSample");
return loggingHandler;
}
@Bean
public MessageProducerSupport mqttInbound() {
MqttPahoMessageDrivenChannelAdapter adapter = new MqttPahoMessageDrivenChannelAdapter("siSampleConsumer",
mqttClientFactory(), "siSampleTopic");
adapter.setCompletionTimeout(5000);
adapter.setConverter(new DefaultPahoMessageConverter());
adapter.setQos(1);
return adapter;
}
配置producer
@Bean
public IntegrationFlow mqttOutFlow() {
//console input
// return IntegrationFlows.from(CharacterStreamReadingMessageSource.stdin(),
// e -> e.poller(Pollers.fixedDelay(1000)))
// .transform(p -> p + " sent to MQTT")
// .handle(mqttOutbound())
// .get();
return IntegrationFlows.from(outChannel())
.handle(mqttOutbound())
.get();
}
@Bean
public MessageChannel outChannel() {
return new DirectChannel();
}
@Bean
public MessageHandler mqttOutbound() {
MqttPahoMessageHandler messageHandler = new MqttPahoMessageHandler("siSamplePublisher", mqttClientFactory());
messageHandler.setAsync(true);
messageHandler.setDefaultTopic("siSampleTopic");
return messageHandler;
}
配置MessagingGateway
@MessagingGateway(defaultRequestChannel = "outChannel")
public interface MsgWriter {
void write(String note);
}
這樣就大功告成了
doc
spring-integration-samples-mqtt
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要為大家詳細介紹了java如何通過SSE實現(xiàn)消息推送功能,文中的示例代碼講解詳細,感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-11-11
關(guān)于Java三大特性之多態(tài)的總結(jié)
這篇文章主要介紹了關(guān)于Java三大特性之多態(tài)的總結(jié)，內(nèi)容詳細，涉及多態(tài)的定義，存在條件，好處，分類及實現(xiàn)方式等相關(guān)內(nèi)容，具有一定參考價值，需要的朋友可以了解下。2017-11-11
這篇文章主要給大家介紹了關(guān)于我們說的CAS自旋鎖到底是什么的相關(guān)資料，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2018-05-05
Java 實現(xiàn)漢字轉(zhuǎn)換為拼音的實例
這篇文章主要介紹了Java 實現(xiàn)漢字轉(zhuǎn)換為拼音的實例的相關(guān)資料,需要的朋友可以參考下2016-12-12
Java與Oracle實現(xiàn)事務(wù)（JDBC事務(wù)）實例詳解
這篇文章主要介紹了Java與Oracle實現(xiàn)事務(wù)（JDBC事務(wù)）實例詳解的相關(guān)資料,需要的朋友可以參考下2017-05-05
這篇文章主要介紹了Java編程泛型限定的相關(guān)內(nèi)容，具有一定參考價值，需要的朋友可以了解下。2017-10-10
這篇文章主要介紹了ZIP4j 壓縮與解壓的實例詳解的相關(guān)資料,希望通過本文能幫助到大家，需要的朋友可以參考下2017-10-10
JavaWeb入門:ServletContext詳解和應(yīng)用
這篇文章主要介紹了Java ServletContext對象用法解析,文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2021-07-07
本文介紹了在SpringBoot項目中防止XSS攻擊的多種方法,包括輸入驗證和過濾、輸出編碼、使用安全框架、使用模板引擎的自動轉(zhuǎn)義功能以及設(shè)置安全HTTP頭等,感興趣的可以了解一下2024-12-12
Java多線程和并發(fā)基礎(chǔ)面試題（問答形式）
多線程和并發(fā)問題是Java技術(shù)面試中面試官比較喜歡問的問題之一。在這里，從面試的角度列出了大部分重要的問題，感興趣的小伙伴們可以參考一下2016-06-06