System.TimeoutException: 'PersistentChannel 上请求的操作已通过 EasyNetQ 超时

Question

我从 RabbitMq 开始，但在启动我的 API 时遇到问题。发生此错误：System.TimeoutException: 'PersistentChannel 上请求的操作已超时'。

我正在使用 EasyNetQ。

RabbitMq 在配置为设置的 Docker 容器中运行：http：15672 和 ampq：56712。单击此处访问 Rabbitmq，在浏览器中没有任何问题。

下面是设置的代码（现在是硬代码）。根据代码，也尝试传递用户名和密码，但没有成功。

protected override Task ExecuteAsync(CancellationToken stoppingToken)
{
    _bus = RabbitHutch.CreateBus("host=localhost:5672;username=guest;password=guest");

    _bus.RespondAsync<UsuarioRegistradoIntegrationEvent, ResponseMessage>(async request =>
        new ResponseMessage(await RegistrarCliente(request)));

    return Task.CompletedTask;
}

ou

protected override Task ExecuteAsync(CancellationToken stoppingToken)
{
    _bus = RabbitHutch.CreateBus("host=localhost:5672");

    _bus.RespondAsync<UsuarioRegistradoIntegrationEvent, ResponseMessage>(async request =>
        new ResponseMessage(await RegistrarCliente(request)));

    return Task.CompletedTask;
}

ou

protected override Task ExecuteAsync(CancellationToken stoppingToken)
{
    _bus = RabbitHutch.CreateBus("host=localhost");

    _bus.RespondAsync<UsuarioRegistradoIntegrationEvent, ResponseMessage>(async request =>
        new ResponseMessage(await RegistrarCliente(request)));

    return Task.CompletedTask;
}

Answer 1

• 您在描述中提到了 AMQP 的非默认端口，请在您的容器中将 56712 更改为 5672（如果适用）
• 确保每个应用程序实例只调用一次RabbitHutch.CreateBus("host=localhost")（共享实例）。
• 确保等待所有异步调用：

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        _bus = RabbitHutch.CreateBus("host=localhost");
    
        await _bus.RespondAsync<UsuarioRegistradoIntegrationEvent, ResponseMessage>(async request =>
            new ResponseMessage(await RegistrarCliente(request)));
    }

我们缺少 RegistrarCliente(request) 的实现，因此很难发现任何其他问题。

Answer 2

通过在防火墙上插入端口 5672 解决了问题。