# 使用 EMQ X Cloud 规则引擎从 MySQL 中获取订阅关系

WARNING

该功能在基础版中不可用

在本文中我们将使用 EMQ X Cloud 规则引擎从 MySQL 中获取订阅关系

在开始之前,您需要完成以下操作:

  • 已经在 EMQ X Cloud 上创建部署(EMQ X 集群)。
  • 对于专业版部署用户:请先完成 对等连接的创建,下文提到的 IP 均指资源的内网 IP。

# MySQL 配置

  1. MySQL 安装

    docker run -d --restart=always \
      --name mysql \
      -p 3306:3306 \
      -e MYSQL_ROOT_PASSWORD=public \
      mysql/mysql-server:5.7
    
    1
    2
    3
    4
    5
  2. 数据库创建

    docker exec -it mysql mysql -uroot -ppublic
    CREATE DATABASE emqx;
    USE emqx;
    
    1
    2
    3
  3. 订阅关系表创建

    使用以下 SQL 语句将创建 mqtt_sub 表,该表将用于存放设备订阅关系数据。

    DROP TABLE IF EXISTS `mqtt_sub`;
    CREATE TABLE `mqtt_sub` (
        `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
        `clientid` varchar(64) DEFAULT NULL,
        `topic` varchar(180) DEFAULT NULL,
        `qos` tinyint(1) DEFAULT NULL,
        PRIMARY KEY (`id`),
        KEY `mqtt_sub_idx` (`clientid`,`topic`,`qos`),
        UNIQUE KEY `mqtt_sub_key` (`clientid`,`topic`),
        INDEX topic_index(`id`, `topic`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8MB4;
    
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11

    WARNING

    订阅关系表结构不能修改,请使用上面SQL语句创建

  4. 设置允许 EMQ X 集群 IP 段访问数据库(可选) 对于专业版部署,获取部署网段可以前往部署详情 → 查看对等连接信息,复制部署 VPC 网段。

    # 专业版
    GRANT ALL PRIVILEGES ON *.* TO root@'10.11.30.%' IDENTIFIED BY 'public' WITH GRANT OPTION;
    
    # 基础版
    GRANT ALL PRIVILEGES ON *.* TO root@'%' IDENTIFIED BY 'public' WITH GRANT OPTION;
    
    1
    2
    3
    4
    5
  5. 插入测试数据,并查看数据

    INSERT INTO mqtt_sub(clientid, topic, qos) values("test", "t1", 1);
    
    select * from mqtt_sub;
    
    1
    2
    3

# EMQ X Cloud 规则引擎配置

  1. 资源创建

    点击左侧菜单栏规则引擎,找到资源面板,点击新建资源,下拉选择 MySQL 资源类型。填入刚才创建好的 mysql 数据库信息,并点击测试如果出现错误应及时检查数据库配置是否正确。

    资源创建

  2. 规则填写

    点击左侧左侧菜单栏规则引擎,找到规则面板,点击创建,然后输入如下规则匹配 SQL 语句

    SELECT * FROM "$events/client_connected"
    
    1
  3. 添加响应动作

    点击左下角添加动作,下拉选择 → 代理订阅 → 从 MySQL 中获取订阅列表,选择第一步创建好的资源

    规则引擎

  4. 点击创建规则,并返回规则列表

    规则列表

  5. 查看规则监控

    查看监控

# 测试

  1. 在 MySQL 中插入订阅数据

    插入客户端 ID 为 client1,订阅主题 topic1,QoS 为 1 的订阅数据。

    INSERT INTO mqtt_sub(clientid, topic, qos) values("client1", "topic1", 1);
    select * from mqtt_sub;
    
    1
    2

  2. 使用 MQTT X (opens new window) 连接部署

    需要将 broker.emqx.io 替换成已创建的部署连接地址,并添加客户端认证信息

    其中,设定 clientID 为 client1

  3. 在部署详情中查看订阅关系

    进入部署详情在 监控 中查看客户端订阅关系