HoloLensアプリ（Unity）とNode-REDで動くWebSocketサーバーをつなぐメモ

using UnityEngine;
using System.Collections;
using UnityEngine.Networking;
using System;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Collections.Generic;
using MiniJSON;

#if UNITY_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 SphereCommands2 : MonoBehaviour
{
    Vector3 originalPosition;
    Vector3 originalRotation;
    Vector3 originalScale;

    public bool flagOnOff = false;

#if UNITY_UWP
    private MessageWebSocket messageWebSocket;
    private DataWriter messageWriter;
    private bool busy;
#endif

    // Use this for initialization
    void Start()
    {
        // 初期の位置記憶
        originalPosition = this.transform.localPosition;

        originalRotation = this.transform.localRotation.eulerAngles;

        originalScale = this.transform.localScale;

#if UNITY_UWP
        // HoloLens実機でWebSocket接続開始
        OnConnect();
#endif
    }

    // Called by GazeGestureManager when the user performs a Select gesture
    void OnSelect()
    {
        if (flagOnOff)
        {
            flagOnOff = false;

            // もとに戻る移動の動作
            iTween.MoveTo(this.gameObject, iTween.Hash(
                "y", originalPosition.y,
                "time", 2f,
                "oncomplete", "AnimationEnd",
                "oncompletetarget", this.gameObject,
                "easeType", "easeInOutBack"
            ));

            // もとに戻る回転の動作
            iTween.RotateTo(this.gameObject, iTween.Hash(
                "x", originalRotation.x,
                "time", 2f
            ));

            // もとに戻る大きさの動作
            iTween.ScaleTo(this.gameObject, iTween.Hash(
                "x", originalScale.x,
                "y", originalScale.y,
                "z", originalScale.z,
                "time", 2f
            ));
        }
        else
        {
            flagOnOff = true;

            var dic = Json.Deserialize("{\"value1\":\"\",\"value2\":2,\"value3\":3}") as Dictionary<string, object>;
            dic["value1"] = System.DateTime.Now.ToString();
            dic["value2"] = this.gameObject.name;
            dic["value3"] = flagOnOff;

            var json = Json.Serialize(dic);
            Debug.Log(json);

#if UNITY_UWP
            Task.Run(async () =>
            {
                AppendOutputLine("Send JSON : " + json);

                UnityEngine.WSA.Application.InvokeOnAppThread(() => {

                    AppendOutputLine("InvokeOnAppThread : iTween");

                    // クリック時にふわっと浮く動作
                    iTween.MoveTo(this.gameObject, iTween.Hash(
                        "y", originalPosition.y + 0.3,
                        "time", 2f,
                        "oncomplete", "AnimationEnd",
                        "oncompletetarget", this.gameObject,
                        "easeType", "easeInOutBack"
                    ));

                }, true);

                await WebSock_SendMessage(messageWebSocket, json);
            });
#endif


        }
    }

    // Called by SpeechManager when the user says the "Reset world" command
    void OnReset()
    {
        
    }

    // Called by SpeechManager when the user says the "Drop sphere" command
    void OnDrop()
    {
        
    }

#if UNITY_UWP


    private void OnConnect()
    {

        AppendOutputLine("OnConnect");
        
        messageWebSocket = new MessageWebSocket();

        //In this case we will be sending/receiving a string so we need to set the MessageType to Utf8.
        messageWebSocket.Control.MessageType = SocketMessageType.Utf8;

        //Add the MessageReceived event handler.
        messageWebSocket.MessageReceived += WebSock_MessageReceived;

        //Add the Closed event handler.
        messageWebSocket.Closed += WebSock_Closed;

        Uri serverUri = new Uri("ws://192.168.1.6:1880"); // 別PCのNode-REDのWebSocketにつながる

        try
        {
            Task.Run(async () => {
                //Connect to the server.
                AppendOutputLine("Connect to the server...." + serverUri.ToString());
                await Task.Run(async () =>
                {
                    await messageWebSocket.ConnectAsync(serverUri);
                    AppendOutputLine("ConnectAsync OK");

                    await WebSock_SendMessage(messageWebSocket, "Connect Start");
                });
                
            });
        }
        catch (Exception ex)
        {
            AppendOutputLine("error : " + ex.ToString());

            //Add code here to handle any exceptions
        }
        
    }
    
    private async Task WebSock_SendMessage(MessageWebSocket webSock, string message)
    {
        AppendOutputLine("WebSock_SendMessage : " + message);

        DataWriter messageWriter = new DataWriter(webSock.OutputStream);
        messageWriter.WriteString(message);
        await messageWriter.StoreAsync();
    }

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

        //Add code here to do something with the string that is received.

        Task.Run(async () =>
        {

            UnityEngine.WSA.Application.InvokeOnAppThread(() => {

                AppendOutputLine("InvokeOnAppThread : iTween");

                // WebSocket受信時に回転が変わる
                iTween.RotateTo(this.gameObject, iTween.Hash(
                    "x", UnityEngine.Random.Range(1, 5) * 20,
                    "y", UnityEngine.Random.Range(1, 5) * 20,
                    "z", UnityEngine.Random.Range(1, 5) * 20,
                    "time", 2f
                ));

                // WebSocket受信時に大きさが変わる
                var scale = UnityEngine.Random.Range(1, 5) * 0.02;
                iTween.ScaleTo(this.gameObject, iTween.Hash(
                    "x", originalScale.x + scale,
                    "y", originalScale.y + scale,
                    "z", originalScale.z + scale,
                    "time", 2f
                ));

            }, true);

            await Task.Delay(100);
        });
    }

    private void WebSock_Closed(IWebSocket sender, WebSocketClosedEventArgs args)
    {
        //Add code here to do something when the connection is closed locally or by the server
    }

    private void AppendOutputLine(string value)
    {
        // OutputField.Text += value + "\r\n";
        Debug.Log(value);
    }

#endif 


}