我想在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); });