WebHook

    Client      |    RMQTT     |  rmqtt-web-hook |   HTTP       +------------+
  =============>| - - - - - - -> - - - - - - - ->===========>  | Web Server |
                |    Broker    |                |  Request     +------------+

rmqtt-web-hook

plugins/rmqtt-web-hook.toml

##--------------------------------------------------------------------
## rmqtt-web-hook
##--------------------------------------------------------------------
## http
#    Method: POST
#    Body: <JSON>
#    Payload: BASE64
## file
#    None
#

## Hook general config
# 由于WebHook使用单独的Tokio运行时环境启动，因此需要指定此运行时环境允许的核心工作线程数。
worker_threads = 3
# 消息队列容量，
queue_capacity = 300_000
# 并行发送WebHook Http请求数
concurrency_limit = 128

## Default urls, supports http and file protocols
# 默认WebHook URL地址，可以指定多个地址
#urls = ["file:///var/log/rmqtt/hook.log", "http://127.0.0.1:5656/mqtt/webhook"]
urls = ["file:///var/log/rmqtt/hook.log"]

## Http config
# HTTP请求超时时间
http_timeout = "8s"
# 此配置项设置最大重试失效时间，如果http请求失败，将在大约2、4、7、11、18或42秒后重试，
retry_max_elapsed_time = "60s"
# 重试因子，默认: 2.5
retry_multiplier = 2.5

规则:
rule.<Event> = [<Rule 1>, <Rule 2>, ..., <Rule n>]

如: 
rule.<Event> = [{action=<Action>, urls=[...], topics=[...]}]

例:
rule.session_created = [{action = "session_created" } ]
rule.session_terminated = [{action = "session_terminated" } ]
rule.session_subscribed = [{action = "session_subscribed" , topics=["x/y/z", "foo/#"] } ]
rule.session_unsubscribed = [{action = "session_unsubscribed" , topics=["x/y/z", "foo/#"] } ]

rule.client_connect = [{action = "client_connect"}]
rule.client_connack = [{action = "client_connack"} ]
rule.client_connected = [{action = "client_connected"}, {action = "client_connected_2", urls = ["http://127.0.0.1:5657/mqtt/webhook"] } ]
rule.client_disconnected = [{action = "client_disconnected" } ]
rule.client_subscribe = [{action = "client_subscribe", topics=["x/y/z", "foo/#"]} ]
rule.client_unsubscribe = [{action = "client_unsubscribe", topics=["x/y/z", "foo/#"] } ]

rule.message_publish = [{action = "message_publish" }]
rule.message_delivered = [{action = "message_delivered", topics=["x/y/z", "foo/#"] } ]
rule.message_acked = [{action = "message_acked", topics=["x/y/z", "foo/#"] } ]
rule.message_dropped = [{action = "message_dropped" } ]

rule.message_publish = [{action = "message_publish", topics=["a/b/c", "foo/#"] }]

URL: <url>      # 来自于配置中的 `url` 字段
Method: POST    # 固定为 POST 方法

Body: <JSON>    # Body 为 JSON 格式字符串