RabbitMQ开启MQTT协议支持_rabbitmq 开启mqtt功能

started 1 plugins.
root@mq:/#

2）RabbitMQ管理控制台查看
如果插件启动成功，rabbitmq会打开1883和15675端口：

3）用MQTTX工具测试

4）用eclipse paho客户端测试
添加依赖
org.eclipse.paho org.eclipse.paho.client.mqttv3 1.2.5

收发消息测试

@RestController
public class DemoController {

@GetMapping(“/publish”)
public String publish() throws MqttException {

MqttClientPersistence persistence = new MemoryPersistence();;//内存持久化
MqttClient client = new MqttClient(“tcp://192.168.137.138:1883”, “abc”, persistence);

//连接选项中定义用户名密码和其它配置
MqttConnectOptions options = new MqttConnectOptions();
options.setCleanSession(true);//参数为true表示清除缓存，也就是非持久化订阅者