MQTT——EMQX学习笔记06—

目录标题

- 一、开启WebHook插件
- 二、绑定web服务器
- 三、配置事件规则
- 四、创建web服务器
- （一）导入pom依赖
- （二）改yml
- （三）代码
- （四）测试

一、开启WebHook插件

这个功能是由emqx_web_hook插件提供支持的。WebHook有什么用，它用于监控一些规则，比如发布、订阅消息。当监控到这些规则触发时，会向web服务器（spring boot项目）发送一些数据（消息）。

这个功能是默认关闭的，我们先去开启这个功能。
在这里插入图片描述

二、绑定web服务器

[root@iz2zedg4ylq9iqtwm11wecz plugins]# pwd
/my/emqx/conf/etc/plugins
[root@iz2zedg4ylq9iqtwm11wecz plugins]# ls
acl.conf.paho          emqx_lua_hook.conf
emqx_auth_http.conf    emqx_lwm2m.conf
emqx_auth_jwt.conf     emqx_management.conf
emqx_auth_ldap.conf    emqx_prometheus.conf
emqx_auth_mnesia.conf  emqx_psk_file.conf
emqx_auth_mongo.conf   emqx_recon.conf
emqx_auth_mysql.conf   emqx_retainer.conf
emqx_auth_pgsql.conf   emqx_rule_engine.conf
emqx_auth_redis.conf   emqx_sasl.conf
emqx_bridge_mqtt.conf  emqx_sn.conf
emqx_coap.conf         emqx_stomp.conf
emqx_dashboard.conf    emqx_telemetry.conf
emqx_exhook.conf       emqx_web_hook.conf
emqx_exproto.conf
[root@iz2zedg4ylq9iqtwm11wecz plugins]# vim emqx_web_hook.conf
# 将web.hook.url 修改为自己web服务器（spring boot项目的请求地址）的地址。
# web.hook.url = http://127.0.0.1:8088/mqtt/webhook

在这里插入图片描述

注意：1、重启emqx
2、这里的IP地址根据自己的进行填写，如果是docker安装的emqx，一定不是127.0.0.1

[root@iz2zedg4ylq9iqtwm11wecz plugins]# docker restart myemqx
myemqx

三、配置事件规则

# 文件所在位置：/etc/plugins/emqx_web_hook.conf

在这里插入图片描述
事件规则的详情可以查看官网

## 格式示例
web.hook.rule.<Event>.<Number> = <Rule>## 示例值
web.hook.rule.message.publish.1 = {"action": "on_message_publish", "topic": "a/b/c"}
web.hook.rule.message.publish.2 = {"action": "on_message_publish", "topic": "foo/#"}

四、创建web服务器

直接创建spring boot项目即可

（一）导入pom依赖

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency>
</dependencies>

（二）改yml

# 注意这个端口号必须跟配置文件里面的一致
# /etc/plugins/emqx_web_hook.conf
# web.hook.url = http://127.0.0.1:8088/mqtt/webhoo
server.port=8088

（三）代码

在这里插入图片描述

package com.lihua.webhook.controller;import org.springframework.web.bind.annotation.*;import java.util.HashMap;
import java.util.Map;/*** @author hs* @date 2021/10/26 17:32*/
@RestController
@RequestMapping("/mqtt")
public class WebHookController {private Map<String,Boolean> clientStatus = new HashMap<>();@PostMapping("/webhook")public void hook(@RequestBody Map<String,Object> params){System.out.println("emqx 触发 webhook,请求体数据={}"+params);String action = (String) params.get("action");String clientId = (String) params.get("clientid");if(action.equals("client_connected")){System.out.println("客户端{}接入本系统"+clientId);clientStatus.put(clientId,true);}if(action.equals("client_disconnected")){System.out.println("客户端{}下线"+clientId);clientStatus.put(clientId,false);}}@GetMapping("/allStatus")public Map getStatus(){return this.clientStatus;}
}