如何使用C#接收MQTT的資料
使用M2Mqtt接收MQTT的資料 https://github.com/ppatierno/m2mqtt
簡單範例：
static void Main(string[] args)
{
MqttClient client = new MqttClient(MQTT_BROKER_ADDRESS);
byte code = client.Connect(Guid.NewGuid().ToString());
ushort msgId = client.Subscribe(new string[] { Topics }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });
client.MqttMsgPublishReceived += client_MqttMsgPublishReceived;
}
{
MqttClient client = new MqttClient(MQTT_BROKER_ADDRESS);
byte code = client.Connect(Guid.NewGuid().ToString());
ushort msgId = client.Subscribe(new string[] { Topics }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });
client.MqttMsgPublishReceived += client_MqttMsgPublishReceived;
}
MQTT_BROKER_ADDRESS:填入主機位址
Topics:填入要訂閱的Topic
private static void client_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e)
{
Console.WriteLine("Received = " + Encoding.UTF8.GetString(e.Message) + " on topic " + e.Topic);
}
{
Console.WriteLine("Received = " + Encoding.UTF8.GetString(e.Message) + " on topic " + e.Topic);
}