c# mqtt 服务端、客户端简易例子

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了c# mqtt 服务端、客户端简易例子，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3827字，纯文字阅读大概需要6分钟。

内容图文

我用的是HslCommunication，本来想用mqttnet的，发现新版本是3.多了，网上的教程都是2.7多了，我项目又比较急，我也懒得研究了，找到了一篇HslCommunication的用法，我整理了下。下面上代码

服务端：

using HslCommunication;
using HslCommunication.MQTT;
using System;
using System.Globalization;
using System.Net.Http.Headers;
using System.Text;

namespace MqttTestServer
{
    class Program
    {
        static void Main(string[] args)
        {
            MyClass my = new MyClass();
            my.Start();
            Console.ReadLine();
        }
    }

    public class MyClass
    {
        private MqttServer mqttServer = null;
        //private MqttClient mqttClient = null;

        public void Start()
        {
            mqttServer = new MqttServer();
            mqttServer.ServerStart(6666);
            mqttServer.ClientVerification += OnConnect;
            mqttServer.OnClientDisConnected += OnClientOffline;
            mqttServer.OnClientConnected += OnClientOnline;
            mqttServer.OnClientApplicationMessageReceive += OnClientReceive;
        }

        /// <summary>
        /// 客户端信息的字符串
        /// </summary>
        /// <param name="session"></param>
        /// <returns></returns>
        private string ClientInfoString(MqttSession session)
        {
            return string.Format("ID:{0}, 用户名:{1} ,Ip:{2}", session.ClientId, session.UserName, session.EndPoint);
        }

        /// <summary>
        /// 客户端下线时候会触发这个回调
        /// </summary>
        /// <param name="session"></param>
        private void OnClientOffline(MqttSession session)
        {
            Console.WriteLine("客户端下线了!" + ClientInfoString(session));
            
        }

        /// <summary>
        /// 客户端上线的时候会触发这个回调
        /// </summary>
        /// <param name="session"></param>
        private void OnClientOnline(MqttSession session)
        {
            Console.WriteLine("客户端上线了!" + ClientInfoString(session));
        }

        /// <summary>
        /// 当有客户端连接上来时会触发这个回调，返回0是通过，否则就是登录失败
        /// </summary>
        /// <param name="clientId"></param>
        /// <param name="userName"></param>
        /// <param name="passwrod"></param>
        /// <returns></returns>
        private int OnConnect(string clientId, string userName, string passwrod)
        {
            Console.WriteLine("客户端连接了。");
            return 0;
        }


        /// <summary>
        /// 客户端收到消息时触发
        /// </summary>
        /// <param name="session"></param>
        /// <param name="message"></param>
        private void OnClientReceive(MqttSession session, MqttClientApplicationMessage message)
        {
            Console.WriteLine("客户端:" + ClientInfoString(session) + "收到消息了:" + Encoding.UTF8.GetString(message.Payload));
        }
    }
}

客户端：

using System;
using System.Text;
using System.Threading;
using HslCommunication;
using HslCommunication.MQTT;

namespace MqttTestClient
{
    class Program
    {
        static void Main(string[] args)
        {
            MyClass mc = new MyClass();
            mc.Start();

            mc.Connect();//连接
            mc.Regist();//注册

            Console.WriteLine("输入“send”发送消息");
            string s = Console.ReadLine();
            if (s == "send")
            {
                Console.WriteLine("我发送成功了");
                mc.SendMsg();
            }

            Console.ReadLine();
        }

        public class MyClass
        {
            private MqttClient mqttClient = null;
            public void Start()
            {
                mqttClient = new MqttClient(new MqttConnectionOptions()
                {
                    ClientId = "ABC",
                    IpAddress = "127.0.0.1",
                    Port = 6666,
                    Credentials = new MqttCredential("admin", "admin"),   // 设置了用户名和密码
                });
            }

            public void Connect()
            {
                // 连接
                OperateResult connect = mqttClient.ConnectServer();
                if (connect.IsSuccess)
                {
                    Console.WriteLine("Success");
                }
                else
                {
                    Console.WriteLine("Failed");
                }
            }

            public void SendMsg()
            {
                // 测试发布
                mqttClient.PublishMessage(new MqttApplicationMessage()
                {
                    Topic = "A",                                                      // 主题
                    QualityOfServiceLevel = MqttQualityOfServiceLevel.AtMostOnce,     // 消息等级
                    Payload = Encoding.UTF8.GetBytes("This is test message!"),        // 数据
                    Retain = false,                                                   // 是否保留
                });
            }

            public void Regist()
            {
                // 订阅测试，在label1上显示结果
                mqttClient.OnMqttMessageReceived += MqttClient_OnMqttMessageReceived; // 调用一次即可
                mqttClient.SubscribeMessage("A");     // 订阅A的主题
            }

            private void MqttClient_OnMqttMessageReceived(string topic, byte[] payload)
            {
                Console.WriteLine("我收到了消息了");
                string s = Encoding.UTF8.GetString(payload);
                Console.WriteLine(s);
            }
        }
    }
}

运行结果：

内容总结

以上是互联网集市为您收集整理的c# mqtt 服务端、客户端简易例子全部内容，希望文章能够帮你解决c# mqtt 服务端、客户端简易例子所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端