【转】在Spring Boot中使用MQTT

节选自：在Spring Boot中使用MQTT

为什么选择MQTT

MQTT的定义相信很多人都能讲的头头是道,本文章也不讨论什么高大上的东西,旨在用最简单直观的方式让每一位刚接触的同行们可以最快的应用起来

先从使用MQTT需要什么开始分析:

  1. 消息服务器
  2. 不同应用/设备之间的频繁交互
  3. 可能涉及一对多的消息传递

根据上面列举的这三点,我们大概可以了解到, MQTT最适合的场景是消息做为系统的重要组成部分,且参与着系统关键业务逻辑的情形

MQTT, 启动!

既然决定使用它,我们首先要研究的是如何让MQTT正常工作,毕竟它不是简单的在maven里加入个依赖就完事的

我们总共需要干如下两件事:

  1. 下载EMQX消息服务器, 作为broker
  2. 在maven中引入依赖
<dependency>  
 <groupId>org.springframework.integration</groupId>  
 <artifactId>spring-integration-mqtt</artifactId>  
 <version>5.3.2.RELEASE</version>  
</dependency>

完成上面两步后, 启动EMQX服务器, 正式进入我们的MQTT旅途

使用方式

在Spring Boot中使用MQTT的代码, 笔者总结了如下两种方式:

  1. 使用spring-integration的消息通道概念
  2. 使用传统的Client客户端概念

第一种会产生一定程度的心智负担,但在笔者成功搭配(抄袭+造轮子)自动注册后, 比后者要方便许多

在介绍具体代码之前, 我们先简单整理下使用中最常见的概念:

  • 主题: MQTT消息的主要传播途径, 我们向主题发布消息, 订阅主题, 从主题中读取消息并进行业务逻辑处理, 主题是消息的通道
  • 生产者: MQTT消息的发送者, 他们向主题发送消息
  • 消费者: MQTT消息的接收者, 他们订阅自己需要的主题, 并从中获取消息
  • broker: 消息转发器, 消息是通过它来承载的, EMQX就是我们的broker, 在使用中我们不用关心它的具体实现

其实, MQTT的使用流程就是: 生产者给主题发消息->broker进行消息的传递->订阅该主题的消费者拿到消息并进行相应的业务逻辑

发表评论