SOB

基于 Spring Boot 实现 MQTT 通信

拉大锯

2025-04-23 09:36

当然可以，下面是一篇关于 基于 Spring Boot 实现 MQTT 通信 的技术文章，适合用于博客发布或项目文档说明。

基于 Spring Boot 实现 MQTT 通信的实践指南

一、前言

在物联网（IoT）领域，MQTT（Message Queuing Telemetry Transport）是一种轻量级、发布/订阅模式的消息传输协议，特别适合带宽低、不可靠网络的设备通信。它被广泛应用于智能家居、车联网、工业控制等场景。

Spring Boot 作为一个快速开发的框架，能够与 MQTT 无缝集成，帮助开发者快速构建稳定、高效的 MQTT 服务端或客户端。

本文将带你了解如何通过 Spring Boot 集成 MQTT，完成消息的发布与订阅。

二、环境准备

JDK 17+
Spring Boot 3.x
MQTT 服务器（如 EMQX、Mosquitto 等）
Maven 或 Gradle

三、引入依赖

我们使用 spring-integration-mqtt 模块，它封装了 MQTT 与 Spring 的集成。

Maven 示例：

xml

复制代码

<dependency>
  <groupId>org.springframework.integration</groupId>
  <artifactId>spring-integration-mqtt</artifactId>
</dependency>

四、配置文件 application.yml

yaml

复制代码

mqtt:
  username: admin
  password: public
  url: tcp://localhost:1883
  client-id: mqtt-client-001
  default-topic: test/topic

五、配置类

创建一个配置类 MqttConfig，用于配置 MQTT 客户端连接、消息通道等。

java

{ String payload = message.getPayload().toString(); System.out.println("接收到消息: " + payload); }; } // 出站通道（发布） @Bean public MessageChannel mqttOutboundChannel() { return new DirectChannel(); } // 出站消息处理器 @Bean @ServiceActivator(inputChannel = "mqttOutboundChannel") public MessageHandler mqttOutbound() { MqttPahoMessageHandler messageHandler = new MqttPahoMessageHandler(clientId + "_outbound", mqttClientFactory()); messageHandler.setAsync(true); messageHandler.setDefaultTopic(defaultTopic); return messageHandler; } }"> 复制代码

@Configuration
public class MqttConfig {

    @Value("${mqtt.url}")
    private String url;

    @Value("${mqtt.username}")
    private String username;

    @Value("${mqtt.password}")
    private String password;

    @Value("${mqtt.client-id}")
    private String clientId;

    @Value("${mqtt.default-topic}")
    private String defaultTopic;

    // 客户端工厂
    @Bean
    public MqttPahoClientFactory mqttClientFactory() {
        DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();
        MqttConnectOptions options = new MqttConnectOptions();
        options.setServerURIs(new String[]{url});
        options.setUserName(username);
        options.setPassword(password.toCharArray());
        factory.setConnectionOptions(options);
        return factory;
    }

    // 入站通道
    @Bean
    public MessageChannel mqttInputChannel() {
        return new DirectChannel();
    }

    // 入站适配器（订阅）
    @Bean
    public MessageProducer inbound() {
        MqttPahoMessageDrivenChannelAdapter adapter =
                new MqttPahoMessageDrivenChannelAdapter(clientId + "_inbound", mqttClientFactory(), defaultTopic);
        adapter.setOutputChannel(mqttInputChannel());
        return adapter;
    }

    // 消息处理器
    @Bean
    @ServiceActivator(inputChannel = "mqttInputChannel")
    public MessageHandler handler() {
        return message -> {
            String payload = message.getPayload().toString();
            System.out.println("接收到消息: " + payload);
        };
    }

    // 出站通道（发布）
    @Bean
    public MessageChannel mqttOutboundChannel() {
        return new DirectChannel();
    }

    // 出站消息处理器
    @Bean
    @ServiceActivator(inputChannel = "mqttOutboundChannel")
    public MessageHandler mqttOutbound() {
        MqttPahoMessageHandler messageHandler =
                new MqttPahoMessageHandler(clientId + "_outbound", mqttClientFactory());
        messageHandler.setAsync(true);
        messageHandler.setDefaultTopic(defaultTopic);
        return messageHandler;
    }
}

六、发布消息服务

java

复制代码

@Service
public class MqttSenderService {

    @Autowired
    private MessageChannel mqttOutboundChannel;

    public void sendMessage(String topic, String payload) {
        Message<String> message = MessageBuilder.withPayload(payload)
                .setHeader(MqttHeaders.TOPIC, topic)
                .build();
        mqttOutboundChannel.send(message);
    }
}

七、控制器示例

java

复制代码

@RestController
@RequestMapping("/mqtt")
public class MqttController {

    @Autowired
    private MqttSenderService senderService;

