Microsoft Azure服务总线队列充当FIFO

Question

我正在为Azure开发两个WebJob：一个将使用主题将消息放入Service Bus队列，另一个将使用相同主题将消息订阅到ServiceBusTrigger。

消息已正确发送到服务总线队列，但是当运行WebJob订阅ServiceBusTrigger时，这些消息将不会以FIFO为基础进行处理。

将消息放入服务总线队列中的WebJob的代码如下：

NamespaceManager namespaceManager = NamespaceManager.Create();

// Delete if exists
if (namespaceManager.TopicExists("SampleTopic"))
{
    namespaceManager.DeleteTopic("SampleTopic");
}

TopicDescription td = new TopicDescription("SampleTopic");
td.SupportOrdering = true;
TopicDescription myTopic = namespaceManager.CreateTopic(td);

SubscriptionDescription myAuditSubscription = namespaceManager.CreateSubscription(myTopic.Path, "ImporterSubscription");

TopicClient topicClient = TopicClient.Create("SampleTopic");
for(int i = 1; i <= 10; i++)
{
    var message = new BrokeredMessage("message"+i);                   
    topicClient.Send(message);
}
topicClient.Close();

订阅服务总线触发器的WebJob具有以下代码：

namespace HO.Importer.Azure.WebJob.TGZProcessor
{
    public class Program
    {
        static void Main(string[] args)
        {
            JobHostConfiguration config = new JobHostConfiguration();
            config.UseServiceBus();
            JobHost host = new JobHost(config);
            host.RunAndBlock();
        }

        public static void WriteLog([ServiceBusTrigger("SampleTopic", "ImporterSubscription")] string message,
            TextWriter logger)
        {                
            Console.WriteLine(message));
        }
    }
}

如何实现将队列中的消息作为FIFO处理？

提前致谢！

Answer 1

使用SessionId或PartitionKey，将确保该消息由同一消息代理处理。

请参阅：https : //docs.microsoft.com/zh-cn/azure/service-bus-messaging/service-bus-partitioning

“ SessionId：如果消息设置了BrokeredMessage.SessionId属性，则Service Bus将该属性用作分区键。这样，属于同一会话的所有消息都由同一个消息代理处理。这使Service Bus能够确保消息排序以及会话状态的一致性。”