1.5.Apache Pulsar的主要组件介绍与命令使用 1.5.1.多租户模式 1.5.1.1. 什么是多租户 1.5.1.2.Pulsar多租户的相关特征_安全性（认证和授权） 1.5.1.3.Pulsar多租户的相关特性_隔离性 1.5.1.4.Pulsar多租户的相关操作 1-获取租户列表 2-创建租户 3-获取配置 4-更新配置 5-删除租户

==================== 1.5.2.Pulsar的名称空间 1.5.2.1.什么是名称空间 1.5.2.2.Pulsar NameSpace(名称空间)相关操作_基本操作 1-在指定的租户下创建名称空间 2-获取所有的名称空间列表 3-删除名称空间

1.5.2.3.Pulsar Namespace(名称空间) 相关操作_高级操作 1-获取名称空间相关的配置策略 2-配置复制集群 2.1 设置backlog quota策略 2.2-获取给定命名空间复制集群的列表

3-配置backlog quota策略 3.1 - 获取backlog quota策略 3.2 - 获取backlog quota策略 3.3 - 移除backlog quota策略

4-配置持久化策略 4.1-设置持久化策略 4.2-获取持久化策略

5-配置消息存活时间（TTL） 5.1-设置消息存活时间 5.2 - 获取消息的存活时间 5.3 - 删除消息的存活时间

6 - 配置整个名称空间中Topic的消息发送速率。 6.1-设置Topic的消息发送的速率 6.2 获取topic的消息发送速率

7-配置整个名称空间中Topic的消息收速率 7.1-设置Topic的消息接收速率 7.2 获取topic的消息接收速率

8-配置整个名称空间中Topic的复制集群的速率 8.1-设置Topic的消息复制集群的速率 8.2 获取topic的消息复制集群的速率

==================== 1.5.3.Pulsar的topic相关操作 1.5.3.1.什么是Topic 1.5.3.2. Pulsar Topic(主题)相关操作_基础操作 1-创建Topic 2 - 列出当前某个名称空间下的所有Topic 3-更新Topic操作 4-删除Topic操作

==================== 1.5.3.3.Pulsar Topic（主题）相关操作_高级操作 1-授权 2-获取权限 3-取消权限

多租户是一种架构，目的是为了让多用户环境下使用同一套程序，且保证用户间数据隔离。 简单讲：在一台服务器上运行单个应用实例，它为多个租户（客户）提供服务。

Apache Pulsar 最初诞生于雅虎，当时就是为了解决雅虎内部各个部门之间数据的协调，所以多租户特性显得至关重用，Pulsar 从诞生之日起就考虑到多租户这一特性，并在后续的实现过程中，将其不断的完善。多租户这一特性，使得各个部门之间可以共享同一份数据，不用单独部署独立的系统来操作数据，很好的保证了各部门间数据一致性的问题，同时简化维护成本。

Pulsar 的多租户设计符合上述要求：

Pulsar的多租户性质主要体现在topic的URL中, 其结构如下:

从URL中可以看出tenant(租户)是topic最基本的单元(比命名空间和topic名称更为基本)

一个多租户系统需要在租户内提供系统级别的安全性，细分来讲，主要可以归类为以下两点:

在 Pulsar 中，多租户的安全性是通过身份验证和授权机制实现的。当 client 连接到 pulsar broker 时，broker 会使用身份验证插件来验证此客户端的身份，然后为其分配一个 string 类型的 role token。role token 主要有如下作用：

Pulsar目前支持以下几种身份认证，同时支持自定义实现自己的身份认证程序

在创建租户时，可以使用-r或者–admin-roles标志分配管理角色。可以用逗号分隔的列表指定多个角色。

namespace是Pulsar中最基本的管理单元，在namespace这一层面，可以设置权限，调整副本设置，管理跨集群的消息复制，控制消息策略和执行关键操作。一个主题topic可以继承其所对应的namespace的属性，因此我们只需对namespace的属性进行设置，就可以一次性设置该namespace中所有主题topic的属性。

namespace有两种，分别是本地的namespace和全局的namespace：

虽然本地namespace和全局namespace的作用域不同，但是只要对他们进行适当的设置，都可以跨团队和跨组织共享。一 旦生产者获得了namespace的写入权限，那么它就可以往namespace中的所有topic主题写入数据，如果某个主题不存在，则在生产者第一次写入数据时动态创建。

3.1 - 获取backlog quota策略

3.2 - 获取backlog quota策略

3.3 - 移除backlog quota策略

4.1-设置持久化策略

4.2-获取持久化策略

5.1-设置消息存活时间

5.2 - 获取消息的存活时间

5.3 - 删除消息的存活时间

6 - 配置整个名称空间中Topic的消息发送速率。 6.1-设置Topic的消息发送的速率

6.2 获取topic的消息发送速率

7-配置整个名称空间中Topic的消息收速率 7.1-设置Topic的消息接收速率

参数说明： –msg-dispatch-rate: 每dispatch-rate-period秒钟接收的消息数据。 –byte-dispatch-rate: 每dispatch-rate-period秒钟接收的总字节数 –dispatch-rate-period: 设置接收的速率，比如1表示 每秒钟

7.2 获取topic的消息接收速率

8-配置整个名称空间中Topic的复制集群的速率 8.1-设置Topic的消息复制集群的速率

参数说明： –msg-dispatch-rate : 每dispatch-rate-period秒钟复制集群的消息数量 –byte-dispatch-rate : 每dispatch-rate-period秒钟复制集群的总字节数 –dispatch-rate-period : 设置复制集群的速率, 比如 1 表示 每秒钟

8.2 获取topic的消息复制集群的速率

Topic,话题主题的含义, 在一个名称空间下, 可以定义多个Topic 通过Topic进行数据的分类划分, 将不同的类别的消息放置到不同Topic, 消费者也可以从不同Topic中获取到相关的消息, 是一种更细粒度的消息划分操作, 同时在Topic下可以划分为多个分片, 进行分布式的存储操作, 每个分片下还存在有副本操作, 保证数据不丢失, 当然这些分片副本更多是由bookkeeper来提供支持。

Pulsar 提供持久化与非持久化两种topic。 持久化topic是消息发布、消费的逻辑端点。 持久化topic地址的命名格式如下:

非持久topic应用在仅消费实时发布消息与不需要持久化保证的应用程序。 通过这种方式，它通过删除持久消息的开销来减少消息 发布延迟。 非持久化topic地址的命名格式如下:

1-创建Topic 方式一：创建一个没有分区的topic

方式二：创建一个有分区的topic

注意：不管是有分区还是没有分区，创建topic后，如果没有任何操作，60s后pulsar会认为此topic是不活动的，会自动进行删除，以避免生成垃圾数据。

相关配置： Brokerdeleteinactivetopicsenabenabled : 默认值为true 表示是否启动自动删除 BrokerDeleteInactiveTopicsFrequencySeconds: 默认为60s 表示检测未活动的时间

2 - 列出当前某个名称空间下的所有Topic

3-更新Topic操作 我们可针对有分区的topic去更新其分区的数量。

4-删除Topic操作 删除没有分区的topic 准备： ./pulsar-admin namespaces create my-tenant/my-namespace （创建命名空间） ./pulsar-admin topics create persistent://my-tenant/my-namespace/my-topic （创建一个无分区的topic） ./pulsar-admin topics create-partitioned-topic persistent://my-tenant/my-namespace/my-topic2 --partitions 4 （创建一个有分区的topic）

1-授权

2-获取权限

3-取消权限