模块 ngx_stream_mqtt_filter_module

Example Configuration
Directives
     mqtt
     mqtt_buffers
     mqtt_rewrite_buffer_size
     mqtt_set_connect

该ngx_stream_mqtt_filter_module模块 (1.23.4) 提供对消息队列遥测传输协议 (MQTT) 版本 3.1.1 和 5.0的支持。

该模块作为我们商业订阅 的一部分提供 。

配置示例

listen            127.0.0.1:18883;
proxy_pass        backend;
proxy_buffer_size 16k;

mqtt             on;
mqtt_set_connect clientid "$client";
mqtt_set_connect username "$name";

指令

句法： mqtt on | off;
默认： 
mqtt off;
语境： stream,server

为给定虚拟服务器启用 MQTT 协议。

句法： mqtt_buffers number size;
默认： 
mqtt_buffers 100 1k;
语境： stream,server

该指令出现在版本 1.25.1 中。

为单个连接设置用于处理 MQTT 消息的缓冲区 number和。size

句法： mqtt_rewrite_buffer_size size;
默认： 
mqtt_rewrite_buffer_size 4k|8k;
语境： server

该指令自版本 1.25.1 起已过时。 应改用 mqtt_buffers指令。

设置size用于写入修改消息的缓冲区。默认情况下，缓冲区大小等于一页内存。这是 4K 或 8K，具体取决于平台。然而，它可以做得更小。

句法： mqtt_set_connect field value;
默认： —
语境： server

将消息设置field 为给定的valueCONNECT 消息。支持以下字段： clientid、 username和 password。该值可以包含文本、变量及其组合。

mqtt_set_connect可以在同一级别上指定 多个指令：

mqtt_set_connect clientid "$client";
mqtt_set_connect username "$name";