HoloLens2 で MQTTnet ライブラリを使って MQTT 通信できたメモ

using System;
using System.Text;

using System.Threading.Tasks;
using System.Threading;

using MQTTnet;
using MQTTnet.Client;
using UnityEngine;
using UnityEngine.EventSystems;

public class Main : MonoBehaviour
{
    IMqttClient mqttClient;

    private SynchronizationContext context;

    async void Start()
    {
        Debug.Log("Start");

        // Unity Editor でメインスレッドに戻れるよう SynchronizationContext.Current 記録
        context = SynchronizationContext.Current;

        var factory = new MqttFactory();
        mqttClient = factory.CreateMqttClient();

        var options = new MqttClientOptionsBuilder()
            .WithTcpServer("<MQTT Server>")
            // .WithCredentials("ID", "PASS") // MQTT に ID/PASS が必要な場合は WithCredentials 記述を
            .Build();

        mqttClient.Connected += (s, e) =>
        {
             LogMessage("mqttClient.Connected");
        };

        mqttClient.Disconnected += async (s, e) =>
        {

            LogMessage("mqttClient.Disconnected");

            if (e.Exception == null)
            {
                LogMessage("Exception Disconnected");

                return;
            }

            UnityEngine.WSA.Application.InvokeOnAppThread(() => {
                LogMessage("Unexception disconnected");
            }, true);

            await Task.Delay(TimeSpan.FromSeconds(5));

            try
            {
                await mqttClient.ConnectAsync(options);
            }
            catch
            {
                LogMessage("Reconnect failed.");
            }
        };

        // メッセージ受信時の処理
        mqttClient.ApplicationMessageReceived += (s, e) =>
        {
            var stringBuilder = new StringBuilder();
            stringBuilder.AppendLine("ApplicationMessageReceived");
            stringBuilder.AppendLine($"Topic = {e.ApplicationMessage.Topic}");
            stringBuilder.AppendLine($"Payload = {Encoding.UTF8.GetString(e.ApplicationMessage.Payload)}");
            stringBuilder.AppendLine($"QoS = {e.ApplicationMessage.QualityOfServiceLevel}");
            stringBuilder.AppendLine($"Retain = {e.ApplicationMessage.Retain}");
            LogMessage(stringBuilder);
        };

        // 接続
        await mqttClient.ConnectAsync(options);

        // メッセージ受信する購読 subscribe
        await mqttClient.SubscribeAsync(new TopicFilterBuilder().WithTopic("hololens2/firststep").Build());

        // メッセージの送信するための設定
        var message = new MqttApplicationMessageBuilder()
            .WithTopic("hololens2/firststep")
            .WithPayload("Hello HoloLens2")
            .WithExactlyOnceQoS()
            .Build();
        // メッセージの送信 publish
        await mqttClient.PublishAsync(message);
    }

    async void LogMessage(object message)
    {
#if WINDOWS_UWP

        await Task.Run(() =>
        {
            // メインスレッドに戻す UWP の場合
            UnityEngine.WSA.Application.InvokeOnAppThread(() =>
            {
                Debug.Log(message);

                // GameObjectなどで描画するならこの中に処理を書く UWP の場合

            }, true);
        });
#elif UNITY_EDITOR
        await Task.Run(() =>
        {

            SynchronizationContext.SetSynchronizationContext(context);

            // メインスレッドに戻す Unty Editor の場合
            context.Post((state) =>
            {
                // 単純にログに出すだけならメインスレッドに戻さず書ける
                Debug.Log(message);

                // GameObjectなどで描画するならこの中に処理を書く

            }, null);
        });
#endif
    }
}

        var options = new MqttClientOptionsBuilder()
            .WithTcpServer("<MQTT Server>")
            // .WithCredentials("ID", "PASS") // MQTT に ID/PASS が必要な場合は WithCredentials 記述を
            .Build();