7.2. 创建持久订阅
持久订阅是远程服务器上代表消息接收器的一种状态。通常,当客户端关闭时,消息接收器会被丢弃。但是,由于持久订阅是永久的,客户端可以从它们分离,然后在以后重新连接。当客户端重新附加时,分离时收到的所有消息都可用。
持久订阅通过组合客户端容器 ID 和接收器名称组成订阅 ID 来唯一标识。这些必须具有稳定值,以便可以恢复订阅。
要创建持久订阅,请按照以下步骤执行:
将连接容器 ID 设置为 stable 值,如
client-1
:Connection conn = new Connection(new Address(connUrl), SaslProfile.Anonymous, new Open() { ContainerId = "client-1" }, null);
设置
Durable
和ExpiryPolicy
属性,将接收器源配置为持久性:Source source = new Source() { Address = "notifications", Durable = 2, ExpiryPolicy = new Symbol("never"), };
使用稳定名称(如
sub-1
)创建接收器,并应用源属性:ReceiverLink receiver = new ReceiverLink(session, "sub-1", source, null);
要从订阅分离,请在不明确关闭接收方的情况下关闭连接。要终止订阅,请直接关闭接收方。
如需更多信息,请参阅 DurableSubscribe.cs 示例。