pulsar 有广播模式吗

发表于： 2025年9月14日 2025年9月14日
分类：消息队列
标签： Pulsar

Apache Pulsar本身没有直接的“广播模式”，即消息在发布后会被所有消费者接收的功能（类似于Kafka的“广播语义”或在RocketMQ中通过广播消费实现的方式）。然而，通过灵活的订阅功能，我们可以模拟广播模式来实现类似的效果。

Pulsar的订阅模型回顾：

Pulsar中有四种主要的订阅类型：

Exclusive – 独享订阅，一个订阅仅允许一个消费者。
Failover – 故障转移订阅，多个消费者订阅一个名称，但只有一个处于活动状态。
Shared – 共享订阅，多个消费者会分流消息。
Key_Shared – 按键共享订阅，消息根据 key 有序地分布给特定消费者。

但是这些订阅模型都是在一个订阅（Subscription）范围内工作的，并不能直接实现消息广播到所有消费者。

模拟广播模式的实现

即使Pulsar没有直接的“广播模式”，我们可以通过以下两种方法来实现类似的效果：

方法一：使用多个独立订阅名称

对于广播场景，我们可以为每个消费者创建一个独立的订阅名称，保证每个消费者都能够获取到全部消息。例如，Topic可以是 my-topic，消费者分别使用订阅名称 subscription1, subscription2, subscription3 等。
示例代码（Golang）：

consumer1, err := client.Subscribe(pulsar.ConsumerOptions{
    Topic:            "my-topic",
    SubscriptionName: "subscription1",
    Type:             pulsar.Exclusive, // 订阅类型可以根据需求选择
})
if err != nil {
    log.Fatal(err)
}

consumer2, err := client.Subscribe(pulsar.ConsumerOptions{
    Topic:            "my-topic",
    SubscriptionName: "subscription2",
    Type:             pulsar.Exclusive, // 订阅类型可以根据需求选择
})
if err != nil {
    log.Fatal(err)
}

通过多个订阅（Subscription），每个消费者都可以独立接收到同一个Topic的所有消息，实现了消息的“广播”效果。