2013-07-30 45 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(儘管它們略有不同) –