> Java > java지도 시간 > 본문

SpringBoot가 MQTT 메시지 전송 및 수신을 구현하는 방법

WBOY
풀어 주다: 2023-05-12 21:31:12
앞으로
1945명이 탐색했습니다.

Spring 통합 상호작용 로직

게시자의 경우:

1 메시지는 메시지 게이트웨이를 통해 전송되며 MessageChannel DirectChannel 인스턴스가 전송 세부정보를 처리합니다. MessageChannel 的实例 DirectChannel 处理发送的细节。

2.DirectChannel 收到消息后,内部通过 MessageHandler 的实例 MqttPahoMessageHandler 发送到指定的 Topic。

对于订阅者:

1.通过注入 MessageProducerSupport 的实例 MqttPahoMessageDrivenChannelAdapter,实现订阅 Topic 和绑定消息消费的 MessageChannel

2.同样由 MessageChannel 的实例 DirectChannel 处理消费细节。

Channel 消息后会发送给我们自定义的 MqttInboundMessageHandler

2. DirectChannel이 메시지를 수신한 후 MessageHandlerMqttPahoMessageHandler 인스턴스를 통해 지정된 주제로 내부적으로 전송됩니다.

구독자의 경우:

1 MessageProducerSupportMqttPahoMessageDrivenChannelAdapter의 인스턴스를 삽입하여 주제를 구독하고 메시지를 바인딩하는 MessageChannel 소비가 실현됩니다.

2. 소비 세부정보는 MessageChannel의 인스턴스 DirectChannel에서도 처리됩니다.

채널 메시지는 소비를 위해 사용자 정의된 MqttInboundMessageHandler 인스턴스로 전송됩니다.

전체 처리 과정은 기본적으로 이전과 동일하다는 것을 알 수 있습니다. Spring Integration은 이러한 메시지 통신 메커니즘 세트를 추상화하고 특정 통신 세부사항은 통합하는 미들웨어에 의해 결정됩니다. MAMEN은 yaml 구성 파일 MQTT Consumer Configuration Class
<!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-integration -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-integration</artifactId>
    <version>2.5.1</version>
</dependency>
 
<!-- https://mvnrepository.com/artifact/org.springframework.integration/spring-integration-stream -->
<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-stream</artifactId>
    <version>5.5.5</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.springframework.integration/spring-integration-mqtt -->
<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-mqtt</artifactId>
    <version>5.5.5</version>
</dependency>
로그인 후 복사

7. 인터페이스 테스트

#mqtt配置
mqtt:
  username: 123
  password: 123
  #MQTT-服务器连接地址,如果有多个,用逗号隔开
  url: tcp://127.0.0.1:1883
  #MQTT-连接服务器默认客户端ID
  client:
    id: ${random.value}
  default:
    #MQTT-默认的消息推送主题,实际可在调用接口时指定
    topic: topic,mqtt/test/#
    #连接超时
  completionTimeout: 3000
로그인 후 복사

위 내용은 SpringBoot가 MQTT 메시지 전송 및 수신을 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

관련 라벨:
원천:yisu.com
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
인기 튜토리얼
더>
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿
회사 소개 부인 성명 Sitemap
PHP 중국어 웹사이트:공공복지 온라인 PHP 교육,PHP 학습자의 빠른 성장을 도와주세요!