接收消息

Python 的 PubSub+ 消息 API 允许客户端消费发布到其订阅主题的任何消息。

接收者可以通过以下方式从事件代理消费消息：

使用 Python API 消费直接消息

直接消息传递提供了一种可靠但不保证的消息传递方式，消息从发布客户端发送到接收客户端。直接消息是“最多一次”传递的。当事件代理为该客户端匹配主题订阅时，可以直接将直接消息传递给客户端会话。直接消息与持久消息不同，因为它们：

• 是“最多一次”发送的
• 当客户端未连接到事件代理时，不会为客户端保留
• 在遇到拥塞或系统故障时可能会被丢弃
• 传递时不会被确认

使用 Python API 消费持久消息

持久消息传递（也称为保证消息传递）可用于确保两个应用程序之间传递消息。持久消息是“至少一次”传递的，在接收应用程序可能会断开连接，但不能容忍消息丢失的情况下非常有用。要接收持久消息，客户端必须创建一个消费者流，以绑定到事件代理上的持久或非持久队列，发布到该队列的消息会存储在消息池中。客户端应用程序绑定到队列后，且有一个活跃的消费者流（即消息正在通过该流传递），就可以从队列中消费持久消息。