    @PostMapping("/publish")
    public String publish(@RequestParam String topic, @RequestParam String message) {
        senderService.sendMessage(topic, message);
        return "消息已发布";
    }
}

八、测试

启动本地 MQTT Broker（如 EMQX）
启动 Spring Boot 应用
访问接口：

bash

复制代码

curl -X POST "http://localhost:8080/mqtt/publish?topic=test/topic&message=HelloMQTT"

你将在控制台看到订阅端收到消息的输出。

九、总结

通过以上步骤，我们完成了基于 Spring Boot 的 MQTT 客户端开发，实现了消息的发布与订阅。这个方案具有以下优点：

易于集成、配置灵活
支持异步处理、性能优越
易于扩展，可接入 Kafka、Redis 等消息队列

MQTT + Spring Boot 的组合非常适合构建轻量级、高可靠的物联网平台。

如果你需要我帮你扩展成 Markdown 文档、添加部署脚本或结合 Docker，请随时告诉我！

"我视别人的钱财如粪土，但你的就不一样啦！"

本文由程序员拉大锯原创发布于阳光沙滩，未经作者授权，禁止转载

0 / 1024

什么是MCP? Monte Carlo Planning（蒙特卡洛规划）

MCP（Monte Carlo Planning，蒙特卡洛规划）是强化学习和决策系统中的重要方法，广泛应用于复杂环境下的行动策略规划。无论是博弈中的AI，还是机器人路径规划，MCP都能通过随机模拟预测未来策略的效果。其中，蒙特卡洛树搜索（MCTS）是其典型实现，具有强大的全局最优性和适应高维复杂策略的能力。文章详细解析了MCP的基本概念、与强化学习的关系、典型算法以及实际应用场景，展示了其在AlphaGo、自动驾驶、游戏AI等领域的卓越表现。

拉大锯围观点赞

智能体相关的概念介绍一下，并且给出学习路线！

智能体是人工智能领域的重要概念，广泛应用于强化学习、多智能体系统和机器人学等方向。本文从智能体的基本概念出发，介绍了其核心组成和分类，并提供了涵盖基础知识、模型理解、实践项目及前沿研究的系统学习路线。无论是初学者还是希望深入探索的研究者，都能从中找到有价值的信息和资源。

拉大锯围观点赞

基于 Spring Boot 实现 MQTT 通信

本文详细介绍了如何利用Spring Boot实现MQTT通信，包括环境准备、依赖配置、消息发布与订阅的完整流程。通过此指南，开发者能快速搭建高效稳定的MQTT服务，适用于物联网场景。无论是初学者还是资深开发者，都能从中受益。快来动手实践吧！

拉大锯围观点赞

Spring boot 实现Websocket通讯

本文档提供了一个基于Spring Boot的WebSocket简单示例，涵盖服务端与客户端的搭建及基本消息通信功能。通过本教程，开发者可快速掌握WebSocket在Spring Boot中的应用，适用于实时数据传输、在线聊天等场景。立即跟随步骤，轻松构建属于你的WebSocket应用！

拉大锯围观点赞

弱智吧经典语录，快看看看吧！

这些有趣的表达方式源自网络文化的独特风格，通过夸张、讽刺和离谱的情境，带来轻松幽默的体验。无论是‘装傻式开头’还是‘典中典’的调侃，都展现了年轻人在虚拟世界中创造的另类交流方式。快来一起感受这种独特的网络语言魅力吧！

黄大锤围观点赞

Java各个版本的发布时间，主要特性有哪些呢？

探索Java自1996年问世以来的发展历程，从早期版本的基础功能到现代化特性如Lambda表达式和虚拟线程，深入了解每个主要版本的核心更新。本文详细整理了各个版本的发布时间与关键特性，帮助开发者选择最适合自己项目的Java版本。无论你是初学者还是资深开发者，都能从中获取宝贵的参考信息，助你更高效地运用这一强大的编程工具。

黄大锤围观点赞

发个文章，看看能不能在动态里发出来呢？

分享了自己在编程学习中的有趣小故事，从儿时课堂上忘记保存代码的经历中寻找成长的乐趣，鼓励大家保持对编程的热情，同时也能引发读者对过去校园时光的共鸣。

拉大锯围观点赞

苏格拉底介绍一下吧

本文详细介绍了古希腊哲学奠基人苏格拉底的核心思想及其对西方哲学的巨大影响。从‘无知之知’到‘德性即知识’，再到批判精神，苏格拉底通过独特的问答法启发人们对真理的追求。他的思想通过柏拉图的记录得以传承，并深刻塑造了西方哲学传统。此外，本文还回顾了苏格拉底的重要人生经历，包括其著名的审判与死亡，以及他对后世哲学家和伦理学发展的深远影响。无论你是哲学爱好者还是追求智慧的人，这篇文章都将为你提供深刻的启示。

¹⁰³⁹

³⁹

¹⁰