如题, 用了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队列里面数据后,队列里面的数据就没了,如何不出队?