基于C#实现MQTT通信实战

本文主要是介绍基于C#实现MQTT通信实战，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

《基于C#实现MQTT通信实战》MQTT消息队列遥测传输,在物联网领域应用的很广泛,它是基于Publish/Subscribe模式,具有简单易用,支持QoS,传输效率高的特点,下面我们就来看看C#实现...

1、连接主机

首先新建一个wpF项目，然后在Nuget中下载MQTTnet。

    // 连接主机
    MqttFactory factory = new MqttFactory();
    _client = factory.CreateMqttClient();
    var options = new MqttClientOptionsBuilder().
        WithtcpServer(this.ipAddress.Text, Convert.ToInt32(this.port.Text))
        .WithClientId(this.clientId.Text)
        .Build();
    var result = await _client.ConnectAsync(options, CancellationToken.None);
    if (result.ResultCode == MqttClientConnectResultCode.Success)
    {
        this.log.Text = DateTime.Now.ToString() + "    连接成功" + Environment.NewLine + this.log.Text;
    }
    else
    {
        this.log.Text = DateTime.Now.ToString() + $"    连接失败，{result.Re编程asonString}" + Environment.NewLine + this.log.Text;
        return;
    }

2、订阅消息

订阅消息分为两块，一个是消息的回显，一个是订阅消息。

    // 订阅消息
    vaChina编程r optiolwYQNqVKPyn = new MqttClientSubscribeOptions();
    MqttQualityOfServiceLevel level;
    switch (this.subscribeQos.SelectedIndex)
    {
        case 0:
            level = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce;
            break;
        case 1:
            level = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtLeastOnce;
            break;
        case 2:
            level = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce;
            break;
        default:
            throw new Exception("请选择服务质量");
    }
 
    option.TopicFilters = new List<MqttTopicFilter>android()
    {
        new MqttTopicFilter()
        {
            Topic = this.subscribeTopic.Text,
            QualityOfServiceLevel = level
        }
    };
    this._client.SubscribeAsync(option, CancellationToken.None);
 
    // 将订阅的消息回显到日志区
    this._client.ApplicationMessageReceivedAsync += e =>
    {
        var task = Task.Factory.StartNew(() => {
            try
            {
                var array = e.ApplicationMessage.PayloadSegment.Array;
                if (array == null)
                {
                    return;
                }
 
                var str = Encoding.UTF8.GetString(array);
 
                // 跨线程更新UI
                Application.Current.Dispatcher.Invoke(() => {
                    this.log.Text = DateTime.Now.ToString() + "    收到消息：" + str + Environment.NewLine + this.log.Text;
                });
            }
            catch (Exception ex)
            {
                this.log.Text = DateTime.Now.ToString() + $"    {ex.Message}" + Environment.NewLine + this.log.Text;
            }
        });
 
        return task;
    };
 
    this.log.Text = DateTime.Now.ToString() + "    订阅成功" + Environment.NewLine + this.log.Text;

订阅消息只需要两个参数：主题Topic和服务质量QoC，主题是用来区分不同频段的消息，避免出现冲突，如果想接收到所有的消息可以这么写：topicXXX/#，#就代表不限制范围，如果打算只接受固定区域的消息，则需要将#改成某个字符串。

服务质量QoC是用来控制可用性的，0是最低等级，最多只发送一次，1是中级，至少发一次，但有可能出现重复接收的情况，2是最高级，只发一次，不会多也不会少。

将消息回显需要注册ApplicationMessageReceivedAsync事件，传入的参数是回显对象，返回值是一个Task类型，是在Task中获取回显的值并完成控件的更新操作。

3、发布消息

发布消息的参数比订阅多两个：消息内容Payload，持久会话（在恢复连接后保留之前的订阅和消息传递状态）

    var msg = new MqttApplicationMessage();
    msg.Topic = this.topic.Text;
    msg.PayloadSegment = Encoding.UTF8.GetBytes(this.msg.Text);
    msg.Retain = isSave.IsChecked??false;
    MqttQualityOfServiceLevel level;
    switch (this.publishQos.SelectedIndex)
    {
        case 0:
            level = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce;
            break;
        case 1:
            level = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtLeastOnce;
            break;
        case 2:
            level = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce;
            break;
        default:
            throw new Exception("请选择服务质量");
    }
    
    msg.QualityOfServiceLevel = level;
    var resultPublish = await _client.PublishAsync(msg, CancellationToken.None);
    if (resultPublish.jsIsSuccess == true)
    {
        this.log.Text = DateTime.Now.ToString() + "    发送成功" + Environment.NewLine + this.log.Text;
    }
    else
    {
        this.log.Text = DateTime.Now.ToString() + "    发送失败" + Environment.NewLine + this.log.Text;
    }

到此这篇关于基于C#实现MQTT通信实战的文章就介绍到这了,更多相关C# MQTT通信内容请搜索China编程(www.chinasem.cn)以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程China编程(www.chinasem.cn)！

这篇关于基于C#实现MQTT通信实战的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！