开源消息系统Apache Kafka, RabbitMQ和NATS比较(2)

上篇

  前面章节我们比较了Apache Kafka的使用,现在我们再看看RabbitMQ和NATS。

RabbitMQ

  RabbitMQ是一个开源消息引擎,遵循 AMQP 0.9.1 definition of a broker,它是一种标准 store-and-forward 模式,你可以选择将数据存储在内存或磁盘,支持各种消息路由范式,能以集群方式部署,消费者直接监听队列,但是发布者只是知道有一个exchanges, 这些exchanges是通过绑定连接到队列的,这种绑定是一种指定路由范式。

下面是它的管理界面management console.

rabbitmq管理界面

下面我们做一个publish-subscribe案例,增加一对队列:notes1和notes2,然后展示如何创建exchange,为了发送输入消息到所有订阅者,我们使用fanout路由类型,其他选项包括diect(指定路由key),topic(依赖匹配的路由key)或header(以消息头路由)

rabbitMQ队列类型

下面是有一个选项绑定这个exchange到另外一个exchanger或一个队列,这里我们绑定到自己创建的notes1队列中:

rabbitmq exchange

任何进入这个exchange的消息将进入两个队列,我们的node.js应用使用 amqplib module推送消息。

var amqp = require('../../node_modules/amqplib/callback_api');
 
amqp.connect('amqp://rseroter:rseroter@localhost:5672/', function(err, conn) {
  conn.createChannel(function(err, ch) {
    var exchange = 'integratenotes';
 
    //exchange, no specific queue, message
    ch.publish(exchange, '', new Buffer('Session: Open-source messaging. Notes: Richard is now showing off RabbitMQ.'));
    console.log(" [x] Sent message");
  });
  setTimeout(function() { conn.close(); process.exit(0) }, 500);
});

正如你看到,我们会有监听者监听这个队列以得到消息。

下面这个演示是使用diect路由,这需要指定一个路由key,这意味着每个队列会接受到消息,前提是它们的绑定匹配提供的路由key:

rabbitmq bingding

你也可以使用通配符来匹配:

 

NATS

  NATS原来是使用Ruby编写,可以实现每秒150k消息,后来使用Go语言重写,能够达到每秒8-11百万个消息,整个程序很小只有3M Docker image,它不支持持久化消息,如果你离线,你就不能获得消息,它是工作已publish-subscribe引擎,但是你能获得人造的队列。

下面演示使用Node.js实现每秒100万消息,这里我们使用nats-top一口气推送一千两百万的消息。

一千六百万消息每秒,而且很少使用到CPU,非常令人惊奇。

下面演示是假设微服务场景中,运行时定位服务非常重要,但不能在设计编程时硬编码到这些服务,使用 Consul可以很好实现,但是如果你有一个高性能消息总线,你实现它们之间的松耦合,下面这个案例是要查询服务端点,它发布一个请求然后等待在线服务的返回:

// Server connection
var nats = require('../../node_modules/nats').connect();
 
console.log('startup ...');
 
nats.request('service2.endpoint', function(response) {
    console.log('service is online at endpoint: ' + response);
});

每个微服务都有一个监听者连接到NATS,如果它接收到一个"are you online"请求,会回复。下面是每个服务的监听NATS代码:

// Server connection
var nats = require('../../node_modules/nats').connect();
 
console.log('startup ...');
 
//everyone listens
nats.subscribe('service2.endpoint', function(request, replyTo) {
    nats.publish(replyTo, 'available at http://www.jdon.com/service2');
});

当我调用这个端点时,我会得到一对响应,因为两个服务都会回复,客户端需要选择其中一个调用,或者我们将服务监听者放到queue group,这意味着仅仅一个订阅者会得到请求:

// Server connection
var nats = require('../../node_modules/nats').connect();
 
console.log('startup ...');
 
//subscribe with queue groups, so that only one responds
nats.subscribe('service2.endpoint', {'queue': 'availability'}, function(request, replyTo) {
    nats.publish(replyTo, 'available at http://www.jdon.com/service2');
});

 

Apache Kafka简单介绍

Node.js