Mqtt second session -- emqx high availability cluster implementation

Main records of this paper mqtt-emqx High availability cluster setup

1. Cluster building

be based on liunx centos7,docker-comspoe,emqx:4.4.4.

1.1 docker-compose.yaml file

version: '3.7'
services:
  emqx01:
    image: emqx:4.4.4
    container_name: emqx01
    ports:
    - "1883:1883" #tcp Connect 
    - "18083:18083" # Console 
    - "8083:8083" # Console tools websocket ws use 
    - "8084:8084" # Console tools websocket wss use 
    environment:
    - TZ=Asia/Shanghai
    - EMQX_NAME=node01
    - EMQX_CLUSTER__DISCOVERY=static
    # Cluster nodes ip  Secure the container ip best 
    - [email protected],[email protected],[email protected]
    networks:
      my-net:
        ipv4_address: 172.19.0.221
  emqx02:
    image: emqx:4.4.4
    container_name: emqx02
    ports:
    - "1813:1883"
    - "18013:18083"
    - "8013:8083"
    - "8014:8084"
    environment:
    - TZ=Asia/Shanghai
    - EMQX_NAME=node02
    - EMQX_CLUSTER__DISCOVERY=static
    # Cluster nodes ip  Secure the container ip best 
    - [email protected],[email protected],[email protected]
    networks:
      my-net:
        ipv4_address: 172.19.0.222
  emqx03:
    image: emqx:4.4.4
    container_name: emqx03
    ports:
    - "1893:1883"
    - "18093:18083"
    - "8093:8083"
    - "8094:8084"
    environment:
    - TZ=Asia/Shanghai
    - EMQX_NAME=node03
    - EMQX_CLUSTER__DISCOVERY=static
    # Cluster nodes ip  Secure the container ip best 
    - [email protected],[email protected],[email protected]
    networks:
      my-net:
        ipv4_address: 172.19.0.223
networks:
  # New network   Internal service name call 
  my-net:
    external: true

Set fixed Intranet ip when , You can go through it first docker network inspect my-net Get the network segment of the specified network

1.2 Start the container

[[email protected] emqx-cluster]# docker-compose up -d
Recreating emqx01 ... done
Creating emqx02   ... done
Creating emqx03   ... done
[[email protected] emqx-cluster]# docker ps -a
CONTAINER ID        IMAGE               COMMAND                  CREATED             STATUS              PORTS                                                                                                                                                                     NAMES
4d45a3c5db23        emqx:4.4.4          "/usr/bin/docker-ent…"   9 seconds ago       Up 6 seconds        4369-4370/tcp, 5369/tcp, 6369-6370/tcp, 0.0.0.0:1883->1883/tcp, 8081/tcp, 8883/tcp, 0.0.0.0:8083-8084->8083-8084/tcp, 0.0.0.0:18083->18083/tcp, 11883/tcp                 emqx01
0b3f9987307b        emqx:4.4.4          "/usr/bin/docker-ent…"   9 seconds ago       Up 6 seconds        4369-4370/tcp, 5369/tcp, 6369-6370/tcp, 8081/tcp, 8883/tcp, 11883/tcp, 0.0.0.0:1813->1883/tcp, 0.0.0.0:8013->8083/tcp, 0.0.0.0:8014->8084/tcp, 0.0.0.0:18013->18083/tcp   emqx02
3c522f7bb76c        emqx:4.4.4          "/usr/bin/docker-ent…"   9 seconds ago       Up 6 seconds        4369-4370/tcp, 5369/tcp, 6369-6370/tcp, 8081/tcp, 8883/tcp, 11883/tcp, 0.0.0.0:1893->1883/tcp, 0.0.0.0:8093->8083/tcp, 0.0.0.0:8094->8084/tcp, 0.0.0.0:18093->18083/tcp   emqx03

1.3 Cluster console interface

2.springboot Integrate

Integration code in the last article
MQTT First words – Docker install emqx as well as Springboot Integrate emqx With , No post here .

mqtt client The connection is a single address connection , So the cluster can be composed of nginx forward , It is necessary to add heartbeat detection , The forwarding address is filled in the intranet IP, There is no need to open to the outside world .

That's all for this chapter .

Last one ：MQTT First words – Docker install emqx as well as Springboot Integrate emqx
Next ：MongoDB First words – Docker install MongoDB as well as Springboot Integrate MongoDB

Setting up one's body and learning first , Learning is based on reading