Pulsar 消息概念2

1 主题
主题名称结构的URL：
{persistent|non-persistent}://tenant/namespace/topic

无需显式创建新主题
你不需要在Pulsar中显式地创建主题。如果客户端尝试向尚未存在的主题写入消息或接收消息，则Pulsar将自动在主题名称中提供的命名空间下创建该主题

2 命名空间
名称空间是租户中的逻辑术语。租户可以通过管理API创建多个名称空间。例如，具有不同应用程序的租户可以为每个应用程序创建单独的命名空间。命名空间允许应用程序创建和管理主题的层次结构。主题my tenant/app1是我的租户的应用程序app1的命名空间。可以在命名空间下创建任意数量的主题

3 订阅模式
Pulsar有三种订阅模式：独占(exclusive)，共享(shared)，故障转移(failover)
独占模式是默认订阅模式
共享模式的局限性
使用共享模式时有两件重要的事情需要注意：
无法保证消息排序。
不能将累积确认与共享模式一起使用。
4 密钥共享(Key_shared)
在密钥共享模式下，多个消息者可以同一订阅
密钥共享模式的限制
在使用密钥共享模式时，有两件重要的事情需要注意：
您需要为消息指定密钥或orderingKey
不能将累积确认与密钥共享模式一起使用
密钥共享订阅是一个测试版功能。您可以在broker.config禁用它(Pulsar 2.4.1)

5 多主题订阅
从Pulsar 1.23.0版开始，Pulsar用户可以同时订阅多个主题,两种方式
1)基于正则表达式（regex），例如persistent://public/default/finance-*
2)通过明确定义的topic列表
当通过regex订阅多个主题时，所有主题必须位于同一命名空间中

不能保证顺序性
当消费者订阅多个主题时，Pulsar通常就单个主题提供的所有订购保证都不成立。如果您的Pulsar用例涉及任何严格的订购要求，我们强烈建议您不要使用此功能
下面是一些Java的多主题订阅示例：
import java.util.regex.Pattern;

import org.apache.pulsar.client.api.Consumer;
import org.apache.pulsar.client.api.PulsarClient;

PulsarClient pulsarClient = // Instantiate Pulsar client object

// Subscribe to all topics in a namespace
Pattern allTopicsInNamespace = Pattern.compile("persistent://public/default/.*");
Consumer<byte[]> allTopicsConsumer = pulsarClient.newConsumer()
.topicsPattern(allTopicsInNamespace)
.subscriptionName("subscription-1")
.subscribe();

// Subscribe to a subsets of topics in a namespace, based on regex
Pattern someTopicsInNamespace = Pattern.compile("persistent://public/default/foo.*");
Consumer<byte[]> someTopicsConsumer = pulsarClient.newConsumer()
.topicsPattern(someTopicsInNamespace)
.subscriptionName("subscription-1")
.subscribe();

6分区主题
分区topic和普通topic，对于订阅模式如何工作，没有任何不同。分区只是决定了从生产者生产消息到消费者处理及确认消息过程中发生的事情。
分区topic需要通过admin API指定创建。创建的时候可以指明分区的数量。
路由模式

消息顺序
消息的顺序与消息路由模式和消息密钥有关。通常，用户需要按密钥分区保证排序。
如果消息附加了密钥，则在使用SinglePartition或RoundRobinPartition模式时，将根据哈希方案将消息路由到相应的分区

7 非持久性主题
格式如下：
non-persistent://tenant/namespace/topic
生产者和消费者可以以与持久主题相同的方式连接到非持久主题，关键的区别在于主题名称必须以非持久主题开头。所有三种订阅模式（独占、共享和故障转移）都支持非持久性主题。
客户端API
PulsarClient client = PulsarClient.builder()
.serviceUrl("pulsar://localhost:6650")
.build();
String npTopic = "non-persistent://public/default/my-topic";
String subscriptionName = "my-subscription-name";
消费
Consumer<byte[]> consumer = client.newConsumer()
.topic(npTopic)
.subscriptionName(subscriptionName)
.subscribe();
生产
Producer<byte[]> producer = client.newProducer()
.topic(npTopic)
.create();
8 消息保留和过期
默认情况下，Pulsar消息服务器：
立即删除消费者已确认的所有消息，以及
将所有未确认的消息持久存储在消息待办事项中。
但是，Pulsar有两个特性，使您能够覆盖此默认行为：
消息保留使您能够存储已由消费者确认的消息
消息过期使您能够为尚未确认的消息设置生存时间（TTL）

9 消息去重
当消息被Pulsar持久化多于一次的时候，会发生数据重复。消息去重是Pulsar可选的特性，阻止不必要的消息重复，每条消息仅处理一次