MassTransit-配置多个主题的RecectEndPoint

Question

我正在研究以下实施：

有一个应用程序来管理一些实体，例如公司，客户等。 该数据需要由另一个应用程序消费才能做一些事情。 基本思想是通过 massTransit 使用消息传播（RabbitMq-aws）实现 Pub/sub 模型。 将消耗这些消息的应用程序是ASPNETCORE 6，我正在尝试弄清楚如何正确配置 receedEndpoints ，因为我是新的消息传递...

这是我到目前为止得到的。 ..

services.AddMassTransit(busCfg =>
{
    busCfg.AddConsumers(typeof(TheAssemblyThatContainsTheMessageSignatures).Assembly);
    
    busCfg.UsingRabbitMq((context, cfg) =>
    {
        // OPTION 1:
        // ONE ReceiveEndpoint (queue) for all messages.
        cfg.ReceiveEndpoint("MyCompany.MyServiceName", e =>
        {
            e.ConfigureConsumer<CompanyCreatedConsumer>(context);
            e.ConfigureConsumer<CompanyUpdatedConsumer>(context);

            e.ConfigureConsumer<ClientCreatedConsumer>(context);
            e.ConfigureConsumer<ClientUpdatedConsumer>(context);
            
            e.ConfigureConsumer<OtherEntityCreatedOrUpdatedConsumer>(context);
        });
        
        // OPTION 2:
        // A ReceiveEndpoint per entity-type.
        cfg.ReceiveEndpoint("MyCompany.MyServiceName.Company", e =>
        {
            e.ConfigureConsumer<CompanyCreatedConsumer>(context);
            e.ConfigureConsumer<CompanyUpdatedConsumer>(context);
        });
        cfg.ReceiveEndpoint("MyCompany.MyServiceName.Client", e =>
        {
            e.ConfigureConsumer<ClientCreatedConsumer>(context);
            e.ConfigureConsumer<ClientUpdatedConsumer>(context);
        });
        cfg.ReceiveEndpoint("MyCompany.MyServiceName.OtherEntityCreatedOrUpdated", e =>
        {
            e.ConfigureConsumer<OtherEntityCreatedOrUpdatedConsumer>(context);
        });
        
        // OPTION 3????
    });
});

Answer 1

请按照 documentation ，并且只使用configure> configureendpoints。您试图过度思考解决方案只会分散您的注意力。

MassTransit已经知道如何根据消费者名称配置接收端点，因此只需使用它即可。