atom-spring-boot-starter-mqtt

Atom MQTT

<!-- 指定parent -->
<dependency>
	<groupId>net.wenzuo</groupId>
	<artifactId>atom-spring-boot-starter-mqtt</artifactId>
</dependency>

配置项

各个模块的配置项，可以在 application.yml 中覆盖

atom:
  mqtt:
    enabled: true # 是否启用 MQTT 模块
    id: default # 实例 ID
    url: tcp://broker.emqx.io:1883 # 服务器地址
    username: # 服务器用户名
    password: # 服务器密码
    client-id: # 客户端 ID
    instances: # MQTT 多实例配置
      - id: emqx1 # 实例 ID
        enabled: true # 是否启用
        url: tcp://broker.emqx.io:1883 # 服务器地址
        username: # 服务器用户名
        password: # 服务器密码
        client-id: # 客户端 ID

使用

订阅消息

1. 使用注解

@MqttListener(topics = "testtopic/#")
public void message(String topic, String message) {
	log.info("mqtt message: {} {}", topic, message);
}

2. 实现MqttSubscriber接口

发布消息

@RequiredArgsConstructor
@RequestMapping("/")
@RestController
public class TestController {

	private final MqttService mqttService;

	@RequestMapping("")
	public String test() {
		mqttService.send("testtopic/test", "test");
		return "test";
	}

}