EMQ整合 springboot

### 整合EMQ与Spring Boot实现MQTT消息传递

对于Java应用程序而言，在整合EMQ X Broker（通常简称EMQ）与Spring Boot来实现在应用中利用MQTT协议进行的消息通信方面，可以遵循如下方法：

#### 添加依赖项
为了使项目能够支持MQTT客户端功能以及更好地同Spring框架集成，需在`pom.xml`文件里加入必要的库。

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

<!-- Paho MQTT Client -->
<dependency>
    <groupId>org.eclipse.paho</groupId>
    <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
    <version>${mqtt.version}</version>
</dependency>

上述配置引入了用于构建基于事件驱动架构的应用程序的支持包和Eclipse Paho提供的官方Java版MQTT客户端库[^1]。

#### 配置连接参数
创建一个新的类用来封装MQTT连接设置的信息，比如服务器地址、端口以及其他认证细节等。这有助于提高代码可读性和维护性的同时也方便后续调整这些属性而无需修改业务逻辑层的源码。

@ConfigurationProperties(prefix = "emqx")
public class MqttConfig {
    
    private String host;
    private int port;
    private String username;
    private String password;

    // Getters & Setters...
}

此部分并未直接提及任何具体的产品名称或版本号，而是通过自定义前缀的方式使得开发者可以在application.properties/yml文件内灵活指定实际使用的Broker服务实例的位置和其他必要选项[^2]。

#### 实现监听器模式接收消息
借助于Spring Integration所提供的Channel Adapter机制，很容易就能建立起一个响应型组件负责处理来自特定主题下的所有入站通知。下面给出了一种可能的设计思路：

@Component
@IntegrationComponentScan
@EnableIntegration
public class MessageReceiver {

    @ServiceActivator(inputChannel = "mqttInputChannel")
    public void handleMessage(Message<?> message) {
        System.out.println("Received message: " + new String((byte[])message.getPayload()));
    }
}

// Corresponding configuration bean definition omitted here.

这里采用@ServiceActivator注解标注的方法将会被自动注册成为目标通道上的消费者角色；每当有新的数据到达时就会触发对应的回调函数执行并打印出具体内容到控制台日志流上[^3]。

#### 发布新消息至指定Topic
最后一步就是编写发送方一侧的核心算法——即怎样把待传输的有效载荷打包成符合标准格式的数据帧再经由网络链路转发给远端节点。考虑到不同场景下可能会涉及到复杂的编码转换过程或是附加的安全措施等因素的影响，建议先单独设立辅助工具类来进行此类操作。

@Autowired
private MqttPahoClientFactory mqttClientFactory;

@Bean
public ApplicationRunner runner(MqttTemplate template){
    return args -> {
        template.convertAndSend("/test/topic", "Hello from Spring Boot!");
    };
}

这段示例展示了如何注入预配置好的工厂对象以便快速获取已初始化完毕的会话句柄，并调用其内置API完成向/test/topic发布一条简单问候语的任务[^4]。