验证 EMQ X 企业版规则引擎。
- 运行
docker-compose.yml
以启动 EMQ X。- 确保服务器对外暴露 1883、18083、8083 端口号
- 启动 kafka
- 启动 MySQL 5.7+
- 启动 RocketMQ 或者使用阿里云 RocketMQ 服务
- 启动当前项目
- 如果与 EMQ X 部署在同一台机器,需要修改项目端口号
相关 API 见 ResourceController
和 ActionController
。
相关 API 见 RuleController
。
MessageController
是用来接收data_to_webserver
规则的数据的data_to_kafka
规则的数据转发到 kafka 之后,可以使用com.ayla.emqxruleenginedemo.kafka
包的 consumer 来消费data_to_rocket
规则的数据转发到 kafka 之后,可以使用com.ayla.emqxruleenginedemo.rocketmq
包的 listener 来消费Constant
接口中描述了 EMQ X 企业版 4.3.3 版本所有支持的 action 和 resource_type