跳到主要内容

Java API开发者指南

Java 的 PubSub+ 消息 API(版本 1.7)在原生 Java 环境中使用现代接口、模式和易用性。Java 的 PubSub+ API 提供了许多与 PubSub+ 消息 API for JCSMP 相同的功能,但需要的设置最少,为开发客户端应用程序提供了流畅的开发体验。

Java 的 PubSub+ API 使用构建器模式,允许您轻松创建一个具有自定义配置的 MessagingService 对象,然后连接到事件代理。建立成功连接后,您可以使用 PubSub+ Java API 提供的其他接口发送和接收消息。您可以使用 Java 的 PubSub+ API 处理消息在内部缓冲区中积累的情况,称为 反向压力。例如,在发送消息的客户端应用程序中,可能会出现客户端应用程序生成消息的速度快于消息发送到事件代理的速度的情况,这可能是由于网络拥塞等因素造成的。

在设置好环境后,以下是使用 Java 的 PubSub+ 消息 API 的概述:

  1. 构建 MessagingService 对象,并使用属性进行配置,以:

    • 连接到事件代理,例如主机名和消息 VPN
    • 设置连接属性,例如 TLS 或压缩
    • 选择身份验证方案以对事件代理进行身份验证
  2. 使用这些对象向事件代理发送消息或从事件代理接收消息:

    • 在创建发布或消费消息的对象时,您可以配置如何处理反向压力的发生。有关详细信息,请参阅以下各节。
    • 使用 DirectMessagePublisher 对象发布直接消息。有关更多信息,请参阅使用 Java API 发布直接消息。
    • 使用 PersistentMessagePublisher 对象发布持久消息(保证消息)。有关更多信息,请参阅使用 Java API 发布持久消息。
    • 使用 DirectMessageReceiver 对象从事件代理消费直接消息。有关更多信息,请参阅使用 Java API 消费直接消息。
    • 使用 PersistentMessageReceiver 消费持久消息(保证消息)。有关更多信息,请参阅使用 Java API 消费持久消息。
  3. 在发布或订阅消息的过程中,使用 OutboundMessageInboundMessage 对象,并通过事件处理器按需处理错误。

您可以参考各种示例应用程序,以了解如何使用 PubSub+ Java API。有关更多信息,请参阅使用 Java API 示例,或结合本指南的相关部分和 Java 的 PubSub+ 消息 API 参考进行查阅。

以下是一段简短视频,提供了 Java 的 PubSub+ API 的简要概述。