最近这个 Apache Pulsar 消息中间件十分的火，号称下一代音讯中件，明天，就一起来看看它到底有多牛逼？

概述

Apache Pulsar 是一个应用 Apache Bookkeeper 提供长久化的 pub/sub 音讯平台，是一个用于服务端到服务端的消息中间件，最后由Yahoo开发并在2016年开源，目前正在Apache基金会下孵化。它能够提供如下个性：

  • 跨地区复制
  • 多租户
  • 零数据失落
  • 零Rebalancing工夫
  • 对立的队列和流模型
  • 高可扩展性
  • 高吞吐量
  • Pulsar Proxy
  • 函数

架构

Pulsar 应用分层构造，将存储机制与 broker 隔离开来。此体系结构为 Pulsar 提供以下益处：

  • 独立扩大broker
  • 独立扩大存储（Bookies）
  • 更容易容器化Zookeeper, Broker and Bookies
  • ZooKeeper提供集群的配置和状态存储

在 Pulsar 集群中，一个或多个代理解决和负载平衡来自生产者的传入音讯，将音讯分派给消费者，与 Pulsar 配置存储通信以解决各种协调工作，将音讯存储在 BookKeeper 实例（又名 bookies）中，依赖特定于集群的 ZooKeeper 集群工作等等。

  • 由一个或多个 bookie 组成的 BookKeeper 集群解决音讯的长久存储。
  • 特定于该集群的 ZooKeeper 集群解决 Pulsar 集群之间的协调工作。

更多对于 Pulsar 的架构介绍请参阅：https://pulsar.apache.org/doc...

四种订阅模式

Pulsar 中有四种订阅模式：exclusive、shared、failover和key\_shared。这些模式如下图所示。

具体介绍参阅：https://pulsar.apache.org/doc...

性能优于 Kafka

Pulsar 体现最出色的就是性能，Pulsar 的速度比 Kafka 快得多，与 Kafka 相比，Pulsar 的速度晋升了 2.5 倍，提早升高了 40％。

数据起源:https://streaml.io/pdf/Gigaom...

注：比照是针对 1 个分区的 1 个主题，其中蕴含 100 字节音讯，Pulsar 每秒可发送 220,000+ 条音讯。

装置

二进制版本装置 Pulsar
#下载官网二进制包[root@centos7 ~]# wget https://archive.apache.org/dist/pulsar/pulsar-2.8.0/apache-pulsar-2.8.0-bin.tar.gz#解压[root@centos7 ~]# tar zxf apache-pulsar-2.8.0-bin.tar.gz[root@centos7 ~]# cd apache-pulsar-2.8.0[root@centos7 apache-pulsar-2.8.0]# lltotal 72drwxr-xr-x 3 root root   225 Jan 22  2020 bindrwxr-xr-x 5 root root  4096 Jan 22  2020 confdrwxr-xr-x 3 root root   132 Jul  6 11:47 examplesdrwxr-xr-x 4 root root    66 Jul  6 11:47 instancesdrwxr-xr-x 3 root root 16384 Jul  6 11:47 lib-rw-r--r-- 1 root root 31639 Jan 22  2020 LICENSEdrwxr-xr-x 2 root root  4096 Jan 22  2020 licenses-rw-r--r-- 1 root root  6612 Jan 22  2020 NOTICE-rw-r--r-- 1 root root  1269 Jan 22  2020 README#bin目录下就有间接启动的命令
Docker装置（重点介绍）
[root@centos7 ~]# docker run -it \ -p 6650:6650 \ -p 8080:8080 \ --mount source=pulsardata,target=/pulsar/data \ --mount source=pulsarconf,target=/pulsar/conf \ apachepulsar/pulsar:2.8.0 \ bin/pulsar standalone

http协定拜访应用8080端口，pulsar协定（Java、Python等客户端）拜访应用6650端口。

官网提供的可视化工具 Pulsar Manager，能够对多个Pulsar进行可视化治理。https://pulsar.apache.org/doc...

[root@centos7 ~]# docker pull apachepulsar/pulsar-manager:v0.2.0[root@centos7 ~]# docker run -it \   -p 9527:9527 -p 7750:7750 \   -e SPRING_CONFIGURATION_FILE=/pulsar-manager/pulsar-manager/application.properties \   apachepulsar/pulsar-manager:v0.2.0

设置管理员用户与明码

[root@centos7 ~]# CSRF_TOKEN=$(curl http://localhost:7750/pulsar-manager/csrf-token)curl \  -H 'X-XSRF-TOKEN: $CSRF_TOKEN' \  -H 'Cookie: XSRF-TOKEN=$CSRF_TOKEN;' \  -H "Content-Type: application/json" \  -X PUT http://localhost:7750/pulsar-manager/users/superuser \  -d '{"name": "admin", "password": "admin123", "description": "test", "email": "mingongge@test.org"}'{"message":"Add super user success, please login"}

浏览器间接输出 http://server_ip:9527 登录如下

输出刚刚创立的用户与明码，配置管理的服务端

列表

Toptic列表

Toptic详细信息

客户端配置

Java客户端

上面是一个应用共享订阅的 Java 消费者配置示例：

import org.apache.pulsar.client.api.Consumer;import org.apache.pulsar.client.api.PulsarClient;import org.apache.pulsar.client.api.SubscriptionType;String SERVICE_URL = "pulsar://localhost:6650";String TOPIC = "persistent://public/default/mq-topic-1";String subscription = "sub-1";PulsarClient client = PulsarClient.builder()        .serviceUrl(SERVICE_URL)        .build();Consumer consumer = client.newConsumer()        .topic(TOPIC)        .subscriptionName(subscription)        .subscriptionType(SubscriptionType.Shared)        // If you'd like to restrict the receiver queue size        .receiverQueueSize(10)        .subscribe();
Python客户端

上面是一个应用共享订阅的 Python 消费者配置示例：

from pulsar import Client, ConsumerTypeSERVICE_URL = "pulsar://localhost:6650"TOPIC = "persistent://public/default/mq-topic-1"SUBSCRIPTION = "sub-1"client = Client(SERVICE_URL)consumer = client.subscribe(    TOPIC,    SUBSCRIPTION,    # If you'd like to restrict the receiver queue size    receiver_queue_size=10,    consumer_type=ConsumerType.Shared)
C++ 客户端

上面是一个应用共享订阅的 C++ 消费者配置示例：

#include <pulsar/Client.h>std::string serviceUrl = "pulsar://localhost:6650";std::string topic = "persistent://public/defaultmq-topic-1";std::string subscription = "sub-1";Client client(serviceUrl);ConsumerConfiguration consumerConfig;consumerConfig.setConsumerType(ConsumerType.ConsumerShared);// If you'd like to restrict the receiver queue sizeconsumerConfig.setReceiverQueueSize(10);Consumer consumer;Result result = client.subscribe(topic, subscription, consumerConfig, consumer);

更多配置及操作指南，官网的文档写的都很分明，官网文档：https://pulsar.apache.org/docs/

总结

Plusar 作为下一代分布式音讯队列，领有十分多吸引人的个性，也补救了一些其余竞品的短板，例如地区复制、多租户、扩展性、读写隔离等等。