HoloLens2 と Node-RED を WebSocket でやり取りするメモ

using System.Collections;
using System.Collections.Generic;
using Microsoft.MixedReality.Toolkit.Input;
using UnityEngine;
using UnityEngine.Networking;
using System;
using System.Net;
using System.Net.Sockets;
using System.Threading;

#if WINDOWS_UWP
    using Windows.Foundation;
    using Windows.Networking.Sockets;
    using Windows.Security.Cryptography.Certificates;
    using Windows.Storage.Streams;
    using System.Threading.Tasks;
#else
using System.Text;
#endif

public class CubeTouchEvent : MonoBehaviour
{

#if WINDOWS_UWP
    private MessageWebSocket messageWebSocket;
#endif

    void Start()
    {
#if WINDOWS_UWP
        // HoloLens2 実機でWebSocket接続開始
        OnConnect();
#endif
    }

    void Update()
    {
        
    }

    public void TouchStarted(HandTrackingInputEventData eventData)
    {
        // TouchStartedが2度送られるときはボタンの形状を薄くしたり小さめにすると1度だけになった

        Debug.Log("TouchStarted");

        // 直接タッチするとちょっと小さくなる
        this.transform.localScale = new Vector3(0.09f, 0.09f, 0.02f);

#if WINDOWS_UWP
        try
        {
            Task.Run(async () => {
                await WebSock_SendMessage(messageWebSocket, "Touched!! 1");
            });
        }
        catch (Exception ex)
        {
            Debug.Log("error : " + ex.ToString());
        }
#endif


    }

    public void TouchCompleted(HandTrackingInputEventData eventData)
    {
        Debug.Log("TouchCompleted");

        // 元に戻る
        this.transform.localScale = new Vector3(0.1f, 0.1f, 0.02f);
    }

#if WINDOWS_UWP
 
 
    private void OnConnect()
    {
 
        Debug.Log("OnConnect");
         
        messageWebSocket = new MessageWebSocket();

        messageWebSocket.Control.MessageType = SocketMessageType.Utf8;
        messageWebSocket.MessageReceived += WebSock_MessageReceived;
        messageWebSocket.Closed += WebSock_Closed;
 
        Uri serverUri = new Uri("ws://192.168.1.105:1880"); // 別PCのNode-REDのWebSocketにつながる
 
        try
        {
            Task.Run(async () =>
            {
                await messageWebSocket.ConnectAsync(serverUri);

                Debug.Log("Connect to the server...." + serverUri.ToString());
                Debug.Log("ConnectAsync OK");
 
                await WebSock_SendMessage(messageWebSocket, "Connect Start");
            });
        }
        catch (Exception ex)
        {
            Debug.Log("error : " + ex.ToString());
        }
         
    }
     
    private async Task WebSock_SendMessage(MessageWebSocket webSock, string message)
    {
        DataWriter messageWriter = new DataWriter(webSock.OutputStream);
        messageWriter.WriteString(message);
        await messageWriter.StoreAsync();
        messageWriter.DetachStream(); // ストリームの破棄。今回加えたら何度も送られるようになった。加えないと一度だけしか送られない。

    }
 
    private void WebSock_MessageReceived(MessageWebSocket sender, MessageWebSocketMessageReceivedEventArgs args)
    {
        DataReader messageReader = args.GetDataReader();
        messageReader.UnicodeEncoding = UnicodeEncoding.Utf8;
        string messageString = messageReader.ReadString(messageReader.UnconsumedBufferLength);

        Task.Run(async () =>
        {
 
            UnityEngine.WSA.Application.InvokeOnAppThread(() => {
                // Node-RED からデータが来るとなんだか細くなる
                this.transform.localScale = new Vector3(0.05f, 0.05f, 0.1f);
            }, true);
 
            await Task.Delay(100);
        });
    }
 
    private void WebSock_Closed(IWebSocket sender, WebSocketClosedEventArgs args)
    {
        // WebSock_Closed
    }
 
#endif

}

    private async Task WebSock_SendMessage(MessageWebSocket webSock, string message)
    {
        DataWriter messageWriter = new DataWriter(webSock.OutputStream);
        messageWriter.WriteString(message);
        await messageWriter.StoreAsync();
        messageWriter.DetachStream(); // ストリームの破棄。今回加えたら何度も送られるようになった。加えないと一度だけしか送られない。

    }

js
[{"id":"5b36a107.f83ad","type":"websocket in","z":"856fbae5.267df8","name":"","server":"b994b2c6.576df","client":"","x":410,"y":160,"wires":[["92080b90.7a2fb8"]]},{"id":"8d6d839.be84a8","type":"websocket out","z":"856fbae5.267df8","name":"","server":"b994b2c6.576df","client":"","x":650,"y":220,"wires":[]},{"id":"92080b90.7a2fb8","type":"debug","z":"856fbae5.267df8","name":"","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"false","statusVal":"","statusType":"auto","x":670,"y":160,"wires":[]},{"id":"b6be4a64.8113d8","type":"inject","z":"856fbae5.267df8","name":"","props":[{"p":"payload"},{"p":"topic","vt":"str"}],"repeat":"","crontab":"","once":false,"onceDelay":0.1,"topic":"","payload":"","payloadType":"date","x":380,"y":220,"wires":[["8d6d839.be84a8"]]},{"id":"b994b2c6.576df","type":"websocket-listener","z":"","path":"/","wholemsg":"false"}]