【发布时间】：2019-01-22 16:06:43
【问题描述】：
我有一个带有 ASP.NET REST API 应用程序的 Azure Web 应用程序，它充当机器人通道注册的服务。
在这个应用程序中，我有一个端点
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()
在模拟器上一切正常，在 Web 服务中根本不起作用。 我尝试自己实现 REST API 客户端，但得到了相同的结果。
我错过了什么？
有关该问题的更多信息
-
我使用 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" /> -
整个 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); } } 如果我通过 ngrok 将 Bot Channel 重新路由到我的开发 PC 上的本地实例，我会收到相同的错误。
我减少了整个方法来执行简单的回显应答，但错误仍然存在
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();
}
【问题讨论】：
-
嗯，这是您报告的一个非常低级别的网络断开异常。你是如何配置客户端的？您是否设置了凭据？这是否发生在通过客户端发送的第一条消息或...？
-
您的 Post 方法看起来不像普通的消息传递端点。您是否绕过连接器服务并直接调用机器人？请分享您用于与机器人通信的客户端代码。
-
感谢您的宝贵时间。我希望我提供了足够的信息来澄清问题。这应该是一项简单的任务，但我不知道为什么它不起作用。
-
您已更改消息传递端点签名。网络聊天控件将调用 Direct Line 连接器服务，该服务将依次调用您的机器人的消息传递端点（不发送任何 userToken 或 botName）。
-
@EricDahlvang usetToken 和 botName 是我的内部凭据，据我了解，对于消息传递端点，
https://link/api/v1/webhook或https://link/api/v1/webhook/a/b之间没有区别。此外，我确实正常接收用户消息，当我尝试回复时出现异常。
标签： c# .net azure botframework