wangwang
wangwang
文章45
标签44
分类5
RabbitMQ配置Mqtt协议

RabbitMQ配置Mqtt协议

步骤

1.启用插件

RabbitMQ安装默认不会启用MQTT插件,执行如下命令启用插件

rabbitmq-plugins enable rabbitmq_mqtt
rabbitmq-plugins list

2.配置权限

MQTT插件默认允许匿名访问,但不建议。
添加用户。 添加一个用户名和密码都是 “admin”的用户

rabbitmqctl add_user admin admin

设置用户读写权限

rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"
rabbitmqctl set_user_tags admin management

3.添加队列,绑定Exchange和Queues

插件基于exchanges 和 queues实现。也就是 MQTT消息是通过Exchange路由到相应的Queue中。

当Mqtt消息发布到MQTT topics时,会使用topic 类型的exchange (默认为amq.topic) 。订阅者通过队列(queues)获取Mqtt消息。

默认情况下,如果Queue不存在,会自动创建一个Auto-Delete类型的队列。

MQTT主题使用(“/“) 分隔;而AMQP 0-9-1使用点(“.”) 分隔。插件可以在不同协议之间转换,例如将“cities/london”转换成“cities.london”

本文作者:wangwang
本文链接:https://www.wangwangit.com/RabbitMQ%E9%85%8D%E7%BD%AEMqtt%E5%8D%8F%E8%AE%AE/
版权声明:本文采用 CC BY-NC-SA 3.0 CN 协议进行许可