nodejs + rabbitmq 如何出队且信息不出队
发布于 6个月前 作者 shadow88sky 408 次浏览

如题, 用了amqp 库,看了相关文档,连接设置了里面的一些参数,如下: var connectionToQueue = function (connection, queue, callback) { //处理回调函数 callback = callback ? callback : function (err, q, exc) { }; try { //连接准备完成 connection.on('ready’, function () { //交换器 var exchange = connection.exchange(queue + 'MQExchange’, { type: 'fanout’, durable: true, confirm: true //加入队列完成后,回调 }); //连接队列 connection.queue(queue, { durable: true, //持久化 autoDelete: false,//自动删除 exclusive: false }, function (queue) { //回调 callback(true, queue, exchange); }) }); } catch (e) { //出错回调错误信息 callback(false, null, null); } }

可是我取MQ队列里面数据后,队列里面的数据就没了,如何不出队?

1 回复

自己研究出来了~~~,原来出队的时候 _queue.subscribe({ ack: true },function (message) { callback(true, message); }); ack:true 就行~

回到顶部