IAsyncConnectionFactory connectionFactory = new ConnectionFactory
{
    HostName = _rabbitMqOptions.HostName,
    Port = _rabbitMqOptions.Port,
    UserName = _rabbitMqOptions.UserName,
    Password = _rabbitMqOptions.Password,
    VirtualHost = _rabbitMqOptions.VirtualHost,
    DispatchConsumersAsync = true
};

//創建連接
var connection = connectionFactory.CreateConnection();
//創建通道
var channel = connection.CreateModel();
channel.BasicQos(prefetchSize, prefetchCount, false);
//事件基本消費者
var consumer = new AsyncEventingBasicConsumer(channel);
//接收到消息事件
consumer.Received += async (ch, ea) =>
{
    try
    {
        var message = Encoding.UTF8.GetString(ea.Body.ToArray());
        var requeue = await executeAsync(message);
        if (requeue)
        {
            //確認該消息已被消費
            channel.BasicAck(ea.DeliveryTag, false);
        }
        else
        {
            channel.BasicNack(ea.DeliveryTag, false, true);
        }
    }
    catch (Exception)
    {
        channel.BasicAck(ea.DeliveryTag, false);
    }
};
//啟動消費者 設置為手動應答消息
channel.BasicConsume(queueName, false, consumer);

private async Task SingleOrPolling(Func<string, Task<bool>> executeAsync, bool isSingle, string? queueName = null)
{
    var connectionFactory = _rabbitMQBaseService.GetAsyncConnectionFactory();
    using var connection = connectionFactory.CreateConnection();
    using var channel = connection.CreateModel();
    queueName = GetQueueName(queueName);
    while (true)
    {
        var response = channel.BasicGet(queueName, false);
        try
        {
            if (null != response)
            {
                var message = Encoding.UTF8.GetString(response.Body.ToArray());
                var requeue = await executeAsync(message);
                if (requeue)
                {
                    //確認該消息已被消費
                    channel.BasicAck(response.DeliveryTag, false);
                }
                else
                {
                    channel.BasicNack(response.DeliveryTag, false, true);
                }
            }
        }
        catch (Exception)
        {
            channel.BasicAck(response.DeliveryTag, false);
        }
        if (isSingle)
        {
            break;
        }
    }
}