借助 emq 消息服务器搭建微信小程序的mqtt服务器

文章目录
一、前言；
二、准备材料；
三、实现的过程和原理；
四、服务器配置；
三、小程序端连接效果；
一、前言；
从去年开始自学前端，到今年的服务器的学习，也算是自己的一大进步了！这几天开始搭建小程序的服务器，琢磨了三天的Nginx中间消息插件，期间也是不睡午觉！也许入门Nginx，和大家一样期间踩了很多坑！微信小程序也仅仅只有websocket协议的说明，但是已经不维护了！

希望你可以静心看看本篇文章，可以帮助你跳过搭建微信小程序的mqtt服务器的坑，不管你是用emq作为服务器，还是其他的服务器程序代码！

本文搭建好了之后，就可以在微信小程序上实现控制智能硬件，即为连接mqtt服務器。像现在最为流行的esp8266，esp32！废话不多说，Let us go !

二、准备材料；
【必要具备】一个备案成功的域名 + 配置的 SSL证书！ 证书可以是免费的，或者您是老板可以买个收费的！

【必要具备】一个服務器，可以是腾讯服务器，或者是阿里云服务器，而本文用的是阿里云服务器！因为双十一刚刚搞活动，一百多块买了一年服务器！呵呵！

【必要具备】关于微信小程序的源码，下篇就会开源免费赠送给大家！！

【其他】 SecureCRT远程命令连接工具！当然还有微信小程序开发工具，这些自己去下载吧！

三、实现的过程和原理；
Nginx环境搭建
mqtt服务器搭建
Nginx监听443端口，代理到mqtt服务器！
总所周知，小程序的架构是用基本前端代码实现的，就是wxml+wcss+js+json，而我们的在js上面实现Mqtt协议通讯，那么就离不开webSocket，微信对于webSocket的连接定义，我总结了一下：
① 连接的端口号必须是443，也就是https的访问端口；
② 连接时候，不能携带端口号，就是不能在URL中注明443端口！比如正确的写法是wss://www.xuhong.com，而不能是wss://www.xuhong.com：443！！切记！

关于Nginx的知识，我也是刚刚入门，如果大家想深入学，可以去慕课网有一门实战专门讲解Nginx这个强大的消息中间件！下面列下常见的命令和知识！
源码安装Nginx的 配置文件默认在 /usr/local/nginx/conf 里面的 nginx.conf文件！
./nginx - t : 表示检测 nginx.conf文件的语法是否有问题！
./nginx - s reload : 表示重新加载 nginx.conf文件！
./nginx - s quit : 表示强制或正常退出 Nginx 服务！
./nginx : 表示开启 Nginx 服务！
四、服务器配置；
下面是服务器配置的详细步骤，千万不要眨眼！！注意每个标题是个命令！
4.1 yum update

更新我们的 yum 源！
4.2 yum -y install gcc automake autoconf libtool make

安装 make工具 ，成功如下；

4.3 yum install gcc gcc-c++

安装g++ ，成功如下；

4.4 yum install pcre pcre-devel

安装pcre正则表达式，因为nginx的rewrite模块和http核心模块都是使用它 ，成功如下；

4.5 wget http://nginx.org/download/nginx-1.9.9.tar.gz

获取 nginx，成功如下；

4.6 tar -vzxf nginx-1.9.9.tar.gz

解压 nginx；
4.7 cd nginx-1.9.9.tar.gz && ./configure

先使配置文件nginx生效；

4.8 yum install zlib zlib-devel

zlib提供压缩算法，nginx很多地方都会用到；

4.9 yum install openssl openssl-devel

用到安全页面，所以需要 OpenSSL库；

4.10 wget https://codeload.github.com/openresty/headers-more-nginx-module/tar.gz/v0.33

据说这个可以适配某些JS的webSocket协议头的库，这里也下载吧；本博文不会用到，但是大家可能会用到！之后注意解压：tar -vzxf headers-more-nginx-module-0.33.tar.gz

4.11 ./configure --prefix=/usr/local/nginx --add-module=/root/nginx-1.9.9/headers-more-nginx-module-0.33 --with-http_stub_status_module --with-http_ssl_module

添加模块openSSL和headers-more-nginx-module-0.33；

4.12 make && make install

开始编译nginx代码；

4.13 cd /usr/local/nginx/sbin && ./nginx -V

编译nginx代码后会有/usr/local/nginx目录，我们查看当前编译后有哪些模块生效了；看到下面有2个模块执行成功了！

4.14 wget https://www.emqx.io/static/brokers/emqttd-centos7-v2.3.11.zip --no-check-certificate

无校验方式获取emq压缩包，如果不加--no-check-certificate可能是失败！

4.15 yum install unzip -y

新增zip的解压工具，用来解压emq的压缩包！

4.16 unzip emqttd-centos7-v2.3.11.zip

解压压缩包emq！

4.17 cd /root/emq/emqttd/bin && ./emqttd console

