Czy istnieje sposób sprawdzenia, ile wiadomości znajduje się w kolejce MSMQ?

Question

Zastanawiam się, czy istnieje sposób programowo sprawdzić, ile wiadomości są w prywatnym lub publicznym MSMQ przy użyciu C#? Mam kod, który sprawdza, czy kolejka jest pusta lub nie używa metody peek owiniętej w try/catch, ale nigdy nie widziałem nic o wyświetlaniu liczby wiadomości w kolejce. Byłoby to bardzo pomocne w monitorowaniu, jeśli trwa tworzenie kopii zapasowej kolejki.

Answer 1

Możesz przeczytać wartość licznika wydajności dla kolejki bezpośrednio z .NET:

using System.Diagnostics; 

// ... 
var queueCounter = new PerformanceCounter(
    "MSMQ Queue", 
    "Messages in Queue", 
    @"machinename\private$\testqueue2"); 

Console.WriteLine("Queue contains {0} messages", 
    queueCounter.NextValue().ToString()); 

Answer 2

Używamy MSMQ Interop. W zależności od potrzeb można prawdopodobnie uprościć następująco:

public int? CountQueue(MessageQueue queue, bool isPrivate) 
    { 
     int? Result = null; 
     try 
     { 
      //MSMQ.MSMQManagement mgmt = new MSMQ.MSMQManagement(); 
      var mgmt = new MSMQ.MSMQManagementClass(); 
      try 
      { 
       String host = queue.MachineName; 
       Object hostObject = (Object)host; 
       String pathName = (isPrivate) ? queue.FormatName : null; 
       Object pathNameObject = (Object)pathName; 
       String formatName = (isPrivate) ? null : queue.Path; 
       Object formatNameObject = (Object)formatName; 
       mgmt.Init(ref hostObject, ref formatNameObject, ref pathNameObject); 
       Result = mgmt.MessageCount; 
      } 
      finally 
      { 
       mgmt = null; 
      } 
     } 
     catch (Exception exc) 
     { 
      if (!exc.Message.Equals("Exception from HRESULT: 0xC00E0004", StringComparison.InvariantCultureIgnoreCase)) 
      { 
       if (log.IsErrorEnabled) { log.Error("Error in CountQueue(). Queue was [" + queue.MachineName + "\\" + queue.QueueName + "]", exc); } 
      } 
      Result = null; 
     } 
     return Result; 

    } 

Answer 3

Najszybszy sposób znalazłem się odzyskać licznik kolejki wiadomości jest użycie metody Peek z poniższego site:

protected Message PeekWithoutTimeout(MessageQueue q, Cursor cursor, PeekAction action) 
{ 
    Message ret = null; 
    try 
    { 
    ret = q.Peek(new TimeSpan(1), cursor, action); 
    } 
    catch (MessageQueueException mqe) 
    { 
    if (!mqe.Message.ToLower().Contains("timeout")) 
    { 
     throw; 
    } 
    } 
    return ret; 
} 

protected int GetMessageCount(MessageQueue q) 
{ 
    int count = 0; 
    Cursor cursor = q.CreateCursor(); 

    Message m = PeekWithoutTimeout(q, cursor, PeekAction.Current); 
    { 
    count = 1; 
    while ((m = PeekWithoutTimeout(q, cursor, PeekAction.Next)) != null) 
    { 
     count++; 
    } 
    } 
return count; 
} 

Answer 4

nie ma API dostępne, ale można użyć GetMessageEnumerator2 który jest szybki ENO ugh. Próbka:

MessageQueue q = new MessageQueue(...); 
int count = q.Count(); 

Realizacja

public static class MsmqEx 
{ 
    public static int Count(this MessageQueue queue) 
    { 
     int count = 0; 
     var enumerator = queue.GetMessageEnumerator2(); 
     while (enumerator.MoveNext()) 
      count++; 

     return count; 
    } 
} 

Próbowałem też inne opcje, ale każda ma pewne wady

1. licznik wydajności może wyjątek throw „Instancja '...' robi nie istnieje w podanej kategorii. "
2. przeczytaniu wszystkich wiadomości, a następnie biorąc count jest bardzo powolny, ale również usuwa wiadomości z kolejki
3. Wydaje się, że problem z Peek metody, która zgłasza wyjątek

Answer 5

  //here queue is msmq queue which you have to find count.   
      int index = 0; 
      MSMQManagement msmq = new MSMQManagement() ; 
      object machine = queue.MachineName; 
      object path = null; 
      object formate=queue.FormatName; 
      msmq.Init(ref machine, ref path,ref formate); 
      long count = msmq.MessageCount(); 

jest szybsza niż ty wybrałeś. Otrzymujesz od MSMQManagement refferance wewnątrz "C: \ Program Files (x86) \ Microsoft SDK \ Windows" tylko przegląda w tym adres dostaniesz go. Aby uzyskać więcej informacji, odwiedź stronę http://msdn.microsoft.com/en-us/library/ms711378%28VS.85%29.aspx.

Answer 6

To zadziałało dla mnie. Używając modułu Enumarator, upewnij się, że kolejka jest pusta.

Dim qMsg As Message ' instance of the message to be picked 
     Dim privateQ As New MessageQueue(svrName & "\Private$\" & svrQName) 'variable svrnme = server name ; svrQName = Server Queue Name 
     privateQ.Formatter = New XmlMessageFormatter(New Type() {GetType(String)}) 'Formating the message to be readable the body tyep 
     Dim t As MessageEnumerator 'declared a enumarater to enable to count the queue 
     t = privateQ.GetMessageEnumerator2() 'counts the queues 

     If t.MoveNext() = True Then 'check whether the queue is empty before reading message. otherwise it will wait forever 
      qMsg = privateQ.Receive 
      Return qMsg.Body.ToString 
     End If 

Answer 7

Jeśli potrzebujesz szybki sposób (25k Połączenia/sekund na moim komputerze), polecam wersję Ayende opartego na MQMgmtGetInfo() i PROPID_MGMT_QUEUE_MESSAGE_COUNT:

dla C# https://github.com/hibernating-rhinos/rhino-esb/blob/master/Rhino.ServiceBus/Msmq/MsmqExtensions.cs

dla VB https://gist.github.com/Lercher/5e1af6a2ba193b38be29

Pochodzenie prawdopodobnie było http://functionalflow.co.uk/blog/2008/08/27/counting-the-number-of-messages-in-a-message-queue-in/, ale nie jestem przekonany, że ta implementacja z 2008 roku już działa.

Answer 8

Liczbę wiadomości w kolejce można znaleźć, korzystając z następującego kodu.

MessageQueue messageQueue = new MessageQueue(".\\private$\\TestQueue"); 
var noOFMessages = messageQueue.GetAllMessages().LongCount(); 

Answer 9

Naprawdę miałem problem z uzyskaniem akceptowanej odpowiedzi z powodu błędu xxx does not exist in the specified Category. Żadne z powyższych rozwiązań nie sprawdziło się u mnie.

Jednak wydaje się, że proste jest określenie nazwy komputera, jak poniżej.

private long GetQueueCount() 
{ 
    try 
    { 
     var queueCounter = new PerformanceCounter("MSMQ Queue", "Messages in Queue", @"machineName\private$\stream") 
     { 
      MachineName = "machineName" 
     }; 

     return (long)queueCounter.NextValue(); 
    } 
    catch (Exception e) 
    { 
     return 0; 
    } 
}