构建emqtt的集群

准备docker的镜像

• 
  
  wget -O emqtt-docker http://www.emqtt.com/downloads/2304/docker
  
  
• 
  
  docker import < emqtt-docker
  
  
• 
  
  #check emqtt-docker image name
  
  
• 
  
  docker images
  
  
• 
  
  #可以看到镜像名称为：emqttd-docker-v2.3-beta.4
  
  
  

运行emqtt-docker

• 
  
  emqttd_img=emqttd-docker-v2.3-beta.4
  
  
• 
  
  #emq nodes
  
  
• 
  
  docker run -tid --name emq1 $emqttd_img
  
  
• 
  
  docker run -tid --name emq2 $emqttd_img
  
  
  

简单的集群配置
进入emq1节点，运行emqttd_ctl status获得集群节点信息。

• 
  
  docker exec -it emq1 /bin/sh
  
  
• 
  
  /opt/emqttd $ emqttd_ctl status
  
  
• 
  
  Node '103a1d9fd0df@172.17.0.2' is started
  
  
• 
  
  #可以看到node名称为103a1d9fd0df@172.17.0.2
  
  
• 
  
  exit
  
  
  

进入到第二节点，并将两个节点join

• 
  
  /opt/emqttd $ docker exec -it emq2 /bin/sh
  
  
• 
  
  /opt/emqttd $ emqttd_ctl cluster join 103a1d9fd0df@172.17.0.2
  
  
• 
  
  Join the cluster successfully.
  
  
• 
  
  Cluster status: [{running_nodes,['103a1d9fd0df@172.17.0.2',
  
  
• 
  
                                   '3a605f1e13b5@172.17.0.3']}]
  
  
• 
  
  /opt/emqttd $ emqttd_ctl cluster status
  
  
  

使用负载均衡HAProxy

docker拉取haproxy

• 
  
  #pull haproxy
  
  
• 
  
  docker pull haproxy
  
  
  

构建emqtt-haproxy-docker

• 
  
  #https://hub.docker.com/_/haproxy/
  
  
• 
  
  mkdir emqtt-haproxy-docker
  
  
• 
  
  cd emqtt-haproxy-docker
  
  
  

创建haproxy的配置文件

• 
  
  touch haproxy.cfg
  
  
• 
  
  #内容如下(将IP地址改成emq1,emq2的ip地址)
  
  
• 
  
  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
  
  
• 
  
  
  
  
• 
  
  frontend emqtt-front
  
  
• 
  
    bind *:1883
  
  
• 
  
    mode tcp
  
  
• 
  
    default_backend emqtt-backend
  
  
• 
  
  
  
  
• 
  
  backend emqtt-backend
  
  
• 
  
     balance roundrobin
  
  
• 
  
     server emq1 172.17.0.2:1883 check
  
  
• 
  
     server emq2 172.17.0.2:1883 check
  
  
• 
  
  
  
  
• 
  
  frontend emqtt-admin-front
  
  
• 
  
    bind *:18083
  
  
• 
  
    mode http
  
  
• 
  
    default_backend emqtt-admin-backend
  
  
• 
  
  
  
  
• 
  
  backend emqtt-admin-backend
  
  
• 
  
    mode http
  
  
• 
  
    balance roundrobin
  
  
• 
  
    server emq1 172.17.0.2:18083 check
  
  
• 
  
    server emq2 172.17.0.3:18083 check
  
  
  

构建emqtt-haproxy的docker image

• 
  
  touch Dockerfile
  
  
• 
  
  echo FROM haproxy:latest > Dockerfile
  
  
• 
  
  echo COPY haproxy.cfg /usr/local/etc/haproxy/haproxy.cfg >> Dockerfile
  
  
• 
  
  docker build -t emqtt-haproxy .
  
  
  

检测配置并运行

• 
  
  docker run -it --rm --name haproxy-syntax-check emqtt-haproxy haproxy -c -f /usr/local/etc/haproxy/haproxy.cfg
  
  
• 
  
  
  
  
• 
  
  #请指定端口映射1833是tcp服务，18083是dashboard
  
  
• 
  
  docker run -d --name emqtt-running-haproxy -p 1883:1883 -p 18083:18083 emqtt-haproxy
  
  
  

使用MQTT.fx客服端测试

下载地址：http://mqttfx.jensd.de/index.php/download
选择local mosquitto，点击链接即可

访问emqtt的Dashboard

http://127.0.0.1:18083/#/

【转载】https://blog.csdn.net/wangshuminjava/article/details/81735322

奈斯