是否已使用Azure服务总线BrokeredMessage？

Question

我的Azure服务总线出现间歇性问题。偶尔，在总线上放置一条消息会导致以下异常：

类型: InvalidOperationException

消息:无法执行该操作，因为代理消息'723eab13dab34351a78bb687d0923b89‘已被消费。请使用新的BrokeredMessage实例执行该操作。

步进

at Microsoft.ServiceBus.Messaging.MessagingUtilities.ValidateAndSetConsumedMessages(IEnumerable`1 messages)
at Microsoft.ServiceBus.Messaging.MessageSender.Send(TrackingContext trackingContext, IEnumerable`1 messages, TimeSpan timeout)
at Microsoft.Practices.TransientFaultHandling.RetryPolicy.<>c__DisplayClass1.<ExecuteAction>b__0()
at Microsoft.Practices.TransientFaultHandling.RetryPolicy.ExecuteAction[TResult](Func`1 func)
at IQ.IR.Core.ServiceBus.AzureBus`1.Enqueue(T message) in c:\BuildAgent\work\cc0c51104c02a4e9\IQ.IR.Core\ServiceBus\AzureBus.cs:line 69
...Rest of stacktrace snipped as it's within my app

来自AzureBus的有问题的代码是：

public void Enqueue(T message)
{
    using (var brokeredMessage = new BrokeredMessage(message) { Label = message.GetType().FullName, TimeToLive = _timeToLive })
    {
        _retryPolicy.ExecuteAction(() => _sender.Send(brokeredMessage));
    }
}

传入的T消息的位置是

[Serializable]
public class ValidationMessage
{
    public string ValidationToken { get; set;}
}

而_retryPolicy是一个

RetryPolicy<ServiceBusTransientErrorDetectionStrategy>

_timeToLive是一个12小时的时间跨度

有什么想法吗？

Answer 1

该错误指示消息已“已发送”，但在处理过程中发生错误。不幸的是，没有一种简单的方法可以通过检查消息来了解这一点，并且消息不能再次重用，因为它被认为是被消费的。我们正在做一些改进，比如允许你查询这样一条消息的状态，抛出一个MessagingException而不是InvalidOperation。最后，克隆消息的能力将有助于更容易地从此类故障中恢复。

Answer 2

……接下来是Abhishek的回答:现在您需要为每次重试构建一个新的BrokeredMessage，因此您的重试策略范围需要更高一级。请注意，如果您放入一个流，我们将按原样使用代理消息中的流，并将其直接拉到网络上，因此您将需要提前为重试循环制作流的副本。

Answer 3

我最近遇到了这种情况，并发现了另一个原因:如果您正在构造BrokeredMessage，并在使用MessageSender发送它之前设置了断点，并检查消息的属性，则它将尝试访问队列并抛出此异常。只需先发送消息，而不在IDE中检查其属性，不会导致此问题。