对于消息队列而言,Pulsar 是绝佳选择,这是因为:
- 为提供主题消息的自动负载均衡(支持自定义负载均衡)。
客户端配置更改
如果你希望严格控制消费者之间的消息调度,请将消费者接收器队列值设置得非常低(如果需要,甚至可能设置为 0 )。 每个 Pulsar 都有一个接收器队列,用于确定消费者一次尝试获取的消息数量。 例如,接收器队列 1000 (默认值)意味着消费者将尝试在连接时处理来自主题的 1000 条待办消息。 将接收器队列值设置为零实质上意味着确保每个消费者一次只做一件事。
以下是使用共享订阅的 Java 消费者配置示例:
以下是使用共享订阅的 Python 消费者配置示例: