引入依赖
org.springframework.integration
spring-integration-mqtt
添加配置
在application.yml中添加如下：
mq:
host: tcp://192.168.1.144:1883
clientId: client_1
topic: root/system
qos: 2
username:
password:
timeout: 1000
keepalive: 20
参数说明：
host:你的mqtt服务地址
clientId:你的客户端ID(随意填写，不能重复)(对mq服务来说，订阅者和发布者都是客户端)
topic:订阅的主题
qos:QoS
username:用户名，可为空
password:密码，可为空
timeout:超时时长
keepalive: /solo_jm/article/details/103403534
QoS说明
0只会发送一次，不管成不成功
1未成功会继续发送，直到成功，可能会收到多次
2未成功会继续发送，但会保证只收到一次
编写配置类
新建类，添加如下注解
@Component
@ConfigurationProperties("mq")
添加如下字段并完善Getter Setter
private String h
