ClientWebSocket.ConnectAsync崩潰與任何錯誤信息

Question

我試圖從C＃控制檯應用程序連接到WebSocket API。

我的代碼崩潰ConnectAsync方法，它不會落入catch block或給出任何錯誤。

這裏是我的代碼

public async System.Threading.Tasks.Task<Details> Get(string locationUid, string eventType) 
{ 
    ServicePointManager.SecurityProtocol = SecurityProtocolType.Ssl3 | SecurityProtocolType.Tls | 
              SecurityProtocolType.Tls11 | SecurityProtocolType.Tls12; 
    var cancellationTokenSource = new CancellationTokenSource(); 
    using (ClientWebSocket clientWebSocket = new ClientWebSocket()) 
    { 
     Uri serverUri = new Uri(Endpoint.WebSocketUrl); 
     try 
     { 
      await clientWebSocket.ConnectAsync(serverUri, cancellationTokenSource.Token); 
     } 
     catch (Exception e) 
     { 
      Console.WriteLine(e); 
      throw; 
     } 

     while (clientWebSocket.State == WebSocketState.Open) 
     { 
      string bodyMessage = $"{{\"locationUid\":\"{locationUid}\",\"eventTypes\":[\"{eventType}\"]}}"; 
      ArraySegment<byte> bytesToSend = new ArraySegment<byte>(Encoding.UTF8.GetBytes(bodyMessage)); 
      await clientWebSocket.SendAsync(bytesToSend, WebSocketMessageType.Text, true, CancellationToken.None); 
      ArraySegment<byte> bytesReceived = new ArraySegment<byte>(new byte[1024]); 
      WebSocketReceiveResult result = await clientWebSocket.ReceiveAsync(bytesReceived, CancellationToken.None); 
      var response = Encoding.UTF8.GetString(bytesReceived.Array, 0, result.Count); 
     } 
    } 
    return null; 
} 

應用墜毀await clientWebSocket.ConnectAsync(serverUri, cancellationTokenSource.Token);也不掉落在catch塊

我改變connectAsync線如下

clientWebSocket.ConnectAsync(serverUri, cancellationTokenSource.Token).Wait(cancellationTokenSource.Token); 

現在下降抓塊以下例外

The request was aborted: Could not create SSL/TLS secure channel.

堆棧跟蹤

at System.Net.HttpWebRequest.EndGetResponse(IAsyncResult asyncResult) 
    at System.Threading.Tasks.TaskFactory`1.FromAsyncCoreLogic(IAsyncResult iar, Func`2 endFunction, Action`1 endAction, Task`1 promise, Boolean requiresSynchronization) 
--- End of stack trace from previous location where exception was thrown --- 
    at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task) 
    at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task) 
    at System.Net.WebSockets.ClientWebSocket.<ConnectAsyncCore>d__21.MoveNext() 

然後我說的方法之前，下面一行開始

ServicePointManager.SecurityProtocol = SecurityProtocolType.Ssl3 | SecurityProtocolType.Tls | 
                SecurityProtocolType.Tls11 | SecurityProtocolType.Tls12; 

新的異常

Unable to connect to the remote server The remote server returned an error: (400) Bad Request.

堆棧跟蹤：

at System.Net.WebSockets.ClientWebSocket.<ConnectAsyncCore>d__21.MoveNext() 

    at System.Net.HttpWebRequest.EndGetResponse(IAsyncResult asyncResult) 
    at System.Threading.Tasks.TaskFactory`1.FromAsyncCoreLogic(IAsyncResult iar, Func`2 endFunction, Action`1 endAction, Task`1 promise, Boolean requiresSynchronization) 
--- End of stack trace from previous location where exception was thrown --- 
    at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task) 
    at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task) 
    at System.Net.WebSockets.ClientWebSocket.<ConnectAsyncCore>d__21.MoveNext() 

Answer 1

這就是我得到這個工作。

public async Task<string> GetAllAsync(string url, string bodyMessage, 
      Dictionary<string, string> additionalHeaders) 
     { 
      _securityService.SetClientToken().Wait(); 
      ServicePointManager.SecurityProtocol = SecurityProtocolType.Ssl3 | SecurityProtocolType.Tls | 
                SecurityProtocolType.Tls11 | SecurityProtocolType.Tls12; 

      var cancellationTokenSource = new CancellationTokenSource(new TimeSpan(1, 1, 0, 0)); 
      using (ClientWebSocket clientWebSocket = new ClientWebSocket()) 
      { 
       Uri serverUri = new Uri(url); 
       clientWebSocket.Options.SetRequestHeader("Authorization", $"Bearer {Endpoint.ClientAccessToken}"); 
       foreach (var additionalHeader in additionalHeaders) 
       { 
        clientWebSocket.Options.SetRequestHeader(additionalHeader.Key, additionalHeader.Value); 
       } 
       try 
       { 
        clientWebSocket.ConnectAsync(serverUri, cancellationTokenSource.Token) 
         .Wait(cancellationTokenSource.Token); 
       } 
       catch (Exception exception) 
       { 
        Console.WriteLine(exception); 
        throw; 
       } 
       while (clientWebSocket.State == WebSocketState.Open) 
       { 
        ArraySegment<byte> bytesToSend = new ArraySegment<byte>(Encoding.UTF8.GetBytes(bodyMessage)); 
        await clientWebSocket.SendAsync(bytesToSend, WebSocketMessageType.Text, true, 
         CancellationToken.None); 
        ArraySegment<byte> bytesReceived = new ArraySegment<byte>(new byte[1024]); 
        WebSocketReceiveResult result = 
         await clientWebSocket.ReceiveAsync(bytesReceived, CancellationToken.None); 
        var response = Encoding.UTF8.GetString(bytesReceived.Array, 0, result.Count); 
        return response; 
       } 
      } 
      return null; 
     }