c# - 我们怎样才能加快从 MSMQ 接收消息的速度？

Question

我的应用程序的瓶颈已成为使用 MassTransit 通过 MSMQ 发送和接收消息。发送和接收都发生在同一个应用程序中，但通常有太多消息无法使用内存队列。

这是我的简单队列设置:

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));
                    });
                });

在我的实验中，MSMQ 目前有大约 100 万条消息，我们没有向它推送任何新消息。我们没有在 Enqueue() 中做任何工作，除了消息发送的速度。

根据这些信息，我们每秒只能从 MSMQ 抓取 150 到 200 条消息，而我希望在没有网络延迟的情况下每秒至少抓取 1000 条消息。每条消息 <2kb。

我们如何加快 MSMQ 通过 MassTransit 将消息传递到应用程序的速度，同时保持队列强制执行的消息顺序？

Answer 1

我之前确实解决过类似的问题。如果我没记错的话我们通过 TimeToBeReceived 指定消息过期时间(从目标队列接收到已发送消息的总时间。默认为 InfiniteTimeout。)。引用这个msdn link .