MassTransit

Question

我看不出有什么可以说这是正常行为，如果我是瞎子，请原谅我，哈哈。在将 MassTransit 与请求-响应结合使用时，我看到了一些奇怪的东西。

所以我有多个消费者在一个服务上侦听不同的请求来执行简单的任务，比如从数据库中获取数据。

为了测试每个消费者，我创建了一个控制台应用程序，它为每个消费者执行请求并检查响应。

我注意到第一个请求-响应工作正常，但是当代码运行s 下一个检查收到响应时，消息随后被移至跳过队列并被删除。

这是第二次请求的公共交通日志。

发送

[2021-05-14 10:27:11.812 DBG] (MassTransit.)-SEND rabbitmq://192.168.0.25/Ksrs.Requests:ConceptByConceptNoRequest d9360000-cf5b-480f-418f-08d916ba7421 Ksrs.Requests.ConceptByConceptNoRequest

收到

[2021-05-14 10:28:00.203 DBG] (MassTransit.ReceiveTransport.)-RECEIVE rabbitmq://192.168.0.25/DESKTOP99KLG9M_Tests_bus_5r5yyygxmpry6jgtbdctpqurrb?temporary=true d9360000-cf5b-480f-2626-08d916ba7429 Ksrs.Response.ConceptResponse MassTransit.MessageHandler<Ksrs.Response.ConceptResponse>(00:00:00.0004546)

跳过？

[2021-05-14 10:28:41.361 DBG] (MassTransit.ReceiveTransport.)-SKIP rabbitmq://192.168.0.25/DESKTOP99KLG9M_Tests_bus_5r5yyygxmpry6jgtbdctpqurrb?temporary=true d9360000-cf5b-480f-ce25-08d916ba75f3

当我仍然得到响应时不明白跳过，响应符合预期，代码可以继续。

这是客户端请求和响应代码，我的所有检查都几乎相同。唯一的区别是请求-响应类型。

static async Task<bool> GetByConceptNo(AutofacServiceProvider autoFac, short ksrsId, short conceptNo, ILogger logger)
    {
        var client = autoFac.GetService<IRequestClient<ConceptByConceptNoRequest>>();

        if (client is null) return false;

        Response<ConceptResponse> response;

        try
        {
            response = await client.GetResponse<ConceptResponse>(new ConceptByConceptNoRequest() {KsrsId = ksrsId, ConceptNo = conceptNo});

            logger.LogInformation("Received {Concept}.",response.Message.Concept);
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
            return false;
        }
        return response.Message.Concept is not null;
    }

一些注意事项：

使用 Autofac 作为容器。

使用 Serilog 进行日志记录。

使用 RabbitMQ (3.8.16) 作为消息代理。

更新：所以发现了一些有趣的东西。我向每个消费者添加了以下日志行，所以我知道是运行.

Logger.LogInformation("Request for [what ever consumer running goes here]");

现在假设我有 Consumer1、Consumer2 和 Consumer3。我在日志中看到了这个。

Request for Consumer 1
SEND blah blah
RECIEVE blah blah
Request for Consumer 1
Request for Consumer 2
SEND blah blah
RECIEVE blah blah
Request for Consumer 1
Request for Consumer 3
SEND blah blah
RECIEVE blah blah
SEND blah blah
RECIEVE blah blah

所以消费者 1 似乎一直在执行，但我不明白为什么每个消费者的消息类型都不同并且客户端没有调用它。

Answer 1

MassTransit 支持多态消息路由。所以在上面的例子中，如果消费者 1 消费的消息类型是由为消费者 2 或消费者 3 产生的请求实现的，消费者 1 将收到该消息的副本——它也会响应。

发布请求时（如果未指定特定目标地址，则为默认设置），请务必确保配置的该消息类型只有一个消费者。

多态消息传递非常适合事件，因为使用单个消费者和多个事件类型很容易吸取有趣的事件属性。但根据您在上面看到的内容，最好避免使用 commands/requests。或者至少在上述情况下，当发布 requests/commands 时，拥有一个消费超类型消息的消费者不应该响应，但可能只有 track/log/audit command/request.

MassTransit - 从请求-响应中获取响应正常，但已从跳过的队列中添加和删除消息？

MassTransit - Getting response from request-response ok but message added and deleted from skipped queue?

c#

rabbitmq

request-response