CNode

node.js + rabbitmq,消费者等待生产者结束之后再消费?

问答
Ssunyonggang发布于10 年前最后回复10 年前2 回复4327 浏览0 收藏

刚接触rabbitmq,查看它的一个例子 Hello World,发现必须要等待sendToQueue()结束之后才开始consumer,一般mq不是一边生产一边消费的么?是我代码的问题,还是我理解的问题? 代码基本与上面的链接中的代码类似,只不过在sendToQueue()的外边加了一个循环:

	for (var i = 0; i < 400000; i++) {
       	   ch.sendToQueue(q, new Buffer(i + ''));
      	   console.log('whwhwhw' + i);
   	  }

想上面这样,将 i依次的打入queue中,consumer应该不断的收到数据才对啊,怎么会在这个for完成之后才开始consumer?😥

另外这个编辑窗口有点醉啊,没有预览么?

查看回复

回复 (2)

O
o6875461#1·10 年前

你理解有问题,我没看到消费者的存在

S
sunyonggang#2·10 年前
引用 o6875461你理解有问题,我没看到消费者的存在

@o6875461 这边我只贴出了sendToQueue(),以及我想做的操作。 具体的consumer在给的链接里面有的,所以这边没贴。😏

参与回复
登录后即可参与回复。登录