将接收到的消息从发送者获取到特定控制器：ASP.NET Core Web API 中的 MassTransit

Question

我对 Masstransit 和rabbitMq 很陌生，我想在两个 Web API 之间建立通信。

目标：如果服务 A 收到做出某些操作的请求，但它需要来自另一个服务 B 的一些附加信息，我想要使用 Masstransit 和 RabbitMq 之间的两个服务之间的连接，但我想在服务 A 中的特定控制器（请求信息的 API）中的操作方法中获取服务 B 的返回结果。

我已经创建了 Masstransit 和 RabbitMq 的集成，但我正在消费者中获取消息，并且我希望在等待服务 B 响应的操作方法中获得该结果。

如果有任何示例或任何提示可以调整解决方案或任何可能有帮助的事情将非常感谢

谢谢

Answer 1

使用请求客户端生成请求并获取响应。 API 控制器中的示例显示在 范围过滤器示例，以及许多其他 MassTransit 示例。

[ApiController]
[Route("[controller]")]
public class CheckInventoryController :
    ControllerBase
{
    readonly IRequestClient<CheckInventory> _client;

    public CheckInventoryController(IRequestClient<CheckInventory> client)
    {
        _client = client;
    }

    [HttpGet]
    public async Task<IActionResult> Get(string sku)
    {
        Response<InventoryStatus> response = await _client.GetResponse<InventoryStatus>(new {sku});

        return Ok(response.Message);
    }
}