我是RabbitMQ 初学者。
用的BasicConsume 订阅模式获取MQ数据,但是获取数据的消费者就是得不慢生成者一拍。
数据有延迟现象,想请教下大神们,求解答。。。在线等。
private void ConnectQueue()
{
if (_readChannel == null)
{
_readChannel = Model();
_readChannel.QueueDeclare(QueueName, true, false, false, null);
_readChannel.BasicQos(0, 1, false);
}
if (_consumer != null) return;
_consumer = new QueueingBasicConsumer(_readChannel);
_readChannel.BasicConsume(QueueName, _noAck, _consumer);
}