Jak możemy przyspieszyć otrzymywanie wiadomości z MSMQ?

Question

Wąskie gardło mojej aplikacji stało się wysyłaniem i odbieraniem wiadomości przez MSMQ z MassTransit. Wysyłanie i odbieranie odbywa się w ramach tej samej aplikacji, ale często jest za dużo wiadomości, aby użyć kolejki w pamięci.

Oto mój prosty setup kolejka:

messageBus = ServiceBusFactory.New(sbc => 
       { 
        sbc.UseMsmq(); 
        sbc.VerifyMsmqConfiguration(); 
        sbc.UseMulticastSubscriptionClient(); 
        sbc.ReceiveFrom("msmq://localhost/msg_queue"); 
        sbc.Subscribe(subs => 
        { 
         subs.Handler<EventMessage>(msg => Enqueue(msg)); 
        }); 
       }); 

Dla moich doświadczeniach MSMQ obecnie ~ 1 milion wiadomości i nie naciskają żadnych nowych wiadomości do niego. Nie wykonujemy żadnej pracy w Enqueue() z wyjątkiem czasu, w jakim wysyłane są wiadomości.

Dzięki tym informacjom możemy pobrać tylko od 150 do 200 wiadomości na sekundę z MSMQ, kiedy miałem nadzieję, że będzie to co najmniej 1000 wiadomości na sekundę, gdy nie ma opóźnień w sieci. Każda wiadomość to < 2kb.

Jak możemy przyspieszyć, jak szybko MSMQ przekazuje wiadomości do aplikacji przez MassTransit, zachowując kolejność wiadomości wymuszoną przez kolejkę?

Answer 1

Zrobiłem już coś podobnego wcześniej. Jeśli dobrze to pamiętam, Określono datę wygaśnięcia wiadomości przez TimeToBeReceived (Łączny czas wysłania wiadomości z kolejki docelowej. Wartość domyślna to InfiniteTimeout.). Patrz: msdn link.