8.3. 创建共享订阅

共享订阅是远程服务器中代表一个或多个消息接收器的状态。由于它是共享的，多个客户端可以从同一消息流使用。

客户端通过在接收器源上设置 共享功能来配置共享 订阅。

共享订阅通过组合客户端容器 ID 和接收器名称来组成订阅 ID 来唯一标识。它们必须具有稳定的值，以便多个客户端进程可以找到相同的订阅。如果除了 共享 外设置了 全局 功能，则仅接收方名称用于标识订阅。

要创建持久订阅，请按照以下步骤执行：

将连接容器 ID 设置为 stable 值，如 client-1 ：

container = Container(handler)
container.container_id = "client-1"

通过设置共享功能来配置用于 共享的 接收器源：

class SubscriptionOptions(ReceiverOption):
    def apply(self, receiver):
        receiver.source.capabilities.put_object(symbol("shared"))

使用稳定名称（如 sub-1 ）创建一个接收器，并应用源属性：

event.container.create_receiver(conn, "notifications",
                                name="sub-1",
                                options=SubscriptionOptions())

要从订阅分离，请使用 Receiver.detach （） 方法。要终止订阅，请使用 Receiver.close （） 方法。

如需更多信息，请参阅 shared-subscribe.py 示例。

8.3. 创建共享订阅

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links