c# – RabbitMQ仅侦听队列中的第一条消息

我的Rabbit队列存在问题,目前只对队列中的第一条消息作出反应,之后被忽略的任何其他消息都被忽略.

我首先实例化连接并在IQueueConnectionProvider中声明队列:

var connectionFactory = new ConnectionFactory() { HostName = hostName };
var connection = _connectionFactory.CreateConnection();
var channel = connection.CreateModel();

然后,IQueueConnectionProvider在我的IQueueListener中用作只有一个方法的依赖项:

public void ListenToQueue(string queue)
{
    var channel = _queueConnectionProvider.GetQueue();

    var consumer = new EventingBasicConsumer(channel);
    consumer.Received += (model,ea) =>
    {
        string path = @"d:\debug.log.txt";
        File.AppendAllLines(path,new List<string>() {"MESSAGE RECEIVED",Environment.NewLine });

        var body = ea.Body;
        var message = Encoding.UTF8.GetString(body);

        channel.BasicAck(ea.DeliveryTag,false);
    };

    channel.BasicConsume(queue,true,consumer);

}

我的日志文件最终只有一行“MESSAGE RECEIVED”,但我可以在Rabbit ui界面看到我的其他服务正在将消息推送到该队列就好了.

这里有什么我想念的吗?

解决方法

这是一个愚蠢的错误……又一次.
channel.BasicConsume(queue,false,consumer);

这就是我所需要的.我想手动确认我的消息,因此noAck需要是假的;

相关文章

文章浏览阅读6.2k次,点赞2次,收藏3次。C#数学运算表达式解...
文章浏览阅读5.2k次,点赞6次,收藏7次。程序要做到用户配置...
文章浏览阅读9k次。错误信息检测到 ContextSwitchDeadlock M...
文章浏览阅读2w次,点赞10次,收藏9次。我发生错误时的环境:...
文章浏览阅读9.8k次。C# 二进制字节流查找函数IndexOf ...
文章浏览阅读2.5w次,点赞3次,收藏9次。c#DataGridView数据...