MassTransit RequestResponse 示例移动响应以跳过 .Net 核心上的队列

Question

我将 MassTransit Sample-RequestResponse sample 移植到 .net 核心。为了托管 .net 核心服务，对样本做了一些小的修改。虽然该服务可以接收请求，但客户端未收到响应，并最终进入 rabbitmq 上的 ignore_skipped 队列。但是，在某些执行中，我会收到对我发送的第一个请求的响应，但之后会失败。造成这种情况的根本原因是什么？我们如何在 MassTransit

上实现 RequestResponse 模式

System.AggregateException: One or more errors occurred. (Timeout waiting for response, RequestId: 61000000-5d62-0015-cafc-08d4d8a6a3f2) ---> MassTransit.RequestTimeoutException: Timeout waiting for response, RequestId: 61000000-5d62-0015-cafc-08d4d8a6a3f2
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at MassTransit.RequestClient`2.<Request>d__6.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at System.Runtime.CompilerServices.TaskAwaiter`1.GetResult()
   at Client.Program.<>c__DisplayClass0_2.<<Main>b__1>d.MoveNext()

Answer 1

request/response 交换和队列的创建方式存在错误。我已经修补了代码，我的拉取请求 #954 已合并。

MassTransit RequestResponse 示例移动响应以跳过 .Net 核心上的队列

MassTransit RequestResponse sample move responses to skipped queue on .Net core

masstransit

rabbitmq

.net-core