FCARDCloud.Framework.Common.MQTTNet 1.9.0

FCARDCloud.Framework.Common.MQTTNet

介绍

net6 版本的MQTT客户端连接库

封装连接和自动重连功能

软件架构

net6

更新日志

v1.09

修改当mqtt服务器断开后，不能重连的bug

配置

Startup.cs 的 ConfigureServices 函数 中注入配置；

//配置阿里MQTT服务
Services.AddMQTTClientByAli(config.GetSection("AliMQTTSetting"));

//配置标准MQTT服务
Services.AddMQTTClient(config.GetSection("MQTTSetting"));

appsettings.json 中的配置项

{
  "AliMQTTSetting": { //标准MQTT服务器
    "ServerAddr": "192.168.1.15",
    "ServerPort": 8883,
    "SSL": true,

    "ClientID": "test001",
    "UserName": "user001",
    "Password": "abcdefg"
   },

  "AliMQTTSetting": { //阿里张家口实例示例
    "AccessKeyID": "",
    "SecretKey": "",

    "ServerAddr": "post-cn-6ja1s60ki1b.mqtt.aliyuncs.com",
    "ServerPort": 8883,
    "SSL": true,

    "Group": "GID_MQWebTest",
    "ClientCode": "Test001",

    "InstanceID": "post-cn-6ja1s60ki1b"
   }

订阅MQTT主题调用示例

Startup.cs 的 ConfigureServices 函数 中注入配置

//配置订阅处理服务
services.AddHostedService<MyMQTTHandleService>();

    public class MyMQTTHandleService : IHostedService
    {
        private readonly ILogger<MyMQTTHandleService> _logger;
        private MQTTClient MQTTClient;

        public MyMQTTHandleService(
            ILogger<MyMQTTHandleService> log,
            MQTTClient client)
        {
            this.MQTTClient = client;
            _logger = log;
        }

        public async Task StartAsync(CancellationToken cancellationToken)
        {
            //全局订阅某主题
            await MQTTClient.Subscribe("testTopic1");
            await MQTTClient.Subscribe("testTopic2");
            await MQTTClient.Subscribe("testTopic3");

            MQTTClient.MqttMsgPublishReceived = MqttMsgPublishReceived;


            _logger.LogInformation($"MQTT服务器已启动!");

        }

        /// <summary>
        /// 订阅的主题有新消息时的回调处理函数
        /// </summary>
        /// <param name="e"></param>
        private void MqttMsgPublishReceived(MqttApplicationMessageReceivedEventArgs  e)
        {
            var msg = e.ApplicationMessage;
            _logger.LogInformation($"MQTT 接收到消息,Topic:[ {msg.Topic}],Body={Encoding.UTF8.GetString(msg.Payload)}");
        }

        public Task StopAsync(CancellationToken cancellationToken)
        {
            return Task.CompletedTask;
        }
    }

发布 MQTT 消息调用示例

    [ApiController]
    [Route("[controller]")]
    public class MqttController : ControllerBase
    {
        private readonly ILogger<MqttController> _logger;
        private MQTTClient MQTTClient;

        public MqttController(
            ILogger<MqttController> log,
            MQTTClient client)
        {
            this.MQTTClient = client;
            _logger = log;
        }

        [HttpPost("Publish")]
        public JsonResult Publish(string msg)
        {
            MQTTClient.Publish("testTopic1", msg);

            return new JsonResult("Publish Over");
        }
    }