这么多服务总线瞬态错误？

Question

我们有两个 Windows 服务，它们位于企业内部服务器上，并不断向云中的 Azure 服务总线发送消息。尽管消息最终确实会在服务总线上结束，但有时消息似乎在很长一段时间内都无法通过。

这给我们带来了延迟问题，因为我们依赖于消息到达服务总线并在一分钟内得到处理。但是，如下所示，一条消息可能会被“阻止”长达 30-40 分钟，然后才能进入 Azure 服务总线。这种情况每天都会发生，而且几乎在每个小时的某个时间都会发生。

错误主要是以下之一（本文末尾的示例日志）：

• 连接尝试失败，因为连接的一方在一段时间后没有正确响应，或者建立连接失败，因为连接的主机没有响应 191.239.XX.XXX:443

• 与服务总线通信时出错。检查连接信息，然后重试。

• 没有这样的主机已知

• 请求操作未在分配的超时时间 00:01:10 内完成。分配给此操作的时间可能是较长超时的一部分。 TrackingId：f2db6377-e17d-401a-b339-11fbb51c7bf7，时间戳：19/05/2017 12:47:36 AM

我们向服务总线发送消息的方式如下，简化如下：

private TopicClient _azureTopic;

...
<Begin Loop>

if (_azureTopic == null)
{
   var connectionString = "Endpoint=sb://mynamespace.servicebus.windows.net/;SharedAccessKeyName=managerfiddev;SharedAccessKey=AABBCCDDEEFFGGHHHASDFADFAadfadfdfz=EntityPath=mytopic";
   _azureTopic = TopicClient.CreateFromConnectionString(connectionString);
   _azureTopic.RetryPolicy = RetryPolicy.NoRetry;
}

var brokeredMessage = new BrokeredMessage(message.Message)
{
    MessageId = message.Id.ToString()
};
brokeredMessage.Properties["ReceivedTimestamp"] = DateTime.Now;

_azureTopic.Send(brokeredMessage);

<End Loop>

注意： 我们制定 NoRetry 政策是有原因的。不想给问题增加太多噪音，失败的相同消息将在下一次迭代中再次尝试（它以循环方式将消息发送给订阅者）。

小时间窗口内的错误日志示例。

20:31:51 Event.WindowsService Event.WindowsService::PublishAzureServiceBusTopicMessage() 尝试与 Azure 同步消息时出错。留言编号：1191251
与服务总线通信时出错。检查连接 信息，然后重试。

20:32:00 Event.WindowsService Event.WindowsService::PublishAzureServiceBusTopicMessage() 尝试与 Azure 同步消息时出错。留言编号：1191251
没有这样的主机是已知的

20:32:00 RFID.WindowsService RFID.WindowsService::PublishAzureServiceBusTopicMessage() 尝试与 Azure 同步消息时出错。留言编号：1930029
没有这样的主机是已知的

20:32:10 RFID.WindowsService RFID.WindowsService::PublishAzureServiceBusTopicMessage() 尝试与 Azure 同步消息时出错。留言编号：1930029
没有这样的主机是已知的

20:32:10 Event.WindowsService Event.WindowsService::PublishAzureServiceBusTopicMessage() 尝试与 Azure 同步消息时出错。留言编号：1191251
没有这样的主机是已知的

20:32:10 RFID.WindowsService RFID.WindowsService::PublishAzureServiceBusTopicMessage() 尝试与 Azure 同步消息时出错。留言编号：1930029
没有这样的主机是已知的

20:34:00 RFID.WindowsService RFID.WindowsService::PublishAzureServiceBusTopicMessage() 尝试与 Azure 同步消息时出错。消息 ID：1930034
与服务总线通信时出错。检查连接 信息，然后重试。

20:38:34 Event.WindowsService Event.WindowsService::PublishAzureServiceBusTopicMessage() 尝试与 Azure 同步消息时出错。留言编号：1191269
与服务总线通信时出错。检查连接 信息，然后重试。

20:38:51 RFID.WindowsService RFID.WindowsService::PublishAzureServiceBusTopicMessage() 尝试与 Azure 同步消息时出错。消息 ID：1930043
与服务总线通信时出错。检查连接 信息，然后重试。

Answer 1

服务总线在 Namespace Manager、Messaging Factory 和 Client 上具有本机重试功能（请参阅 Retry guidance for specific services）。

因为它正在处理瞬态异常，所以您不应该重复发送消息。

如果你只想重试一次你可以这样配置：

var connectionString = "myconnectionstring";
var client = TopicClient.CreateFromConnectionString(connectionString);
client.RetryPolicy = new RetryExponential(minBackoff: TimeSpan.FromSeconds(2),
                                        maxBackoff: TimeSpan.FromSeconds(2),
                                        maxRetryCount: 1);

这应该可以解决问题。

如果要确保重复数据删除，只需 google azure servicebus deduplication。