Go API开发者指南

SolacePubSub+ Go 版消息 API（版本 1.8）采用现代开发模式和易用性，以原生 Solace API 的形式呈现。PubSub+ Go API 让你的应用程序能够充分利用 Solace 事件代理的功能集。

PubSub+ Go API 采用了构建器模式，允许你轻松创建一个 MessagingService 实例，并通过自定义配置连接到事件代理。成功建立连接后，你可以使用我们的 Go API 发送和接收消息。我们的 Go API 还允许你处理消息在内部缓冲区积压的情况，这被称为“背压（back-pressure）”。例如，在一个发送消息的客户端应用程序中，可能会出现客户端生成消息的速度快于消息发送到事件代理的速度的情况，这可能是由于网络拥塞等因素导致的。

以下是设置好环境后如何使用 PubSub+ Go 消息 API 的概述：

1. 构建一个 MessagingService 实例，并通过属性对其进行配置，以实现以下功能：

   • 连接到事件代理，例如主机名和消息 VPN。
   • 使用代理（如 HTTP 或 SOCKS5）连接到主机事件代理。
   • 设置连接属性，例如 TLS 或压缩。
   • 选择认证方案以认证到事件代理。

2. 使用以下方式向事件代理发送消息或从事件代理接收消息：

   • 在创建消息发布者或消息消费者时，可以配置如何处理背压发生的情况。更多信息请参见以下各部分：
   • 使用 DirectMessagePublisher 发布直接消息。更多信息，请参见“使用 Go API 发布直接消息”。
   • 使用 PersistentMessagePublisher 发布持久消息（保证消息）。更多信息，请参见“使用 Go API 发布持久消息”。
   • 使用 DirectMessageReceiver 从事件代理消费直接消息。更多信息，请参见“使用 Go API 消费直接消息”。
   • 使用 PersistentMessageReceiver 消费持久消息（保证消息）。更多信息，请参见“使用 Go API 消费持久消息”。

3. 在发布或消费消息的过程中，使用 OutboundMessage 和 InboundMessage，并通过事件处理器按需处理错误。

你可以参考各种示例应用程序来了解如何使用我们的 Go API。更多信息，请查看本指南的相关部分，以及 Solace Go API GitHub 页面上的 PubSub+ Go 消息 API 参考和 Go 示例代码。