| | |
| | | } |
| | | |
| | | await m_Socket.ConnectAsync(uri, m_CancellationToken); |
| | | Debug.Log($"[NativeWebSocket] ConnectAsync 完成, Socket.State = {m_Socket.State}"); |
| | | // Debug.Log($"[NativeWebSocket] ConnectAsync 完成, Socket.State = {m_Socket.State}"); |
| | | OnOpen?.Invoke(); |
| | | |
| | | Debug.Log("[NativeWebSocket] 开始进入 Receive 循环..."); |
| | | // Debug.Log("[NativeWebSocket] 开始进入 Receive 循环..."); |
| | | await Receive(); |
| | | Debug.Log("[NativeWebSocket] Receive 循环已返回"); |
| | | // Debug.Log("[NativeWebSocket] Receive 循环已返回"); |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | |
| | | WebSocketCloseCode closeCode = WebSocketCloseCode.Abnormal; |
| | | await new WaitForBackgroundThread(); |
| | | |
| | | Debug.Log($"[NativeWebSocket] Receive 循环开始, Socket.State = {m_Socket.State}"); |
| | | // Debug.Log($"[NativeWebSocket] Receive 循环开始, Socket.State = {m_Socket.State}"); |
| | | int messageCount = 0; |
| | | |
| | | ArraySegment<byte> buffer = new ArraySegment<byte>(new byte[8192]); |
| | |
| | | if (result.MessageType == WebSocketMessageType.Text) |
| | | { |
| | | messageCount++; |
| | | Debug.Log($"[NativeWebSocket] 📩 收到文本消息 #{messageCount}, 大小: {ms.Length} bytes"); |
| | | // Debug.Log($"[NativeWebSocket] 📩 收到文本消息 #{messageCount}, 大小: {ms.Length} bytes"); |
| | | lock (IncomingMessageLock) |
| | | { |
| | | m_MessageList.Add(ms.ToArray()); |
| | |
| | | else if (result.MessageType == WebSocketMessageType.Binary) |
| | | { |
| | | messageCount++; |
| | | Debug.Log($"[NativeWebSocket] 📩 收到二进制消息 #{messageCount}, 大小: {ms.Length} bytes"); |
| | | // Debug.Log($"[NativeWebSocket] 📩 收到二进制消息 #{messageCount}, 大小: {ms.Length} bytes"); |
| | | lock (IncomingMessageLock) |
| | | { |
| | | m_MessageList.Add(ms.ToArray()); |