这几天测试了MQTT的性能，个人觉得对比rabbitmq他有以下几个关键性的优点
- 安装简单并且集群也简单
- 建立topic的String字符串无需final类型，对比rabbitmq是需要final类型的
- 非常良好的支持动态建立topic，rabbitmq动态建立topic挺费劲
- 速度比rabbitmq快，并且比rabbitmq要轻量级
针对以上几点优点，物联网设备使用MQTT和服务器端通信是一个良好的选择
因为业务到了后期并发量肯定会上去的，因此需要集群下面是我搭建MQTT集群的步骤以及我踩过的一些坑
- 首先选择emqx的版本的时候务必选择3.2以下的版本，我现在选择的是3.1的版本，为什么这么说呢？因为从emqx3.2开始 如果按照emqx官方文档的说法，直接启动或者修改node.name节点的参数，无论怎么修改 ./emqx start 都会报一个 Node 'emqx@127.0.0.1(或其他IP地址)' not responding to pings. 的错出来，这个问题官方文档一直没有解释，因此为了避开这个坑，我们从要使用emqx3.1开始，这里我推荐一个下载网址给大家下载 https://www.emqx.io/downloads/broker/v3.1.1/
- 首先我们要准备三台服务器（或三台虚拟机）
将emqx3.1的zip包拷到centos从节点对应的目录然后解压，进入etc文件夹编辑emqx.conf
## 修改结点名，通常设置为 名字@ip
node.name = emqx@***.***.***.142
## 修改集群策略为static，无需手动添加节点了
cluster.discovery = static
## 所有集群节点
cluster.static.seeds = emqx@***.***.***.142, emqx@***.***.***.149
这里我使用的集群方式Haproxy，我这里首先使用docker的方式下载镜像并书写Dockerfile制作成容器
docker pull haproxy
编写haproxy.cfg文件
defaults
log global
option dontlognull
option http-server-close
retries 3
timeout http-request 10s
timeout queue 1m
timeout connect 10s
timeout client 1m
timeout server 1m
timeout http-keep-alive 10s
timeout check 10s
# front花呗渡边纲1883端口
frontend emqtt-front
bind *:1883
mode tcp
default_backend emqtt-backend
# backend分发前台请求
backend emqtt-backend
balance roundrobin
server emq1 ***.***.***.142:1883 check
server emq2 ***.***.***.149:1883 check
# dashboard控制面板
frontend emqtt-admin-front
bind *:18083
mode http
default_backend emqtt-admin-backend
backend emqtt-admin-backend
mode http
balance roundrobin
server emq1 ***.***.***.142:18083 check
server emq2 ***.***.***.149:18083 check
Dockerfile文件如下：
FROM haproxy:latest
COPY haproxy.cfg /usr/local/etc/haproxy/haproxy.cfg
然后制作新的cfg镜像
docker build -t haproxy-emqx .
然后开启容器
docker run -d --name emqx-haproxy -p 1883:1883 -p 18083:18083 haproxy-emqx
最后使用mqtt的客户端连接haproxy节点，然后进行发送接收测试，测试无误MQTT的集群即可搭建完成
image.png