执行服务器emq！
4.18 cd /root/emq/emqttd/bin && ./emqttd start

守护进程开始emq！

4.19 cd /usr/local/nginx/conf && vim nginx.conf

修改nginx的配置文件！根据你的实际情况来定，添加如下代码！
其中www.domain.com是您的备案后域名， ssl_certificate和ssl_certificate_key对应的文件位置根据你的实际而定，注意这个是你配置域名的证书的信息！这个向证书生产方索取!!!
server {
listen 443;
server_name www.domain.com;

ssl on;
ssl_certificate /root/myCert/cert/cert.crt;
ssl_certificate_key /root/myCert/cert/cert.key;
ssl_session_timeout 5m;
ssl_protocols TLSv1 TLSv1.1 TLSv1.2;
ssl_ciphers ECDHE-RSA-AES128-GCM-SHA256:HIGH:!aNULL:!MD5:!RC4:!DHE;
ssl_prefer_server_ciphers on;

location / {
root html;
index index.html index.htm;
}

location = /mqtt {

# 8083就是我们的emq的websocket的端口号
proxy_pass http://www.domain.com:8083;
proxy_redirect off;
proxy_set_header Host www.domain.com:8083;

proxy_set_header Sec-WebSocket-Protocol mqtt;

# 这个是与你的 js客户端的库有关系，本博文的不需要，为了兼顾以后小伙伴，我这里注释了下！
#more_clear_headers Sec-WebSocket-Protocol;

# 这些都是 websocket必须要配置的
proxy_http_version 1.1;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection "upgrade";
}
}

4.20 cd /usr/local/nginx/sbin&& ./nginx -t

查看配置文件语法有问题？

4.20 cd /usr/local/nginx/sbin&& ./nginx -s reload

重新加载配置文件！

附件完整的nginx配置文件:

worker_processes  1;

events {
    worker_connections  1024;
}

http {
    include                        mime.types;
    default_type                   application/octet-stream;
    sendfile                       on;
    keepalive_timeout              65;

    server {
    listen      80;
    root        /usr/share/nginx/html;
    error_page  404 /404.html;
    error_page  500 502 503 504 /50x.html;

    location / {
    }

    location /api {
        root        html;
        index       index.html index.htm;
        proxy_pass  http://localhost:3000;
    }

    location /winecellarapi {
        root        html;
        index       index.html index.htm;
        proxy_pass  http://localhost:3001;
    }

    location /download {
        root        html;
        index       index.html index.htm;
        proxy_pass  http://localhost:8080/;
    }

    location = /40x.html {
    }

    location = /50x.html {
    }

    include     /etc/nginx/default.d/*.conf;
    }
    
    server {
    listen       5683;
    server_name  nbIot;
    root         /var/www/nbIot/;
    index        index.html index.htm;

    location / {
        proxy_pass  http://localhost:5684;
    }
}

    server {
        listen                     443;
        server_name                www.10000bee.com;
        ssl                        on;
        ssl_certificate            /root/tools/cert/10000bee.com.crt;
        ssl_certificate_key        /root/tools/cert/10000bee.com.key;
        ssl_session_timeout        5m;
        ssl_protocols              TLSv1 TLSv1.1 TLSv1.2;
        ssl_ciphers                ECDHE-RSA-AES128-GCM-SHA256:HIGH:!aNULL:!MD5:!RC4:!DHE;
        ssl_prefer_server_ciphers  on;
    
        location / {
            root   /usr/share/nginx/html;
            index  index.html index.htm;
        }
    
        location = /mqtt {
            proxy_pass          http://www.10000bee.com:8083;
            proxy_redirect      off;
            proxy_set_header    Host www.10000bee.com:8083;
            proxy_set_header    Sec-WebSocket-Protocol mqtt;
            proxy_http_version  1.1;
            proxy_set_header    Upgrade $http_upgrade;
            proxy_set_header    Connection upgrade;
        }
    }

    server_tokens                  off;
    access_log                     off;
    server_names_hash_max_size     512;
    server_names_hash_bucket_size  128;
    client_header_buffer_size      32k;
    large_client_header_buffers    4 32k;
    gzip                           on;
    gzip_disable                   msie6;
    gzip_min_length                1k;
    gzip_comp_level                5;
    gzip_buffers                   4 16k;
    gzip_http_version              1.1;
    gzip_proxied                   any;
    gzip_vary                      on;
    gzip_types                     text/plain text/css text/xml text/javascript text/x-component application/json application/javascript application/xml application/xhtml+xml application/xml+rss application/rss+xml application/atom+xml application/x-font-ttf application/x-web-app-manifest+json font/opentype image/svg+xml image/x-icon;
    fastcgi_buffer_size            64k;
    fastcgi_buffers                4 64k;
    fastcgi_busy_buffers_size      128k;
    fastcgi_temp_file_write_size   256k;
    include                        conf.d/*.conf;
}