用。NET核心注册RabbitMQ使用者？

Question

我试图使用消息队列（RabbitMQ）在基于微服务的体系结构中处理请求授权。

根据这些说明，我已经将接收器和发送器配置为。NET核心中的控制台应用程序。但是，当在一个真实的例子中使用它时，我的应用程序接收项目并不是作为使用者收集消息。

我假设我必须在startup.cs中注册使用者，但我似乎无法使其工作。

public class RabbitMqHandler 
{
    private readonly IJWTFactory _jwtFactory;

    public RabbitMqHandler(IJWTFactory jWTFactory)
    {
        _jwtFactory = jWTFactory;

    }

    public void Register()
    {
        var mqFactory = new ConnectionFactory() { HostName = "localhost" };

        using (var connection = mqFactory.CreateConnection())
        {
            Console.WriteLine("Listening on Rabbit MQ");
            using (var channel = connection.CreateModel())
            {
                channel.QueueDeclare(queue: "Authorize", durable: false, exclusive: false, autoDelete: false, arguments: null);

                var consumer = new EventingBasicConsumer(channel);
                consumer.Received += (model, ea) =>
                {
                    var body = ea.Body;
                    var jwtToken = Encoding.UTF8.GetString(body);

                    Console.WriteLine("Rceived Message");

                    var validatedToken = _jwtFactory.ValidateTokenSignature(jwtToken);

                    SendResponse(validatedToken);
                };
                channel.BasicConsume(queue: "Authorize", autoAck: true, consumer: consumer);
            }
        }
    }

    public void Deregister()
    {

    }

public static class ApplicationBuilderExtentions
{
    public static RabbitMqHandler Listener { get; set; }

    public static IApplicationBuilder UseRabbitListener(this IApplicationBuilder app)
    {
        Listener = app.ApplicationServices.GetService<RabbitMqHandler>();

        var life = app.ApplicationServices.GetService<IApplicationLifetime>();

        life.ApplicationStarted.Register(OnStarted);

        //press Ctrl+C to reproduce if your app runs in Kestrel as a console app
        life.ApplicationStopping.Register(OnStopping);

        return app;
    }

    private static void OnStarted()
    {
        Listener.Register();
    }

    private static void OnStopping()
    {
        Listener.Deregister();
    }
}

• 如何在.NET核心中正确配置使用者以使用消息？
• 期望消息队列管理请求/响应样式的通信是错误的吗？
• 我是否应该使用API调用来对用户进行身份验证和授权？

Answer 1

@evk提供的答案（在评论中）：

“using是用来处理东西的，当您到达using块的末尾时，它调用dispose。basicconsume不是阻塞调用，因此它开始消耗并立即返回。
在此之后，通道和连接都到达using块的末尾，并处理它们（处理它们与关闭相同）。”

我想补充以下内容：如果删除使用很容易带来想要的结果，您可以快速尝试。更改以下代码行：

using (var connection = mqFactory.CreateConnection())

var connection = mqFactory.CreateConnection();