Emqx入门系列【1】emqx环境搭建

大家好，欢迎来到IT知识分享网。

一、EMQX是什么？

EMQ X 是一个高度可扩展的、分布式的 MQTT 消息服务器，适用于 IoT、M2M 和移动应用程序。它提供了完整的 MQTT 协议支持，包括 QoS 0、QoS 1、QoS 2 消息传输，以及 Last Will 和 Testament 功能。EMQ X 还支持插件扩展，可以方便地集成各种功能，如 SQL 数据库集成、Websocket 支持等。

EMQ X 特点：

• 高性能：EMQ X 可以处理数百万的并发客户端连接。
• 分布式：支持分布式运行，可以水平扩展以满足大规模部署需求。
• 插件系统：通过插件可以轻松扩展功能，如数据库集成、认证等。
• 完整的 MQTT 支持：遵循 MQTT 3.1、3.1.1 和 5 协议规范。
• 多种协议支持：除了 MQTT，还支持 CoAP、LwM2M、WebSocket 等协议。
• 安全性：支持 SSL/TLS 加密传输，以及多种认证机制。

二、EMQX安装

1.获取 EMQX：

从官方网站 EMQX 官网软件下载 下载最新版本的 EMQ X

1.1 选择对应系统与版本下载，其中有yum 、安装包类型（rpm 、 tar.zip ）

这里讲述下tar.zip 包安装方式

wget https://www.emqx.com/zh/downloads/broker/5.7.1/emqx-5.7.1-el7-amd64.tar.gz

 1.2  进行安装

mkdir -p emqx && tar -zxvf emqx-5.7.1-el7-amd64.tar.gz -C emqx

1.3启动

./emqx/bin/emqx start

1.3 服务状态与面板

2.注册成服务

2.1 创建一个emqx.service 放到conf文件夹下

[Unit] Description=EMQ X Broker After=network.target [Service] User=root Group=root ProtectProc=invisible Type=forking ExecStart=START_PATH start ExecStop=STOP_PATH stop Restart=on-failure [Install] WantedBy=multi-user.target 

2.2 编写安装与卸载脚本

install.sh

#!/bin/bash # int='\033[94m _______ _____ ______ ________ ___ ___ |\ ___ \ |\ _ \ _ \|\ __ \ |\ \ / /| \ \ __/|\ \ \\\__\ \ \ \ \|\ \ \ \ \/ / / \ \ \_|/_\ \ \\|__| \ \ \ \\\ \ \ \ / / \ \ \_|\ \ \ \ \ \ \ \ \\\ \ / \/ \ \_______\ \__\ \ \__\ \_____ \ / /\ \ \|_______|\|__| \|__|\|___| \__Y__/ /\ __\ \|__|__|/ \|__| \033[0m' echo -e "$int" # Get current directory CurDir=$(cd `dirname $0`;pwd) echo "CurDir :$CurDir" echo " home $HOME" chmod 777 -R $CurDir START_PATH="$CurDir/bin/emqx" STOP_PATH="$CurDir/bin/emqx" cp -r $CurDir/conf/emqx.service $CurDir/emqx.service sed -i "s%START_PATH%$START_PATH%g" $CurDir/emqx.service sed -i "s%STOP_PATH%$STOP_PATH%g" $CurDir/emqx.service # service copy cp -rf $CurDir/emqx.service /usr/lib/systemd/system/emqx.service echo emqx server is is add to service and setup to boot up systemctl daemon-reload #添加开机启动 systemctl enable emqx.service systemctl start emqx.service #开放端口号 firewall-cmd --zone=public --add-port=1883/tcp --permanent firewall-cmd --reload if [ $? -eq 0 ]; then echo emqx is install success exit 0 else echo emqx is install fail exit 1 fi 

uninstall.sh

#!/bin/bash # int='\033[94m _______ _____ ______ ________ ___ ___ |\ ___ \ |\ _ \ _ \|\ __ \ |\ \ / /| \ \ __/|\ \ \\\__\ \ \ \ \|\ \ \ \ \/ / / \ \ \_|/_\ \ \\|__| \ \ \ \\\ \ \ \ / / \ \ \_|\ \ \ \ \ \ \ \ \\\ \ / \/ \ \_______\ \__\ \ \__\ \_____ \ / /\ \ \|_______|\|__| \|__|\|___| \__Y__/ /\ __\ \|__|__|/ \|__| \033[0m' echo -e "$int" SERVICE_NAME=emqx systemctl --no-pager status $SERVICE_NAME if [ "$?" -ne 0 ] then echo " $SERVICE_NAME not install" else CurDir=$(cd `dirname $0`; pwd) #delete service PROXY_FILE="/usr/lib/systemd/system/${SERVICE_NAME}.service" if [ ! -f $PROXY_FILE ]; then echo "$SERVICE_NAME file is not exist in /usr/lib/systemd/system" else systemctl stop $SERVICE_NAME systemctl disable $SERVICE_NAME rm -rf $PROXY_FILE systemctl daemon-reexec if [[ "$OS_NAME" == "CentOS" || $CentOSVH -ge 7 ]];then systemctl daemon-reload fi rm -rf $CurDir/software/cms echo "$SERVICE_NAME is deleted from service" fi echo " " echo -e "\e[1;32m $SERVICE_NAME Service uninstalled succeed.\e[0m" echo " " fi 

 

3. 整体服务目录结构