如何保证azure队列FIFO

var message = new BrokeredMessage(item); 
message.SessionId = "LB"; 
Console.WriteLine("Response from Central Scoring System : " + item); 
client.Send(message);

3）尽管为了恢复消息创建接收器： -

queueClient.OnMessage(s => 
{ 
    var body = s.GetBody<string>(); 
    var messageId = s.MessageId; 
    Console.WriteLine("Message Body:" + body); 
    Console.WriteLine("Message Id:" + messageId); 
});

4）虽然具有相同的会话ID它会自动确保订单并提供订购的消息。

谢谢！

来源

2017-03-31 09:45:26

我不知道你想如何快速处理这些消息，但如果你需要有一个真正的FIFO，不允许Azure的队列同时得到一个以上的消息。

在函数顶部的“program.cs”中使用它。

static void Main() 
      { 
       var config = new JobHostConfiguration(); 

       if (config.IsDevelopment) 
       { 
        config.UseDevelopmentSettings(); 
       } 
       config.Queues.BatchSize = 1; //Number of messages to dequeue at the same time. 
       config.Queues.MaxPollingInterval = TimeSpan.FromMilliseconds(100); //Pooling request to the queue. 


       JobHost host = new JobHost(config); 

....your initial information... 

      // The following code ensures that the WebJob will be running continuously 
      host.RunAndBlock();

这会在100毫秒的等待一段时间得到一个消息。

这是一个记录器webjob工作完全写入文件traze信息。

来源

2017-08-05 20:03:20 GeMe

的docs说的Azure存储队列是：

消息在存储队列通常是先入先出，但有时他们能进能出的顺序;例如，当消息的可见性超时持续时间到期（例如，由于客户机应用程序在处理期间崩溃）。当可见性超时过期时，消息在队列上再次变为可见，以供另一个工作人员将其出列。此时，最近可见的消息可能会放在队列中（要再次出队），该消息在最初排队后的消息之后。

也许这对你来说足够好了？否则使用服务总线。

来源

2017-11-01 09:02:39 Renaud

如何保证azure队列FIFO

回答

相关问题