队列未在 Rabbitmq 中显示

Question

我有两个独立的服务，一个叫做 Teacher.API 和 Process.API。教师服务生成 POST 请求，教师详细信息将根据我的需要发送到流程服务。

这就是我在这两个服务中配置 MassTrasit 的方式。

在 Teacher.API

中

services.AddMassTransit(x =>
{
    x.UsingRabbitMq((context, config) =>
    {
        config.Host(new Uri("rabbitmq://localhost"), h =>
        {
            h.Username("guest");
            h.Password("guest");
        });
    });
});

在 Process.API 中。

services.AddMassTransit(x =>
{
    x.AddConsumer<TeacherConsumer>();
    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.Host(new Uri("rabbitmq://localhost"), h =>
        {
            h.Username("guest");
            h.Password("guest");
        });
        cfg.ReceiveEndpoint("teacherQueue", ep =>
        {
            ep.PrefetchCount = 16;
            ep.UseMessageRetry(r => r.Interval(2, 100));
            ep.ConfigureConsumer<TeacherConsumer>(context);
        });
    });
});

而在Teacher Controller中，我的POST请求如下，

[HttpPost]
public async Task<IActionResult> Registraion(Teacher Teacher)
{
    if (Teacher != null)
    {
        Teacher.BookedOn = DateTime.Now;
        Uri uri = new Uri("rabbitmq://localhost/teacherQueue");
        var endPoint = await _bus.GetSendEndpoint(uri);
        await endPoint.Send(Teacher);
        return Ok();
    }
    return BadRequest();
}

在这里，我正在创建一个新的 teacherQueue 队列并推送 Teacher 对象。

我的问题是，RabbitMQ 管理插件，没有在队列部分显示teacherQueue，而是在 Exchanges 中显示。

我的消费者部分如下，这个消费者也没有命中。

public class TeacherConsumer : IConsumer<Teacher>
{
    public Task Consume(ConsumeContext<Teacher> context)
    {
        var data = context.Message;
        return Task.CompletedTask;
    }
}

有什么原因吗？我做错了什么？

Answer 1

您缺少 AspNetCore 包，以及对以下内容的调用：

services.AddMassTransitHostedService();

真正启动公共汽车。