Nodejs - RabbitMQ

这里我们来看看如何在Nodejs上使用rabbitmq消息通道,消息通道主要解决RPC服务调用的持久化问题，当然了，还有其它类似的需求，比如可以作为日志的收集，还可以用来作聊天消息中心等。

使用指南

环境

node --version
v8.11.0

安装Rabbitmq包amqplib

npm install amqplib --save
# 或者
yarn add amqplib

使用demo

const topic = 'hello';
var amqp = require('amqplib/callback_api');
function publisher(conn) {
    conn.createChannel(on_open);
    function on_open(err, ch) {
        if (err != null) bail(err);
        ch.assertQueue(topic);
        ch.sendToQueue(topic, new Buffer('something to do'));
    }
}
function consumer(conn) {
    var ok = conn.createChannel(on_open);
    function on_open(err, ch) {
        if (err != null) bail(err);
        ch.assertQueue(topic);
        ch.consume(topic, function(msg) {
            if (msg !== null) {
                console.log('consumer',msg.content.toString());
                ch.ack(msg);
            }
        });
    }
}
amqp.connect('amqp://admin:admin@localhost', function(err, conn) {
    consumer(conn);
    publisher(conn);
});

信赖docker rabbitmq

docker-compose.yml

version: '2'  #"登录容器请执行:rabbitmq-plugins enable rabbitmq_management 才可使用WEB管理页面"
services:
  rabbitmq:
    image: rabbitmq
    ports:
      - "5672:5672"
      - "15672:15672"
    hostname: rabbit
    environment:
      RABBITMQ_DEFAULT_VHOST: /
      RABBITMQ_DEFAULT_USER: admin
      RABBITMQ_DEFAULT_PASS: admin

运行结果

node index.js 
consumer something to do