使用EasyNetQ的.NET6微服务请求响应遇TaskCanceledException，调用方收不到响应

我正尝试用EasyNetQ基于.NET 6实现简单的RabbitMQ微服务，两个项目分属不同解决方案。使用请求/响应模式时，请求能成功发送，接收方也能收到并处理，但调用方始终收不到响应，在RequestService.cs中抛出TaskCanceledException，提示“A task was canceled.”。

请求方代码（RequestService.cs） #

var bus = RabbitHutch.CreateBus("host=localhost;timeout=120;username=guest;password=guest");

var req = new SendMessageRequestModel
{
    SenderUsername = "me",
    ReceiverUsername = "alsoMe",
    DateSent = DateTime.Now,
    Content = "message"
};

// 请求成功发送，但此处抛出TaskCanceledException
var response = await bus.Rpc.RequestAsync<SendMessageRequestModel, Result<bool>>(req);

Console.WriteLine("Response is:" + response.IsSuccessful);
Console.ReadLine();
bus.Dispose();

接收方代码（ReceiverService.cs） #

var bus = RabbitHutch.CreateBus("host=localhost;timeout=120;username=guest;password=guest");

await bus.Rpc.RespondAsync<SendMessageRequestModel, Result<bool>>(req =>
{
   Console.WriteLine("Request made at: " + DateTime.UtcNow);
   // 断点能命中，说明请求已接收并进入处理逻辑
   return Result<bool>.Success(true);
});

Console.ReadLine();
bus.Dispose();

异常信息 #

System.Threading.Tasks.TaskCanceledException: A task was canceled.
   at EasyNetQ.DefaultRpc.RequestAsync[TRequest,TResponse](TRequest request, Action`1 configure, CancellationToken cancellationToken)
   at Program.<Main>$(String[] args) in D:\Other\TempMQReceiver\temp\TempSender\TempSender\Program.cs:line 14
   at Program.<Main>(String[] args)

排查与解决方案 #

1. 确保消息类定义完全一致 #

EasyNetQ依赖序列化/反序列化匹配，请求和响应的实体类（SendMessageRequestModel、Result<T>）必须在两个项目中完全一致，包括：

• 命名空间
• 属性名称、类型
• 构造函数、静态方法（比如Success）的实现

示例Result<T>的标准定义（两边要完全相同）：

public class Result<T>
{
    public bool IsSuccessful { get; set; }
    public T Data { get; set; }

    public static Result<T> Success(T data)
    {
        return new Result<T> { IsSuccessful = true, Data = data };
    }
}

2. 显式设置RPC请求超时 #

连接字符串中的timeout=120是RabbitMQ连接超时，不是RPC请求的等待超时。EasyNetQ默认RPC超时为10秒，若接收方处理或响应路由耗时超过这个值，会触发TaskCanceledException。

修改请求方代码，显式设置更长超时：

var response = await bus.Rpc.RequestAsync<SendMessageRequestModel, Result<bool>>(
    req,
    config => config.WithTimeout(TimeSpan.FromSeconds(120))
);

3. 检查接收方异步逻辑（若有） #

如果接收方的响应处理包含异步操作，必须用async/await修饰委托，避免同步阻塞导致响应无法及时返回：

await bus.Rpc.RespondAsync<SendMessageRequestModel, Result<bool>>(async req =>
{
   Console.WriteLine("Request made at: " + DateTime.UtcNow);
   // 异步操作需加await
   await Task.Delay(100);
   return Result<bool>.Success(true);
});

如果是纯同步逻辑，也可以改用同步版本Respond：

bus.Rpc.Respond<SendMessageRequestModel, Result<bool>>(req =>
{
   Console.WriteLine("Request made at: " + DateTime.UtcNow);
   return Result<bool>.Success(true);
});

4. 验证RabbitMQ队列权限 #

登录RabbitMQ管理界面（默认http://localhost:15672），检查：

• 请求方的临时响应队列（名称类似EasyNetQ.Response.xxx）是否存在
• 队列是否有正确的读写权限，确保响应能被路由回请求方

内容的提问来源于stack exchange，提问作者Svetlozar Stoykov