c# - 机器人 channel 注册 SocketException - 远程主机强制关闭现有连接

Question

我有一个带有 ASP.NET REST API 应用程序的 Azure Web 应用程序，充当机器人 channel 注册的服务。

在此应用中，我有一个端点

 public async Task<IHttpActionResult> Post(string userToken, string botName, [FromBody] Activity activity)

我从用户那里收到消息，处理它并发回。

当我尝试与用户沟通时(通过打字事件或实际答案)

private static async Task ShowTyping(Activity activity, ConnectorClient client)
{
    var typingResponse = new Activity
    {
        Conversation = activity.Conversation,
        From = activity.Recipient,
        Locale = activity.Locale,
        Recipient = activity.From,
        ReplyToId = activity.Id,
        Id = activity.Id,
        Type = "typing"
    };
    await client.Conversations.UpdateActivityAsync(typingResponse);
}

...

foreach (var reply in replies)
{
      Trace.TraceInformation($"[{userToken}:{botName}] Sending reply {reply.Id}:{reply.Text}");
      await client.Conversations.ReplyToActivityAsync(reply);
}

通过 REST API 我收到 HttpRequestException - An existing connection was forcibly closed by the remote host :

2019-01-22T15:49:54  PID[17864] Error       System.Net.Http.HttpRequestException: An error occurred while sending the request. ---> System.Net.WebException: The underlying connection was closed: An unexpected error occurred on a send. ---> System.IO.IOException: Unable to read data from the transport connection: An existing connection was forcibly closed by the remote host. ---> System.Net.Sockets.SocketException: An existing connection was forcibly closed by the remote host    at System.Net.Sockets.Socket.EndReceive(IAsyncResult asyncResult)    at System.Net.Sockets.NetworkStream.EndRead(IAsyncResult asyncResult)   
--- End of inner exception stack trace ---    at System.Net.TlsStream.EndWrite(IAsyncResult asyncResult)    at System.Net.PooledStream.EndWrite(IAsyncResult asyncResult)    at System.Net.ConnectStream.WriteHeadersCallback(IAsyncResult ar)    --- End of inner exception stack trace ---    at System.Net.HttpWebRequest.EndGetRequestStream(IAsyncResult asyncResult, TransportContext& context)    at System.Net.Http.HttpClientHandler.GetRequestStreamCallback(IAsyncResult ar)    --- End of inner exception stack trace ---    at Microsoft.Rest.RetryDelegatingHandler.<SendAsync>d__15.MoveNext()
--- 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.Runtime.CompilerServices.TaskAwaiter.ValidateEnd(Task task)    at Microsoft.Bot.Connector.Conversations.<UpdateActivityWithHttpMessagesAsync>d__9.MoveNext()
--- 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 Microsoft.Bot.Connector.ConversationsExtensions.<UpdateActivityAsync>d__16.MoveNext()
--- 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 ChatFirst.Channels.BotFramework.Controllers.WebhookController.<ShowTyping>d__5.MoveNext()

在模拟器上一切正常，但在网络服务中根本不起作用。我尝试自己实现REST API客户端，但得到了相同的结果。

我错过了什么？

<小时/>

有关该问题的更多信息

1. 我使用 v4.2 Bot Framework 包

   <package id="Microsoft.Bot.Builder" version="4.2.0" targetFramework="net472" /> <package id="Microsoft.Bot.Connector" version="4.2.0" targetFramework="net472" /> <package id="Microsoft.Bot.Schema" version="4.2.0" targetFramework="net472" />

2. 整个 Post 方法，userToken和botName是我的内部凭证

   /// <summary>
   ///     POST: api/v1/webhook/{userToken}/{botName}
   ///     Receive a message from a user and reply to it
   /// </summary>
   [HttpPost]
   [Route("api/v1/webhook/{userToken}/{botName}")]
   public async Task<IHttpActionResult> Post(string userToken, string botName, [FromBody] Activity activity)
   {
       try
       {
           if (activity.Type == ActivityTypes.Message)
           {
               Trace.TraceInformation($"[{userToken}:{botName}] Message from {activity.From.Id}");
               MicrosoftAppCredentials credentials = _channelGateway.GetCredentials(userToken, botName);
   
               if (credentials == null)
                   return Ok();
   
               var serviceUri = new Uri(activity.ServiceUrl);
               var client = new ConnectorClient(serviceUri, credentials);
   
               await ShowTyping(activity, client);
   
               IEnumerable<Activity> replies = await _coreTalkService.GetRepliesAsync(new BotToken(userToken, botName), activity);
   
               foreach (var reply in replies)
               {
                   Trace.TraceInformation($"[{userToken}:{botName}] Sending reply {reply.Id}:{reply.Text}");
                   await client.Conversations.ReplyToActivityAsync(reply);
               }
           }
           else
           {
               HandleSystemMessage(activity);
           }
   
           return Ok();
       }
       catch (Exception e)
       {
           Trace.TraceError(e.ToString());
           return InternalServerError(e);
       }
   }
   

3. 机器人 channel 注册设置如下所示

4. 如果我通过 ngrok 将 Bot Channel 重新路由到我的开发 PC 上的本地实例，我会收到相同的错误。

5. 我减少了整个方法来执行简单的回显应答，但错误仍然存​​在

public async Task<IHttpActionResult> Post(string userToken, string botName, [FromBody] Activity activity)
{
    Trace.TraceInformation($"[{userToken}:{botName}] Message from {activity.From.Id}");
    var client = new ConnectorClient(new Uri(activity.ServiceUrl), 
        new MicrosoftAppCredentials("<secret>", "<secret>"));
    var answer = activity.CreateReply(activity.Text, activity.Locale);
    await client.Conversations.ReplyToActivityAsync(answer);
    return Ok();
}

activity.ServiceUrl是 https://webchat.botframework.com/

如果通过网络聊天发送消息，则会发生错误，我没有检查其他 channel

Answer 1

我唯一能想到的是一定有一些引用的库干扰了项目中的传出消息。

我没有尝试调试您的项目，而是创建了一个按预期工作的新的类似项目:https://github.com/xakpc/BotFrameworkChannel.Test/pull/1