Basic Producer-Consumer model with Node.js and RabbitMQ

consumer.js

const amqp = require('amqp')

const conn = amqp.createConnection({
  host: '127.0.0.1',
  port: 5672,
  login: 'guest',
  password: 'guest',
  connectionTimeout: 10000
})

conn.on('ready', () => {
  // 和 publisher 使用的队列名称一致
  conn.queue('test', queue => {
    queue.bind('#')
    queue.subscribe(message => {
      let payload = unescape(message.data)
      console.log(`CONSUME ${payload}`)
    })
  })
})

publisher.js

const amqp = require('amqp')

const conn = amqp.createConnection({
  host: '127.0.0.1',
  port: 5672,
  login: 'guest',
  password: 'guest',
  connectionTimeout: 10000
})

conn.on('ready', () => {
  let count = 1
  setInterval(() => {
    let message = `TEST ${count}`
    // 如果 test 不存在，就新建一个名为 test 的队列
    conn.publish('test', message)
    console.log(`SENT ${count} - ${message}`)
    count += 1
  }, 1000)
})