node.js - Topic交换的node-amqp示例

Question

有人有在 Node-amqp 中创建主题交换的示例吗？我已经通过了 https://github.com/rabbitmq/rabbitmq-tutorials/tree/master/javascript-nodejs但不幸的是，它不会从 RabbitMQ 网站重新创建教程 4+。

Answer 1

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

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.