Node.js中使用Rabbitmq
发布于 3分钟前 作者 huyueMiss 4 次浏览 来自 问答

我想在Node.js中使用Rabbitmq,用了node-amqp的客户端。

我在测试的时候发现一个问题,我用了for做了100000万次循环,循环里面就发布消息到Rabbit Server。

为啥总是循环执行完成后queue里面才会有消息,不是每次循环都发布的吗??

谢谢。。。

var amqp = require(‘amqp’);

var connection = amqp.createConnection();

connection.on('ready’, function () { for(var i=0;i<100000;i++) { console.log(i); var exchange=connection.exchange('test’,{type:’fanout’,durable:true,autoDelete:false}); exchange.publish('#’,i,function(a){ console.log(a); }) } });

connection.on('error’,function(s){ console.log(s); });

回到顶部