对于消息队列而言,Pulsar 是绝佳选择,这是因为:

    • 为提供主题消息的自动负载均衡(支持自定义负载均衡)。

    客户端配置更改

    • If you’d like to have tight control over message dispatching across consumers, set the consumers’ receiver queue size very low (potentially even to 0 if necessary). 每个 Pulsar 都有一个接收器队列,用于确定消费者一次尝试获取的消息数量。 例如,接收器队列 1000 (默认值)意味着消费者将尝试在连接时处理来自主题的 1000 条待办消息。 将接收器队列值设置为零实质上意味着确保每个消费者一次只做一件事。

    以下是使用共享订阅的 Java 消费者配置示例:

    以下是使用共享订阅的 Python 消费者配置示例: