Jt.Common.Tool.RabbitMq 1.0.0

Jt.Common.Tool.RabbitMq

RabbitMq帮助类

用法

引入nuget包

dotnet add package Jt.Common.Tool.RabbitMq

在Program 服务注册

builder.Services.AddRabbitMq(option =>
{
    option.IpAddress = "127.0.0.1";
    option.Port = 5672;
    option.UserName = "guest";
    option.Password = "guest";
});

注入RabbitMQPublisher

public class WeatherForecastController : ControllerBase
{
    private RabbitMQPublisher _publisher;

    private readonly ILogger<WeatherForecastController> _logger;

    public WeatherForecastController(ILogger<WeatherForecastController> logger, RabbitMQPublisher publisher)
    {
        _logger = logger;
        _publisher = publisher;
    }

    [HttpGet("Send")]
    public bool Send(string msg)
    {
        _publisher.PublishQueue(msg, "test");
        _publisher.PublishQueue(msg, "aaa");
        return true;
    }
}

注入RabbitMQSublisher

// push模式
public class MqBackgroundService : BackgroundService
{
    private readonly RabbitMQSublisher _rabbitMQSub;
    private ILogger<MqBackgroundService> _logger;

    public MqBackgroundService(RabbitMQSublisher rabbitMQSub, ILogger<MqBackgroundService> logger)
    {
        _rabbitMQSub = rabbitMQSub;
        _logger = logger;
    }

    protected override Task ExecuteAsync(CancellationToken stoppingToken)
    {
        _rabbitMQSub.SubscribeQueue("test", (msg) =>
        {
            _logger.LogInformation("test:" + msg);
            return true;
        });

        return Task.CompletedTask;
    }
}

// pull模式
public class MqPullBackgroundService : BackgroundService
{
    private readonly RabbitMQSublisher _rabbitMQSub;
    private ILogger<MqPullBackgroundService> _logger;

    public MqPullBackgroundService(RabbitMQSublisher rabbitMQSub, ILogger<MqPullBackgroundService> logger)
    {
        _rabbitMQSub = rabbitMQSub;
        _logger = logger;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            _rabbitMQSub.PullQueueMsg("aaa", (msgs) =>
            {
                List<bool> result = new List<bool>();
                foreach (var item in msgs)
                {
                    _logger.LogInformation("aaa:" + item);
                    result.Add(true);
                }

                return result;
            }, 10);

            await Task.Delay(1000);
        }
    }
}