服务Fabric群集。Statefull服务。服务总线队列使用

Question

  QueueClient Queue = QueueClient.CreateFromConnectionString(
                                 GetServicebusConnectionString(), 
                                 ConfigData.SERVICE_QUEUE_NAME);
   if (Queue != null)
   {
       var options = new OnMessageOptions();
       options.AutoComplete = false;

       Queue.OnMessage((receivedMessage) => 
                          ProcessMessage(receivedMessage), options);
   }

Answer 1

队列客户端的默认接收模式是PeekLock，您将AutoComplete属性设置为false，这样在客户端收到消息后不会自动删除消息。锁到期后，消息将再次可用，其他服务实例可以再次接收和处理它。

当队列中的每个消息只由一个服务实例接收时，是否可以使用服务总线队列？

您可以将AutoComplete属性设置为true，或者在客户端接收并处理消息后调用Complete方法。

Queue.OnMessage((receivedMessage) =>
                { ProcessMessage(receivedMessage); receivedMessage.Complete(); }, options);