RabbitMQ使用MQTT协议

Edited on In

开启 mqtt 插件

1
~/rabbitmq-server/sbin/rabbitmq-plugins enable rabbitmq_mqtt

配置

1
vim ~/rabbitmq-server/etc/rabbitmq/rabbitmq.conf

写入配置

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
mqtt.listeners.tcp.1 = 1883
mqtt.listeners.tcp.2 = 1884
# 匿名用户的用户名密码
mqtt.default_user = guest
mqtt.default_pass = guest
# 不允许匿名用户访问
mqtt.allow_anonymous = false
mqtt.vhost = /
mqtt.exchange = amq.topic
# 默认24小时，可以配置 undefined
mqtt.subscription_ttl = 1800000
# 将被传递的未确认消息的最大数量
mqtt.prefetch = 10
# 新集群可用 quorum模式
mqtt.durable_queue_type = quorum
# 保留消息存储不会复制到集群其它节点
# 磁盘存储保留消息（最大2G）
# mqtt.retained_message_store = rabbit_mqtt_retained_msg_store_dets
# 内存存储保留消息
mqtt.retained_message_store = rabbit_mqtt_retained_msg_store_ets
# only used by DETS store
mqtt.retained_message_store_dets_sync_interval = 2000

创建用户和 vhost

1
2
3
4
5
6
7
8
9
10
11
# 创建 bhost
~/rabbitmq-server/sbin/rabbitmqctl add_vhost ，mqtt_vhost
# 修改guest的密码
~/rabbitmq-server/sbin/rabbitmqctl list_users
~/rabbitmq-server/sbin/rabbitmqctl change_password guest guest
# 创建其他管理员账号比如test/test：
~/rabbitmq-server/sbin/rabbitmqctl add_user maxzhao maxzhao
#
~/rabbitmq-server/sbin/rabbitmqctl set_user_tags maxzhao administrator
# /是 vhost的目录  Configure regexp   Write regexp  Read regexp
~/rabbitmq-server/sbin/rabbitmqctl set_permissions -p / maxzhao ".*" ".*" ".*"

客户端接入

1
2
username：mqtt_vhost:maxzhao
password：maxzhao

RabbitMQ 不支持 Qos2，会被降级到Qos1。

本文地址： https://github.com/maxzhao-it/blog/post/c4ae7068/