Node.js中使用Rabbitmq

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