Hanson.Mqtt.Utils 1.0.0

README

Hanson.Mqtt.Utils

功能說明

簡化 MQTT 的使用方式

主要功能

1. Broker

   • 支援 Client 上線及下線異動的處理事件
   • 支援 Client 訂閱及解除訂閱異動的處理事件
   • 支援 StartAsync 啟動 Broker
   • 支援 取得所有線上 client id

2. Publish/Subscrib

   • 支援 Pushlish MQTT 訊息
   • 支援 Subscrib MQTT 訊息

3. 限制

   • 限使用 本機 IP 啟動 Broker Server

安裝方式

• 使用 Nuget 方式進行安裝 https://www.nuget.org/packages/hanson.mqtt.utils/

使用範例

• Broker Server

// 使用 SimpleFactory 建立 Broker Server

using (var server = SimpleFactory.GetBrokerServer())
{
   server.OnClientConnectedEvent += ((x) =>
        {
            _logger.Info($"使用者:{x} 已上線");
        });
   server.OnClientDisconnectedEvent += ((x) =>
        {
            _logger.Info($"使用者:{x} 已下線");
        });
   server.OnInterceptingPublishEvent += ((client, payload) =>
        {
            _logger.Info($"接收使用者:{client} 上傳的Topic:{payload.Topic}, message:{payload.Value}");
        });
   Console.WriteLine("Start MQTTnet Server ...");
   await server.StartAsync();
}

• Publish 使用範例

var config = new MqttConfig
        {
            Host = "127.0.0.1",
            Port = 1883,
            ClientId = "publish"
        };
using (var client = SimpleFactory.CreateInstance(config))
{
	client.OnPublishAcknowledgedEvent += ((x) =>
    {
        _logger.Info($"Send topic:{x.Topic} is success");
    });
    client.OnPublishMessageTimeoutEvent += ((x) =>
    {
        _logger.Info($"Send topic:{x.Topic} is timeout");
    });        
   	var msg = Console.ReadLine();
    var payload = new Payload
        {
          Topic = "test",
          Value = "message"
         };
    await client.PublishAsync(payload);
}

• Subscribe 使用範例

var config = new MqttConfig
        {
            Host = "127.0.0.1",
            Port = 1883,
            ClientId = "subscribe"
        };
using (var client = SimpleFactory.CreateInstance(config))
{
	client.OnMessageReceivedEvent += ((x) =>
    {
        _logger.Info($"Topic:{x.Topic}, Message value: {x.Value}");
    });
      
   	await client.SubscribeAsync("test");
}