2013-07-30 21 views

回答

4

这可能是一个过于简单的答案,但在基本层面上这是可行像这样...

var amqp = require('amqp'); 
var connection = amqp.createConnection({ host: '127.0.0.1' }); 
connection.on('ready', function() { 
    var exchange = connection.exchange('my-super-xchange', {type: 'topic'}); 
    exchange.on('open', function(){ 
    console.log('Lets do this!'); 
    }) 
}) 

一旦运行上述,交流现在应该在你的RabbitMQ实例

可见
$ rabbitmqctl list_exchanges 
Listing exchanges ... 
    direct 
amq.direct direct 
amq.fanout fanout 
amq.headers headers 
amq.match headers 
amq.rabbitmq.log topic 
amq.rabbitmq.trace topic 
amq.topic topic 
dingo topic 
my-super-xchange topic 
...done. 
+0

谢谢!这看起来和我最终的结果非常相似。希望他们可以给我们一个很好的例子:) – RachelC

+0

看起来他们到达节点示例的时候已经蒸发了,但是如果您想要发出一些pull请求,那么还有github repo :: https:// github .com/rabbitmq/rabbitmq-tutorials/tree/master/javascript-nodejs 同样值得注意的是,一般的态度似乎是用zeroMQ代替rabbitMQ(尽管它们略有不同) –