centos EMQTTD 集群安装配置与测试验证

简介:

安装包下载地址:

1
http: //emqtt .com /downloads

在这里我们下载 emqttd-centos6.8-v2.1.2.zip



配置两台主机hosts

1
2
192.168.0.10  s1.emqtt.io
192.168.0.20  s2.emqtt.io


安装配置(s1.emqtt.io): 

1
2
3
4
5
6
7
8
  安装依赖包
  # yum install -y lksctp-tools
  
  安装
# unzip emqttd-centos6.8-v2.1.2.zip 
#cd emqttd
#vi etc/emq.conf
node.name = emqttd@s1.emqtt.io或node.name = emqttd@192.168.0.10

同理配置s2.emqtt.io,分别启动两台节点

1
2
3
4
5
6
7
8
9
10
启动
 
# bin/emqttd start
emqttd 2.1.2 is started successfully!
 
EMQ 消息服务器进程状态查询:
 
# ./bin/emqttd_ctl status
Node  'emqttd@s1.emqtt.io'  is started
emqttd 2.1.2 is running

加入集群

emqttd@s2.emqtt.io上执行:

1
2
3
# bin/emqttd_ctl cluster join emqttd@s1.emqtt.io
Join the cluster successfully.
Cluster status: [{running_nodes,[ 'emqttd@s1.emqtt.io' , 'emqttd@s2.emqqt.io' ]}]

或者 emqttd@s1.emqtt.io上执行:

1
2
3
4
#bin/emqttd_ctl cluster join emqttd@s2.emqtt.io
 
Join the cluster successfully.
Cluster status: [{running_nodes,[ 'emqttd@s1.emqtt.io' , 'emqttd@s2.emqtt.io' ]}]

任意节点上查询集群状态:

1
2
3
#bin/emqttd_ctl cluster status
 
Cluster status: [{running_nodes,[ 'emqttd@s1.emqtt.io' , 'emqttd@s2.emqtt.io' ]}]

节点退出集群

节点退出集群,两种方式:

  1. leave: 本节点退出集群

  2. remove: 从集群删除其他节点

emqttd@s2.emqtt.io主动退出集群:

1
2
3
#bin/emqttd_ctl cluster leave
Leave the cluster successfully.
Cluster status: [{running_nodes,[ 'emqttd@s2.emqqt.io' ]}]

或emqttd@s1.emqtt.io节点上,从集群删除emqttd@s2.emqtt.io节点:

1
#bin/emqttd_ctl cluster remove emqttd@s2.emqtt.io

防火墙设置

如果集群节点间存在防火墙,防火墙需要开启4369端口和一个TCP端口段。4369由epmd端口映射服务使用,TCP端口段用于节点间建立连接与通信。

防火墙设置后,EMQ 需要配置相同的端口段,emqttd/etc/emq.conf文件:

1
2
3
## Distributed node port range
node.dist_listen_min = 6000
node.dist_listen_max = 6999

注意事项: NetSplit

EMQ消息服务器集群需要稳定网络连接以避免发生NetSplit故障。集群设计上默认不自动处理NetSplit,如集群节点间发生NetSplit,需手工重启某个分片上的相关节点。


EMQTTD 集群验证

集群验证我们用Mosquitto进行验证《centos yum 安装Mosquitto

1
2
3
4
5
6
7
8
9
10
11
12
13
14
  10消息,20订阅
  
10写入消息
# mosquitto_pub -t topicTest07 -m Message05 -h 192.168.0.10 -p 1883
20订阅查看
# mosquitto_sub -v -t topicTest07 -h 192.168.0.20 -p 1883
topicTest07 Message05
 
  20消息,10订阅
20写入消息
# mosquitto_pub -t topicTest08 -m Message06 -h 192.168.0.20 -p 1883
10订阅查看
# mosquitto_sub -v -t topicTest08 -h 192.168.0.10 -p 1883
topicTest08 Message06


EMQTTD 状态监测

状态监测可通过自带的WEB进行监测

http://192.168.0.10:8083/status

wKiom1kRRNyAOFgrAAAWAgGLaWA265.png-wh_50

还有通过控制台:

http://192.168.0.10:18083

默认账户与密码:admin/public

wKioL1kRRSzj6X82AAEzeL_AdEk599.png-wh_50


控制台信息比较全,自己发现吧



本文转自 jackjiaxiong 51CTO博客,原文链接:http://blog.51cto.com/xiangcun168/1923607
相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
2月前
|
存储 缓存 算法
基于FPGA的图像双边滤波实现,包括tb测试文件和MATLAB辅助验证
基于FPGA的图像双边滤波实现,包括tb测试文件和MATLAB辅助验证
|
26天前
|
传感器 算法 计算机视觉
基于肤色模型和中值滤波的手部检测算法FPGA实现,包括tb测试文件和MATLAB辅助验证
该内容是关于一个基于肤色模型和中值滤波的手部检测算法的描述,包括算法的运行效果图和所使用的软件版本(matlab2022a, vivado2019.2)。算法分为肤色分割和中值滤波两步,其中肤色模型在YCbCr色彩空间定义,中值滤波用于去除噪声。提供了一段核心程序代码,用于处理图像数据并在FPGA上实现。最终,检测结果输出到"hand.txt"文件。
|
3月前
|
算法 异构计算
基于FPGA的图像高斯滤波实现,包括tb测试文件和MATLAB辅助验证
基于FPGA的图像高斯滤波实现,包括tb测试文件和MATLAB辅助验证
|
4月前
|
Web App开发 Java Linux
Nexus【部署 02】最新版本 nexus-3.35.0-02-unix.tar.gz 安装配置启动及测试(JDK版本+虚拟机参数配置说明)
Nexus【部署 02】最新版本 nexus-3.35.0-02-unix.tar.gz 安装配置启动及测试(JDK版本+虚拟机参数配置说明)
116 0
|
28天前
|
分布式计算 资源调度 Hadoop
Hadoop集群基本测试
Hadoop集群基本测试
22 0
|
1月前
|
编解码 算法 计算机视觉
基于FPGA的图像最近邻插值算法verilog实现,包括tb测试文件和MATLAB辅助验证
基于FPGA的图像最近邻插值算法verilog实现,包括tb测试文件和MATLAB辅助验证
|
2月前
|
算法 自动驾驶 计算机视觉
基于FPGA的图像Robert变换实现,包括tb测试文件和MATLAB辅助验证
基于FPGA的图像Robert变换实现,包括tb测试文件和MATLAB辅助验证
|
3月前
|
监控 算法 计算机视觉
基于FPGA的图像自适应阈值二值化算法实现,包括tb测试文件和MATLAB辅助验证
基于FPGA的图像自适应阈值二值化算法实现,包括tb测试文件和MATLAB辅助验证
|
3月前
|
并行计算 算法 异构计算
基于FPGA的图像拼接算法实现,包括tb测试文件和MATLAB辅助验证
基于FPGA的图像拼接算法实现,包括tb测试文件和MATLAB辅助验证
|
3月前
|
传感器 缓存 算法
基于FPGA的图像拉普拉斯变换实现,包括tb测试文件和MATLAB辅助验证
基于FPGA的图像拉普拉斯变换实现,包括tb测试文件和MATLAB辅助验证