基于 M2Mqtt 和 emqx 实现的MQTT通讯

配置emqx服务端

1.首先下载emqx服务端。https://www.emqx.io/cn/downloads#broker，下载broker就行。

2.解压，cd到bin目录下，然后敲命令

emqx start

注意在这之前最好保证下面这些端口不被占用。否则你还要emqx restart重启。

尤其是8081端口，冲突概率很高，Url not found 这个错就是因为这个端口冲突所致。

start之后不会有显示成功的状态显示，没其他提示就是成功。

3.之后进入http://localhost:18083/ 默认用户名是admin，密码public。

首次进入设置里面可以将语言改成“中文”。

到这里mqtt服务基本是部署好了。开始编写客户端代码

开始写客户端代码

新建一个web项目，或者winform项目都行。

nuget里面搜 M2Mqtt。（为什么选这个呢，因为这个对.net环境几乎没有依赖，任何版本的.net都能运行。好多其他的Mqttnet什么的都要求core才行）

安装完后github（https://github.com/eclipse/paho.mqtt.m2mqtt，如果连接没了就自己在github上搜m2mqtt）上面有源码和案例，粘下来几段开始试验。

我这边直接把我试验代码贴上来

using uPLibrary.Networking.M2Mqtt;
using uPLibrary.Networking.M2Mqtt.Messages;

后端是tcp协议，默认就是1883端口，就不用改，

public class HomeController : Controller{string MQTT_BROKER_ADDRESS = "192.168.0.10";public string recive_message { get; set; }public ActionResult Index(){// create client instance MqttClient client = new MqttClient(IPAddress.Parse(MQTT_BROKER_ADDRESS));// register to message received client.MqttMsgPublishReceived += client_MqttMsgPublishReceived;string clientId = Guid.NewGuid().ToString();client.Connect(clientId);// subscribe to the topic "/home/temperature" with QoS 2 client.Subscribe(new string[] { "/home/temperature" }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE }); return View();}void client_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e){recive_message = System.Text.Encoding.UTF8.GetString(e.Message);// handle message received }public JsonResult post(string message){MqttClient client = new MqttClient(IPAddress.Parse(MQTT_BROKER_ADDRESS));string clientId = Guid.NewGuid().ToString();client.Connect(clientId);// publish a message on "/home/temperature" topic with QoS 2 client.Publish("/home/temperature", Encoding.UTF8.GetBytes(message), MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE, false);return Json(true);}}

这个类库太精简了，精简到看方法名称就知道这个是干嘛的了。真的不用再去讲解这个类库怎么用了。

后端（winform）接收发送消息到这就差不多了。

下面开始前端（web）接受发送消息。

前端我们添加引用（https://github.com/eclipse/paho.mqtt.javascript）官方说明文档：https://www.eclipse.org/paho/files/jsdoc/Paho.MQTT.Client.html js下载地址：https://www.eclipse.org/downloads/download.php?file=/paho/releases/1.0.3/paho.javascript-1.0.3.zip

<script src="https://cdnjs.cloudflare.com/ajax/libs/paho-mqtt/1.0.1/mqttws31.js" type="text/javascript"></script>

然后加下面这段代码，也是人家官网抄的，前端是走的websocket协议，所以是8083端口。

// Create a client instanceclient = new Paho.MQTT.Client("127.0.0.1", 8083, "clientId");// set callback handlersclient.onConnectionLost = onConnectionLost;client.onMessageArrived = onMessageArrived;// connect the clientclient.connect({ onSuccess: onConnect });// called when the client connectsfunction onConnect() {// Once a connection has been made, make a subscription and send a message.console.log("onConnect");client.subscribe("/home/temperature");message = new Paho.MQTT.Message("Hello");message.destinationName = "World";client.send(message);}// called when the client loses its connectionfunction onConnectionLost(responseObject) {if (responseObject.errorCode !== 0) {console.log("onConnectionLost:" + responseObject.errorMessage);}}// called when a message arrivesfunction onMessageArrived(message) {console.log("onMessageArrived:" + message.payloadString);}

到这调吧调吧基本就都通了。。。

最后

最后我补充一下emqx和咱们写好的客户端联调测试的方法。

显示当前状态: 已连接就对了

然后

订阅完成，

代码写完了，就可以各种进行收发测试了。