Http2mqtt

load_module modules/njt_http_mqtt_module.so;

...
load_module modules/njt_http_mqtt_module.so;      //加载mqtt模块
...

http {
        client_max_body_size 1G; //如果mqtt消息超过1M，需要将此配置设置大一点
       
        upstream mqtt_upstream {
                mqtt_server 192.168.40.136:1885 user=test password=112233;
                mqtt_server 192.168.40.136:1884 user=test password=112233;
                #mqtt_keepalive off;     //默认是开启长连接，如果不用，设置为off
                #mqtt_keepalive max=10;  //默认开启长连接，max默认为10
                //每个链接使用的发送缓冲区大小，默认4M，如果是长消息或者短时间大量消息，则要将次缓存设置足够大
                #mqtt_send_buffer_size 10M;    
                mqtt_recv_buffer_size 1M;      //每个链接使用的接收缓冲区大小，默认1M
                mqtt_ping_time 10s;            //ping 消息发送间隔，默认5s
                mqtt_read_timeout 10s;
                #mqtt_retry_times 2;           //next upstream尝试次数，默认为1
        }

     server {
        listen       80;
        location /mqtt {
              mqtt_topic /test/mqtt;    //需要配置发送的topic
              mqtt_retain 1;            //保留topic的最后一条消息，默认为0，不保留
              mqtt_qos 0;               //mqtt qos级别，默认是0

              client_body_buffer_size 10M; //如果mqtt消息比较大，将此buffer设置大一点

              //目前只支持mqtt upstream， 不支持ip或者unix socket等
              mqtt_pass mqtt://mqtt_upstream;
        }
     }
}

...
load_module modules/njt_http_mqtt_module.so;      //加载mqtt模块
...

http {
        client_max_body_size 1G; //如果mqtt消息超过1M，需要将此配置设置大一点
       
        upstream mqtt_upstream {
                mqtt_server 192.168.40.136:1885 user=test password=112233;
                mqtt_server 192.168.40.136:1884 user=test password=112233;
                #mqtt_keepalive off;     //默认是开启长连接，如果不用，设置为off
                #mqtt_keepalive max=10;  //默认开启长连接，max默认为10
                //每个链接使用的发送缓冲区大小，默认4M，如果是长消息或者短时间大量消息，则要将次缓存设置足够大
                #mqtt_send_buffer_size 10M;    
                mqtt_recv_buffer_size 1M;      //每个链接使用的接收缓冲区大小，默认1M
                mqtt_ping_time 10s;            //ping 消息发送间隔，默认5s
                mqtt_read_timeout 10s;
                #mqtt_retry_times 2;           //next upstream尝试次数，默认为1
        }

     server {
        listen       80;
        location /mqtt {
              mqtt_topic /test/mqtt;    //需要配置发送的topic
              mqtt_retain 1;            //保留topic的最后一条消息，默认为0，不保留
              mqtt_qos 0;               //mqtt qos级别，默认是0

              client_body_buffer_size 10M; //如果mqtt消息比较大，将此buffer设置大一点

              //目前只支持mqtt upstream， 不支持ip或者unix socket等
              mqtt_pass mqtt://mqtt_upstream;
        }
     }
}

yum install mosquitto

allow_anonymous true       #此处配置匿名访问， 不配置也可，默认就是true

mosquitto -c /etc/mosquitto/mosquitto.conf -p 1884

mosquitto_sub -p 1884  -F '%t : %p' -t "#"

...
load_module modules/njt_http_mqtt_module.so;   #加载http2mqtt模块
...

http{
...   
     upstream mqtt_upstream {
                mqtt_server 192.168.40.136:1884;  #不配置用户名和密码
                mqtt_keepalive max=10;
                mqtt_send_buffer_size 10M;
                mqtt_recv_buffer_size 1M;
                mqtt_ping_time 10s;
     }

     server {
        listen       80;
        location /mqtt {
              mqtt_topic /test/mqtt;   #配置topic
              mqtt_retain 1;           #保留消息
              mqtt_pass mqtt_upstream;
        }
     }
...
}

curl -X POST http://localhost:80/mqtt -d '==========1' -v

[root@CDN157 test_mqtt]$ mosquitto_sub -p 1884  -F '%t : %p' -t "#" 
/test/mqtt : ==========1

allow_anonymous false       #此处关闭匿名访问
password_file  /etc/mosquitto/password_file    #此处配置密码文件路径

#配置用户名为admin 密码为admin， 第一个用户配置需要指定-c， 密码会让输入一遍确认一遍
mosquitto_passwd -c /etc/mosquitto/password_file admin

#去查看密码文件发现有两个用户
cat /etc/mosquitto/password_file
admin:$6$iVtan6BFKlJCOb4y$c6tz/+NCaulkIPh9wOfO9Ba2pmg4pZOG8kuQNHfe7ViHzuqZczsS90w38M9QvflBamDOzxKtRnnL//QnHGW4Lw==

mosquitto -c /etc/mosquitto/mosquitto.conf -p 1884

mosquitto_sub -p 1884  -F '%t : %p' -t "#" -u admin -P admin

...
load_module modules/njt_http_mqtt_module.so;   #加载http2mqtt模块
...

http{
...   
     upstream mqtt_upstream {
                mqtt_server 192.168.40.136:1884 user=test password=112233;  #使用用户名密码访问
                mqtt_keepalive max=10;
                mqtt_send_buffer_size 10M;
                mqtt_recv_buffer_size 1M;
                mqtt_ping_time 10s;
     }

     server {
        listen       80;
        location /mqtt {
              mqtt_read_timeout 20s;
              mqtt_topic /test/mqtt;
              mqtt_pass mqtt_upstream;
        }
     }
...
}

curl -X POST http://localhost:80/mqtt -d '==========1' -v

[root@CDN157 test_mqtt]$ mosquitto_sub -p 1884  -F '%t : %p' -t "#"  -u admin -P admin
/test/mqtt : ==========1