emqx配置和安装.docx

EMQX 配置和安装指南 EMQX 是基于 Erlang/OTP 平台开发的开源物联网 MQTT 消息服务器。它的设计目标是实现高可靠，并支持承载海量物联网终端的 MQTT 连接，支持在海量物联网设备间低延时消息路由。EMQX 可以稳定承载大规模的 MQTT 客户端连接，单服务器节点支持 200 万连接。分布式节点集群，快速低延时的消息路由。消息服务器内扩展，支持定制多种认证方式、高效存储消息到后端数据库。 一、EMQX 安装 EMQX 的安装非常简单，首先需要下载安装包，下载地址是 https://www.emqx.io/zh/downloads。下载完成后，进入安装文件夹的 bin 文件夹内，执行命令 `emqx start` 启动 EMQX。然后，在浏览器中输入 `127.0.0.1:18083`，使用默认账号 `admin` 和密码 `public` 登录控制台界面。 二、EMQX 配置 EMQX 的配置主要分为两部分：客户端连接情况和规则引擎的使用。 客户端连接情况：EMQX支持多种认证方式，包括用户名和密码认证。可以在 `emqx/etc/emqx.conf` 文件中设置 `allow_anonymous = false` 来关闭匿名登录，然后在 `emqx/etc/plugins/emqx_auth_username.conf` 文件中设置用户名和密码。 规则引擎的使用：EMQX 的规则引擎可以在消息发布或事件触发时将触发规则引擎，满足触发条件的规则将执行各自的 SQL 语句筛选并处理消息和事件的上下文信息。可以点击新建规则，设置消息体内带有 flag=”hello” 属性的规则，并点击测试结果。 三、EMQX 测试工具 EMQX 提供了一个测试工具 mqtt.fx，可以点击安装，选择安装位置直接下一步即可。安装完成后，可以配置连接客户端，输入连接信息，点击连接，出现右侧绿色标识标识连接成功。 四、规则引擎的使用 EMQX 的规则引擎可以拦截消息，并将消息发送到 Web 服务。可以点击新建资源，选中 webhook，然后输入规则拦截后转发的 URL 以及路径等信息，并点击新建响应动作完成。 五、EMQX 的消息存储 EMQX 的消息存储可以使用 MySQL 数据库，创建一个名为 `emqx_history_20220612` 的表，表结构如下： CREATE TABLE `emqx_history_20220612` ( `msg_id` int(11) NOT NULL, `msg_body` text CHARACTER SET utf8 COLLATE utf8_general_ci NULL, `topic_name` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL, `creater` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL, `create_time` datetime(0) NULL DEFAULT NULL, PRIMARY KEY (`msg_id`) USING BTREE ); 可以使用 Node.js 写一个服务端接口来测试消息的存储。