EMQ X(MQTT消息服务器)教程

2022-02-04

字数统计: 598字 | 阅读时长: 3分

EMQ X 是一款完全开源，高度可伸缩，高可用的分布式 MQTT 消息服务器，适用于 IoT、M2M 和移动应用程序，可处理千万级别的并发客户端。

一、安装

(1)EMQ X Docker 镜像安装

1	docker run -d --name emqx -p 1883:1883 -p 8081:8081 -p 8083:8083 -p 8883:8883 -p 8084:8084 -p 18083:18083 emqx/emqx

(2)Shell 脚本一键安装 (Linux)

1	curl https://repos.emqx.io/install_emqx.sh \| bash

(3)包管理器安装 (CentOS 7 为例)

#安装所需要的依赖包
sudo yum install -y yum-utils device-mapper-persistent-data lvm2
#使用以下命令设置稳定存储库
sudo yum-config-manager --add-repo https://repos.emqx.io/emqx-ce/redhat/centos/7/emqx-ce.repo
#安装最新版本的 EMQ X Broker
sudo yum install emqx

如果提示接受 GPG 密钥，请确认密钥符合 fc84 1ba6 3775 5ca8 487b 1e3c c0b4 0946 3e64 0d53，并接受该指纹。

二、启动

#直接启动
$ emqx start
emqx 4.0.0 is started successfully!

$ emqx_ctl status
Node 'emqx@127.0.0.1' is started
emqx v4.0.0 is running
#systemctl 启动
$ sudo systemctl start emqx
#service 启动
$ sudo service emqx start
#停止 EMQ X Broker
$ emqx stop
#重启 EMQ X Broker
$ sudo emqx restart
#卸载 EMQ X Broker
$ sudo yum remove emqx

三、配置

匿名认证 EMQ X 默认配置中启用了匿名认证，任何客户端都能接入 EMQ X,必须关闭匿名认证，MySQL认证/访问控制才能生效。
配置匿名认证开关：

# /etc/emqx/emqx.conf

## Value: true | false
allow_anonymous = true

1.开启MySQL认证/访问控制

(1) 设置配置文件

配置文件/etc/emqx/plugins/emqx_auth_mysql.conf

## MySQL server address.
##
## Value: Port | IP:Port
##
## Examples: 3306, 127.0.0.1:3306, localhost:3306
auth.mysql.server = 127.0.0.1:3308

## MySQL pool size.
##
## Value: Number
auth.mysql.pool = 8

## MySQL username.
##
## Value: String
auth.mysql.username =fff

## MySQL password.
##
## Value: String
auth.mysql.password =xxx

## MySQL database.
##
## Value: String
auth.mysql.database = mqtt

## MySQL query timeout
##
## Value: Duration
auth.mysql.query_timeout = 5s

(2)数据库和数据表 (密码默认是sha256加密)

CREATE TABLE `mqtt_user` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `username` varchar(100) DEFAULT NULL,
  `password` varchar(100) DEFAULT NULL,
  `salt` varchar(35) DEFAULT NULL,
  `is_superuser` tinyint(1) DEFAULT 0,
  `created` datetime DEFAULT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `mqtt_username` (`username`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8;

CREATE TABLE `mqtt_acl` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `allow` int(1) DEFAULT NULL COMMENT '0: deny, 1: allow',
  `ipaddr` varchar(60) DEFAULT NULL COMMENT 'IpAddress',
  `username` varchar(100) DEFAULT NULL COMMENT 'Username',
  `clientid` varchar(100) DEFAULT NULL COMMENT 'ClientId',
  `access` int(2) NOT NULL COMMENT '1: subscribe, 2: publish, 3: pubsub',
  `topic` varchar(100) NOT NULL DEFAULT '' COMMENT 'Topic Filter',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

(3)在dashboard中，插件—->emqx_auth_mysql,点击启动