c# - 如何在 MassTransit 中配置多个消息消费者？

Question

我正在考虑使用 MassTransit将事件从一个进程发布到所有其他关心该事件的进程。在我的环境中，订阅该事件的多个进程可能在同一个盒子上运行。

基于 MassTransit 的示例代码，这里有一个非常简单的概念验证，它不会尝试处理多播(进程也将分布在许多机器上)。将下面的“消息”视为“事件”，并且我希望此过程的每个实例都获得该消息:

using System;
using MassTransit;

namespace BasicPubSub
{
    public class Message
    {
        public String Text { get; set; }
    }

    public class Program
    {
        static void Main(string[] args)
        {
            //initialize the bus
            var bus = ServiceBusFactory.New(sbc =>
            {
                sbc.UseMsmq();

                //cause the DTC and MSMQ to get installed/fixed if needed.
                sbc.VerifyMsDtcConfiguration();
                sbc.VerifyMsmqConfiguration();

                //sbc.UseMulticastSubscriptionClient();//Doesn't behave for a private queue.
                sbc.ReceiveFrom("msmq://localhost/test_queue");

                //Listen for interesting events.
                sbc.Subscribe(subs =>
                {
                    subs.Handler<Message>(msg => Console.WriteLine(msg.Text));
                });
            });

            //stay open until the user types "exit"
            var message = "";
            do
            {
                message = Console.ReadLine();
                //broadcast the message
                bus.Publish(new Message { Text = message });
            } while (message != "exit");
        }
    }
}

如果我运行此 C# 应用程序的多个实例，只有一个实例会收到消息，但我需要所有实例都收到它。这种行为与队列的经典概念一致，所以我对此没有意见。

我想知道的是，我是否可以使用 MSMQ/MassTransit 发布所有订阅者都会收到的消息，而不是只有一个订阅者将其出列而其他订阅者没有收到。也许我正在尝试使用锤子，但我需要一把画笔？

这里要明确一点，我不是要为不同类型的消息共享一个队列，我是要为特定类型的消息设置“点对点”发布-订阅，使用 MT 和MSMQ.

Answer 1

我不确定使用锤子还是画笔，但我认为您的方向是正确的。

首先，总线的每个实例都需要有自己的队列来读取。如果您正在运行同一程序的多个版本，请确保它们正在读取不同的队列。尝试从同一个队列读取会导致 Bad Stuff(TM)。

如果您有更多问题，请加入邮件列表。 https://groups.google.com/forum/#!forum/masstransit-discuss .

发布时，all consumers should recieve the message一旦他们被订阅。启动时，订阅数据可能需要一两秒钟才能传递到所有进程。

我还建议看一下 RabbitMQ。除非您绝对需要 DTC，否则 RabbitMQ 是一个更强大的消息传递平台。