摘要：public IMqttClient _mqttClient;string serverIP, serverPort, user, pwd;public MqttHelper(string ipAddr, string port, string userNam
一、安装MQTTnet
二、引用dll
using MQTTnet;using MQTTnet.Client;using MQTTnet.Protocol;三、建立MQTT连接
public IMqttClient _mqttClient;string serverIP, serverPort, user, pwd;public MqttHelper(string ipAddr, string port, string userName, string userPwd){ serverIP = ipAddr; serverPort = port; user = userName; pwd = userPwd;}MqttClientOptions options = null;public Action GetActionSubscribe;public async void ConntionServer{ try { options = new MqttClientOptions { ClientId = Guid.NewGuid.ToString("D") }; options.ChannelOptions = new MqttClientTcpOptions { Server = serverIP, Port = Convert.ToInt32(serverPort) }; options.Credentials = new MqttClientCredentials { Username = user, Password = pwd }; options.CleanSession = true; options.KeepAlivePeriod = TimeSpan.FromSeconds(100.5); options.KeepAliveSendInterval = TimeSpan.FromSeconds(20000); if (null != _mqttClient) { await _mqttClient.DisconnectAsync; _mqttClient = null; } _mqttClient = new MqttFactory.CreateMqttClient; //接收信息 _mqttClient.ApplicationMessageReceived += (sender, args) => { GetActionSubscribe?.Invoke(Encoding.UTF8.GetString(args.ApplicationMessage.Payload)); }; _mqttClient.Connected += (sender, args) => { }; _mqttClient.Disconnected += (sender, args) => { }; await _mqttClient.ConnectAsync(options); } catch (Exception ex) { }}public async void DisConntionServer{ try { if (null != _mqttClient && _mqttClient.IsConnected) { await _mqttClient.DisconnectAsync; _mqttClient.Dispose; _mqttClient = null; } } catch (Exception ex) { }}public async void HeartConntionServer{ try { if (null != _mqttClient && options != null) { await _mqttClient.ConnectAsync(options); } } catch (Exception ex) { }}四、发布/订阅消息
//发布消息public void SendMessage(string Topic, string Payload){ try { Task.Factory.StartNew(async => { var msg = new MqttApplicationMessage { Topic = Topic, Payload = Encoding.UTF8.GetBytes(Payload), QualityOfServiceLevel = (MqttQualityOfServiceLevel) Enum.Parse(typeof(MqttQualityOfServiceLevel), "1"), Retain = false }; if (null != _mqttClient) { await _mqttClient.PublishAsync(msg); } else { } }); } catch (Exception ex) { }}//订阅消息public async void SubscribeAsync(string Topic){ try { if (_mqttClient == null) return; Thread.Sleep(1000); await _mqttClient.SubscribeAsync( new List { new TopicFilter( Topic, (MqttQualityOfServiceLevel) System.Enum.Parse(typeof (MqttQualityOfServiceLevel), "1")) }); } catch (Exception ex) { }}来源：有趣的科技君
免责声明：本站系转载，并不代表本网赞同其观点和对其真实性负责。如涉及作品内容、版权和其它问题，请在30日内与本站联系，我们将在第一时间删除内容!