1

czw

6 天以前 1b0fabfa17d07c9bd38eeafd204b638afa4d7c39

 HnSx/Build/Project/´úÂë/VS×Ô¶¨ÒåÀà/AutoThread.cs

@@ -120,6 +120,8 @@
        /// <param name="action"></param>
        public void ThreadSettingInit(Tag tag)
        {


        }

        public async void ThreadwebSoc()
@@ -768,10 +770,10 @@
                                            }
                                            else return "发送失败。";
                                        }
                                        else
                                        {
                                            return "未连接。";
                                        }
                                        //else
                                        //{
                                        //    return "未连接。";
                                        //}
                                    }
                                    break;
                            }
@@ -1057,13 +1059,21 @@

        public async Task<bool> SendAsync(string message)
        {
            if (_webSocket?.State != WebSocketState.Open)
            try
            {
                throw new InvalidOperationException("WebSocket is not connected");
            }
                if (_webSocket?.State != WebSocketState.Open)
                {
                    throw new InvalidOperationException("WebSocket is not connected");
                }

            var bytes = System.Text.Encoding.UTF8.GetBytes(message);
            await _webSocket.SendAsync(new ArraySegment<byte>(bytes), WebSocketMessageType.Text, true, _cts.Token);
                var bytes = System.Text.Encoding.UTF8.GetBytes(message);
                await _webSocket.SendAsync(new ArraySegment<byte>(bytes), WebSocketMessageType.Text, true, _cts.Token);
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex.Message, ex);
                return false;
            }
            return true;
        }
    }