masstransit - 新手 - 是否需要消费者队列才能使发布在 MassTransit 中工作

Question

我正在尝试了解 MassTransit 和 RabbitMQ 并排队(第 1 天)

我的问题是“为了在 MT 中排队工作，是否需要消费者。我问的原因是因为我首先创建了域和生产者，但我没有在 RabbitMQ 管理窗口中看到任何排队的项目。”

创建消费者队列后，我可以看到消息正在排队。

根据我的理解，Producer 从来不知道消费者，那么为什么 MassTransit 需要消费者队列来启动消息发布？

制作人

using MassTransit;

namespace Producer
{
    class Program
    {
        static void Main(string[] args)
        {
            Bus.Initialize(sbc =>
            {
                sbc.UseRabbitMq();         //1
                sbc.UseControlBus();
                sbc.EnableMessageTracing();
                sbc.EnableRemoteIntrospection();
                sbc.ReceiveFrom("rabbitmq://localhost/MT.Producer");
                sbc.UseControlBus();
            });

            Bus.Instance.Publish(new NewOrderMessage { OrderName = "Hello World" });
        }
    }
}

应用程序

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using MassTransit;
using Topshelf;

namespace Consumer
{
    class Program
    {
        static void Main(string[] args)
        {
            Bus.Initialize(sbc =>
            {
                sbc.UseRabbitMq();
                sbc.UseRabbitMqRouting();
                sbc.ReceiveFrom("rabbitmq://localhost/MT.ConsumerService");
            });

            var cfg = HostFactory.New(c =>
            {
                c.SetServiceName("MT.ConsumerService");
                c.SetDisplayName("MT.ConsumerService");
                c.SetDescription("MT.ConsumerService");

                //c.BeforeStartingServices(s => {});

                c.Service<ConsumerService>(a =>
                {
                    a.ConstructUsing(service => new ConsumerService());
                    a.WhenStarted(o => o.Start());
                    a.WhenStopped(o => o.Stop());
                });

            });

            try
            {
                cfg.Run();
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw;
            }
        }
    }
}

消息

namespace Domain
{
    public class NewOrderMessage
    {
        public NewOrderMessage()
        {
            OrderId = Guid.NewGuid();
        }
        public Guid OrderId { get; set; }
        public string OrderName { get; set; }
    }
}

消费者服务

namespace Consumer
{
    class ConsumerService
    {
        readonly IServiceBus _bus;

        public ConsumerService()
        {
            _bus = Bus.Instance;
        }

        public void Start()
        {
            _bus.SubscribeHandler<NewOrderMessage>(CreateOrder);

            Console.WriteLine("Starting....");
        }

        public void Stop()
        {    
            Console.WriteLine("Stopping....");
        }

        public void CreateOrder(NewOrderMessage command)
        {
            Console.WriteLine("Creating Order: {0}  with Id: {1}", command.OrderName, command.OrderId);
        }
    }
}

代码是使用网络上的示例创建的。

编辑 还要补充一点，所有命名空间都是不同的项目
领域
制作人
消费者

问候，

三月

Answer 1

以下有关大众运输铁饼的答案确实对我有帮助。

来自 Google Group masstransit-讨论

... MassTransit 的问题在于您实际上并没有发布到队列，而是发布到一个交换器，然后该交换器被设置为将该消息传递到已订阅该交换器上的消息的其他队列。由于您没有任何消费者，因此没有人对您的消息表示任何兴趣，因此它只会被忽略。

所以只需设置一个消费者并让它听“rabbitmq://localhost/B”。第一次运行它时，它将在它们之间创建必要的交换和链接，并且您的消息将被传递到名为 B 的队列。

安德斯

总线是所有交换、队列和服务的集合。当您在总线上发布时，所有在该总线上注册的消费者都会收到它。

Exchanges 是实现这项工作的 RabbitMQ 实现。

特拉维斯