mqtt服务器emqx搭建
A. Android使用MQTT通讯
主要讲下Android如何使用MQTT通讯。用到漏侍的软件或者框架有：
EMQ： https://www.emqx.io/cn/
org.eclipse.paho的MQTT通讯框架： https://github.com/eclipse/paho.mqtt.android
如果已经有MQTT相关服务返尺吵，可以跳过第一项，从第二项开始看。
1.安装所需要的依困吵赖包
2.使用以下命令设置稳定存储库，以 CentOS7 为例
3.安装最新版本的 EMQ X
4.安装特定版本的 EMQ X
5.启动 EMQ X
地址：xxx.xxx.xxx:18083，地址为服务器ip或者域名，端口为18083端口
1.在Android中导入依赖
项目地址： https://github.com/eclipse/paho.mqtt.android
2.创建MQTT连接的一个Service
B. EMQ X 服务器 SSL/TLS 安全连接配置指南
EMQ X 内置对 TLS/DTLS 的支持，包括支持单双向认证、X.509 证书等多种身份认证和 LB Proxy Protocol V1/2 等。你可以为 EMQ X 支持的所有协议启用 TLS/DTLS，也可以将 EMQ X 提供的 HTTP API 配置为使用 TLS。本文以自签证书的方式介绍如何在 EMQ X 中为 MQTT 启用 TLS。
查看证书
查看证书
创建 Root CA 自签名证书的步骤与前文一致，不再赘述。
与前文类似，只不过需要将 Root CA 的信息替换成 Second CA 的。最后我们将得到以下文件：
Note: Client 既可以使用 root-cacert.pem 与 second-cacert.pem 合并后的 cacert.pem ，也可以使用 second-cacert.pem 。
假设你已经成功安装了 EMQ X，我们将之前生成的证书一并拷贝到 emqx/etc/certs 目录下：
然后修改 emqx.conf 配置如下：
启动 EMQ X 并将冲携弯日志等级改为 Debug。
使用 openssl s_client 连接 EMQ X 并发送一个 Client ID 为 "a" 的 MQTT Connect 报文。
如果你在 emqx/log/erlang.log.1 中看到以下日志，说明 SSL 认证成功。
EMQ X 继续保持运行，编译并启动 emqtt 。
连接建立成功，可散闷以正常订阅发布，SSL 单向认证测试通过。
EMQ X 继续保持运行，启动 mqtt.fx，参照下图完成配置：
**Note: **这里只能使用 second-cacert.pem 作为 CA Certificate。
点击 Connect 按钮，连接成功，并且可以正常订阅发布，SSL 双向认证通过。
修改 emqx.conf 配置如下：
启动 EMQ X 并将日志等级改为 Debug。
使用 openssl s_client 连接 EMQ X 并发送一个 Client ID 为 "a" 的 MQTT Connect 报文。
如果你在 emqx/log/erlang.log.1 中看到以下日志，说明 SSL 双向认证成功。
EMQ X 继续保持运行，启隐饥动 emqtt 。
连接建立成功，可以正常订阅发布，SSL 双向认证测试通过。
EMQ X 继续保持运行，启动 mqtt.fx，参照下图完成配置：
Note: CA File 可以使用 root-cacert.pem 与 second-cacert.pem 合并后的 cacert.pem ，也可以使用 second-cacert.pem 。
点击 Connect 按钮，连接成功，并且可以正常订阅发布，SSL 双向认证通过。
最近公司做的项目中有用到消息推送，经过多方面的筛选之后确定了使用MQTT协议，相对于XMPP，MQTT更加轻量级，并且占用用户很少的带宽。
MQTT是IBM推出的一种针对移动终端设备的基于TCP/IP的发布/预订协议，可以连接大量的远程传感器和控制设备。
MQTT的官网见：http://mqtt.org/。其中http://mqtt.org/software里面提供了官方推荐的各种服务器和客户端使用的各种语言版本的API。
下面以服务器Apollo 1.6为例，之前尝试过使用ActiveMQ，效果很不理想，只能实现服务器和客户端一对一的通信，从官网上了解到Apollo属于activemq的一个子工程。先不管这些了，言归正传，以下在windows环境下。
1、在这里下载Apollo服务器，下载后解压，然后运行apache-apollo-1.6\bin\apollo.cmd，输入create mybroker（名字任意取，这里是根据官网介绍的来取的）创建服务器实例，服务器实例包含了所有的配置，运行时数据等，并且和一个服务器进程关联。
2、create mybroker之后会在bin目录下生成mybroker文件夹，里面包含有很多信息，其中etc\apollo.xml文件下是配置服务器信息的文件，etc\users.properties文件包含连接MQTT服务器时用到的用户名和密码，后面会介绍，可以修改原始的admin=password，可以接着换行添加新的用户名密码。
3、打开cmd，运行…apache-apollo-1.6\bin\mybroker\bin\apollo-broker.cmd run 开启服务器，可以在浏览器中输入http://127.0.0.1:61680/查看是否安装成功，该界面展示了topic，连接数等很多信息。
经过上面的简单步骤，服务器基本上就已经完成，下一篇将介绍Android客户端的编写和注意事项。
客户端使用的API，开始我使用的是mqtt-client，使用过后发现问题百出，不能很好的满足要求，后来使用了官方推荐的Eclipse Paho，下面开始客户端代码的编写，为了方便测试这里有android和j2se两个工程：
1、新建android工程MQTTClient
2、MainActivity代码如下：
D. 黑群晖怎样搭建MQTT服务器
1、打开群晖Docker，注册表搜索：mqtt；
2、点击下载好的镜像文件创建容器，输入容器名字，点击高级设置
3、勾选启用自动重新启动
4、点击网络—-勾选与docker host相同的网络，点击应用，一直下一步直到创建完成
E. 在云服务器上搭建了mqtt，为什么手机连接不上mqtt，要怎么做才能连接上求求大神帮忙
MQTT协议是广泛应用的物联网协议，使用测试MQTT协议需要MQTT的代理。有两种方法使用MQTT服务，一是租用现成的MQTT服务器，如阿里云，网络云，华为云等公用的云平台提供的MQTT服务，使用公用的MQTT服务器的好处是省事，但如果仅仅用于测试学习还需要注册帐号，灵活性差些，有的平台还需要付费。另一方法是自己使用开源的MQTT组件来搭建。
MQTT服务器非常多，如apache的ActiveMQ，emtqqd，HiveMQ，Emitter，Mosquitto，Moquette等等。
这里介绍的是用轻量级的mosquitto开源项目来搭建一个属于自己的MQTT服务器。
第一步：需要安装一台linux主机，这不多介绍，可以使用真机安装也可以使用虚拟机安装。如果仅仅是自己测试使用都可以。
第二步：下载mosquitto需要的依赖
sudo apt-get install libssl-devsudo apt-get install uuid-devsudo apt-get install cmake
第三步：下载mosquitto并解压，现在mosquitto官网最新的版本是1.5.1
tar xzvf mosquitto-1.5.1.tar.gz
第四步：编译
cd mosquitto-1.5.1/
make
make install
第五步：启动mosquitto
./mosquitto -v
1535473957: mosquitto version 1.5.1 starting
1535473957: Using default config.
1535473957: Opening ipv4 listen socket on port 1883.
1535473957: Opening ipv6 listen socket on port 1883.
这时候mosquitto就会以默认的参数启动。如果需要带配置文件可以修改配置文件mosquitto.conf，
启动时候加上参数 -c，
./mosquitto -c mosquitto.conf
可以看到，mosquitto监听的端口为1883.
这时候我们的MQTT服务器就搭建好了。可找一个mqtt客户端来测试一下。
先发布一个主题“home/garden/fountain/2”
内容是“hello world”
这时候在mosquitto会打印出下面的log
535474247: New connection from 192.168.1.105 on port 1883.
1535474247: New client connected from 192.168.1.105 as MQTT_FX_Client (c1, k60).
1535474247: No will message specified.
1535474247: Sending CONNACK to MQTT_FX_Client (0, 0)
1535474307: Received PINGREQ from MQTT_FX_Client
1535474307: Sending PINGRESP to MQTT_FX_Client
1535474339: Received PUBLISH from MQTT_FX_Client (d0, q0, r0, m0, 'home/garden/fountain/2', ... (12 bytes))
1535474367: Received PINGREQ from MQTT_FX_Client
1535474367: Sending PINGRESP to MQTT_FX_Client
订阅主题“home/garden/fountain/2”
可以看到收到了自己发布的消息。
用wireshark抓包
可以看到抓到了一个MQTT的publish的报文。
F. php安装mqtt扩展【Mosquitto】
没有安装mosquitto的可以看一下链接先安装一下
MQTT服务器搭建-mosquitto1.4.4安装指南
然后我们来安装php扩展
如果你已经使用预先建立的软件包来安装Mosquitto，你需要确保你已经安装了开发头文件。在红帽派生的系统上，这可能是叫做libmosquitto-devel，在基于 Debian的系统上叫做libmosquitto-dev。
你可以使用pecl来来安装这个拓展包：
pecl install Mosquitto-alpha
1
或者，你也可以使用常规的安装拓展的方法来安装：
phpize
./configure --with-mosquitto=/path/to/libmosquitto
make
make install
1
2
3
4
然后添加extension=mosquitto.so到你的PHP配置文件php.ini中。
--with-mosquitto
1
是可选参数，只有当安装程序找不到libmosquitto拓展包，才需要添加这个参数
G. springboot整合RabbitMQ Mqtt
第一，pom配置，我们需要引入相关jar：
第二，配置MQTT服务器基本信息，在springBoot配置文件application.properties中配置，添加如下：
第三，配置MQTT消息推送配置类，
第四，配置MqttGateway消息推送接口类，在sendToMqtt(String data,@Header(MqttHeaders.TOPIC)String topic)接口中，data为发送的消息内容，topic为主题。指定topic，则我们的接口可以根据需要，向不同的主题发送消息，方便灵活应用。如果不指定，则使用默认配置的主题。
第五，接口类测试下功能，用Postman调用sendMqtt.do接口，往hello主题发送消息，用MQTTLens订阅hello主题，从下面截图，可以看出可以正常往MQTT服务发送消息了，而且可以订阅到。
H. 海为物联云HMI如何设置MQTT
首先需要搭建MQTT服务器，然后搭建MySQL数据库，然后使用海为组态写段程序，最后配置客户端验证即可。具体可以参考内容 Haiwell（海为）HMI/CBOX/IPC MQTT 配置应用教程网页链接