如何獲取MassTransit IBus的大小（消息數量）？

Question

我正在使用MassTransit庫的InMemoryMessageBus，我想知道如何獲得隊列中消息的數量（總線的大小）。

Answer 1

使用內存傳輸的任何特定隊列中的消息數量不可用。消息傳遞基於排隊的任務調度程序，並且消息計數尚未提供。我不確定他們是否可能成功（很好，很容易，任何事情都有可能，但實際是另一回事）。

更新：這已添加到MassTransit並將在下一個版本（3.5.x）中。​​位於GitHub上，包括新代碼的示例用法。

Answer 2

如果您使用RabbitMQ作爲您的交通工具，您可以使用HareDu。 以下片段將幫助您開始：

var client = HareDuFactory.New(x => x.ConnectTo(RabbitMqHostUrl)); 

var data = client 
      .Factory<VirtualHostResources>(y => y.Credentials(RabbitMqUser, RabbitMqPass)) 
      .Queue 
      .GetAll() 
      .Data(); 

foreach (var queue in data) 
{ 
/*then you can access     
queue.Name, queue.VirtualHostName, queue.Memory, queue.Messages, 
queue.MessagesReady, queue.MessagesUnacknowledged, queue.Node, queue.IsDurable, queue.Consumers, queue.IdleSince */ 
}