客户端未收到来自套接字 js 服务器的消息

Question

我正在努力在桌面上的 UWP 应用程序和 Hololens 1 之间建立消息通信。

根据 Microsoft 文档 Websocket Implementation 中 Websockets 的实现，我可以 使用 socket.io Server 实现 Nodejs 的信令部分

var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);

app.get('/', function(req, res){
  res.sendFile(__dirname + '/index.html');
});


var PORT = 3000;
var userId = 0;

http.listen(PORT, function () {
  console.log('listening on *: ' + PORT);
});

io.on('connection', function(socket){
    socket.userId = userId++;
    console.log('a user connected, user id: ' + socket.userId);

    socket.on('mess', function (msg) {
    console.log('message from user#' + socket.userId + ": " + msg);
    // Send message with emit"mess" to all client
    io.emit('mess', msg);
  });

  socket.on('disconnect', function(){
    console.log('user disconnected');
  });
});

客户端（uwp 应用程序和 hololens）都可以建立到服务器。 在计算机上，我可以向服务器发送一些数据。 我目前遇到的问题是 Hololens 没有收到来自服务器的消息。

对于通信部分，我使用了一个为 2 个客户端提供发送和接收功能的包装类。这个包装类已经生成到 dll 中，以便在 2 个不同的项目中引用（uwp 应用程序和用于 hololens 的统一应用程序）

// Declare "Using" part here...

namespace SocketWrapperNamespace
{

    public delegate void OnReceiveMessengerCallback(string msg);
    public delegate void OnDisconnectCallback(bool connect);

    public class SocketWrapper
    {
        public event OnReceiveMessengerCallback OnReceiveMessenger;
        public event OnDisconnectCallback onDisconnect;

#if !UNITY_EDITOR
        private Uri _uri;
        private MessageWebSocket messageWebSocket;
        private DataWriter dataWriter;
#endif
        // Client can call this function to connect
        public void Connect(string uri)
        {
#if !UNITY_EDITOR
            try
            {
                Connector(uri);
            }
            catch (Exception ex)
            {
                Debug.WriteLine(ex.Message);
            }
#endif
        }

        private async void Connector(string uri)
        {
#if !UNITY_EDITOR
           // Code here look pretty much like in the example from microsoft documentation
#endif
        }

        // Function for client to send message to server
        public void SendMessage(string emiter, string message)
        {
#if !UNITY_EDITOR
            try
            {
                Emit(emiter, message);
            }
            catch (Exception ex)
            {
                Debug.WriteLine(ex.Message);
            }
#endif
        }


        //Emitter
        private async void Emit(string emiter, string message)
        {
#if !UNITY_EDITOR
            try
            {
                if (messageWebSocket == null)
                {
                    return;
                }
                if (dataWriter == null)
                {
                    return;
                }

                string form = string.Format("42[\"{0}\",\"{1}\"]", emiter, message);

                dataWriter.WriteString(form);
                await dataWriter.StoreAsync();
            }
            catch (Exception ex)
            {
                Debug.WriteLine(ex.Message);
            }
#endif
        }

        //Disconnect
        public void Disconnect()
        {
#if !UNITY_EDITOR
          // Disconnecting server ...
#endif
        }

        //Message Arrived Handler
        private void WebSocket_MessageArrived(MessageWebSocket sender, MessageWebSocketMessageReceivedEventArgs args)
        {
#if !UNITY_EDITOR
            try
            {
                if (OnReceiveMessenger == null)
                {
                    return;
                }
                using (DataReader dataReader = args.GetDataReader())
                {
                    if (dataReader != null)
                    {
                        dataReader.UnicodeEncoding = UnicodeEncoding.Utf8;
                        string message = dataReader.ReadString(dataReader.UnconsumedBufferLength);
                        OnReceiveMessenger?.Invoke(message);
                    }
                }
            }
            catch (Exception ex)
            {
                Debug.WriteLine(ex.Message);
            }
#endif
        }

        //Websocket Close Handler
        private void WebSocket_Closed(IWebSocket sender, WebSocketClosedEventArgs args)
        {
#if !UNITY_EDITOR
            // Close work here ...
#endif
    }
}

在 Hololens 上，我准备连接到服务器并监听收到的消息事件。

// hololens client call this method to initialize the connection
public void OnStart()
    {
        socketWrapper = new SocketWrapper();
        uri = String.Concat("ws://",server,":3000/socket.io/?EIO=3&transport=websocket");
#if !UNITY_EDITOR
        socketWrapper.Connect(uri);
        socketWrapper.OnReceiveMessenger += OnMessageArrived_Handler;
        socketWrapper.onDisconnect += OnDisconnect_Handler;
#endif
    }

//Message Arrived Handler
    private void OnMessageArrived_Handler(string msg)
    {
// Here I do not received any message from server
}

我犯了什么错误？我想知道即使我可以从 hololens 连接到服务器，但订阅部分似乎不起作用？ 考虑这 2 个项目位于不同的位置，并且 dll 也发生了同样的情况。

我认为我必须将 SocketWrapper 类设置为 Singleton，因为 hololens 部分实例化了一个新对象，因此订阅可能在这里不起作用

使用其他实现解决此问题的任何更好的建议都会有所帮助。

谢谢

Answer 1

我认为现在在 C# 和 Unity 环境中使用 WebSocket 的最佳解决方案是WebSocketSharp library。 它有一个很好的实现，并保持更新至今 6 年。此外，它还有 3 个示例说明如何在不同场景中使用它。