Microsoft.Azure.ServiceBus - SubscriptionClient 忽略 RetryPolicy (RetryExponencial)
Microsoft.Azure.ServiceBus - SubscriptionClient ignoring RetryPolicy (RetryExponencial)
我正在尝试实施重试政策,但它总是被忽略。
SubscriptionClient 中是否有属性覆盖我在创建客户端时提供的属性?
这是我试过的代码:
_retryPolicy = new Microsoft.Azure.ServiceBus.RetryExponential(
TimeSpan.FromMinutes(2), // MinBackOff
TimeSpan.FromMinutes(5), // MaxBackOff
3); // Max Retries
_subscriptionClient = new SubscriptionClient(
serviceBusPersisterConnection.ServiceBusConnectionStringBuilder,
subscriptionClientName, retryPolicy: _retryPolicy);
所以这应该使它仅以最少 2 分钟的间隔重试 3 次。
日志结果:
28 May 2019 16:34:49.928 MessageId: 1d327c9033de4fc69892766084264
28 May 2019 16:34:49.285 MessageId: 1d327c9033de4fc69892766084264
28 May 2019 16:34:48.718 MessageId: 1d327c9033de4fc69892766084264
28 May 2019 16:34:48.075 MessageId: 1d327c9033de4fc69892766084264
28 May 2019 16:34:47.499 MessageId: 1d327c9033de4fc69892766084264
28 May 2019 16:34:46.965 MessageId: 1d327c9033de4fc69892766084264
28 May 2019 16:34:46.511 MessageId: 1d327c9033de4fc69892766084264
28 May 2019 16:34:45.957 MessageId: 1d327c9033de4fc69892766084264
如您所见,它重试了 8 次而不是 3 次,并且重试之间的时间间隔(这是我的主要问题)有半秒的间隔。
为了确定这不是我的重试策略,我尝试了这个:
_subscriptionClient = new SubscriptionClient(
serviceBusPersisterConnection.ServiceBusConnectionStringBuilder,
subscriptionClientName, retryPolicy: RetryPolicy.NoRetry);
结果完全一样,所以我确定它被忽略了。
任何帮助将不胜感激。
继续努力。
RetryExponential 旨在供服务总线客户端在存在不会立即冒泡到您的代码的暂时性错误时使用。 IE。客户端内置的内部重试机制,用于在引发异常之前代表您执行重试。如果没有异常并且您的回调显式放弃消息,则此处甚至不使用重试策略,并且消息只是通过正常传递最多 MaxDeliveryCount 次(在您的场景中为 50 次),之后是 DQed。
使用重试策略向服务总线客户端指定在放弃之前如何处理暂时性错误,而不是消息可以出列多少次。
您可以阅读有关 here 的更多信息。
希望对您有所帮助。
我正在尝试实施重试政策,但它总是被忽略。 SubscriptionClient 中是否有属性覆盖我在创建客户端时提供的属性?
这是我试过的代码:
_retryPolicy = new Microsoft.Azure.ServiceBus.RetryExponential(
TimeSpan.FromMinutes(2), // MinBackOff
TimeSpan.FromMinutes(5), // MaxBackOff
3); // Max Retries
_subscriptionClient = new SubscriptionClient(
serviceBusPersisterConnection.ServiceBusConnectionStringBuilder,
subscriptionClientName, retryPolicy: _retryPolicy);
所以这应该使它仅以最少 2 分钟的间隔重试 3 次。 日志结果:
28 May 2019 16:34:49.928 MessageId: 1d327c9033de4fc69892766084264
28 May 2019 16:34:49.285 MessageId: 1d327c9033de4fc69892766084264
28 May 2019 16:34:48.718 MessageId: 1d327c9033de4fc69892766084264
28 May 2019 16:34:48.075 MessageId: 1d327c9033de4fc69892766084264
28 May 2019 16:34:47.499 MessageId: 1d327c9033de4fc69892766084264
28 May 2019 16:34:46.965 MessageId: 1d327c9033de4fc69892766084264
28 May 2019 16:34:46.511 MessageId: 1d327c9033de4fc69892766084264
28 May 2019 16:34:45.957 MessageId: 1d327c9033de4fc69892766084264
如您所见,它重试了 8 次而不是 3 次,并且重试之间的时间间隔(这是我的主要问题)有半秒的间隔。
为了确定这不是我的重试策略,我尝试了这个:
_subscriptionClient = new SubscriptionClient(
serviceBusPersisterConnection.ServiceBusConnectionStringBuilder,
subscriptionClientName, retryPolicy: RetryPolicy.NoRetry);
结果完全一样,所以我确定它被忽略了。 任何帮助将不胜感激。
继续努力。
RetryExponential 旨在供服务总线客户端在存在不会立即冒泡到您的代码的暂时性错误时使用。 IE。客户端内置的内部重试机制,用于在引发异常之前代表您执行重试。如果没有异常并且您的回调显式放弃消息,则此处甚至不使用重试策略,并且消息只是通过正常传递最多 MaxDeliveryCount 次(在您的场景中为 50 次),之后是 DQed。
使用重试策略向服务总线客户端指定在放弃之前如何处理暂时性错误,而不是消息可以出列多少次。
您可以阅读有关 here 的更多信息。
希望对您有所帮助。