6

我正在考虑使用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 为特定类型的消息设置“点对点”发布订阅。

4

1 回答 1

1

我不确定锤子或画笔，但我认为你正朝着正确的方向前进。

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

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

发布时，所有消费者都应该在订阅后收到消息。启动时订阅数据可能需要一两秒钟才能传递给所有进程。

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

于 2012-08-09T15:43:55.327 回答