You need to enable JavaScript to run this app.
导航
消息队列 RocketMQ版
  • 文档首页
    • /消息队列 RocketMQ版/SDK 参考/概述
概述
最近更新时间：2024.01.23 14:26:44首次发布时间：2022.11.01 11:10:52
我的收藏

SDK 类型

消息队列 RocketMQ版实例完全兼容开源 RocketMQ 协议，可以直接使用 RocketMQ 开源客户端连接。

SDK类型

用途及说明

开源 RocketMQ SDK

消息队列 RocketMQ版与开源 Apache RocketMQ 完全兼容，支持通过开源 RocketMQ SDK 生产和消费消息。开源 RocketMQ SDK 通常集成在客户端程序中，用于管理 RocketMQ 实例中的资源和数据，例如生产消息、消费消息。
消息队列 RocketMQ版提供 Go、Java 等语言的示例项目供您参考，其中包括各种机制下的消息生产与消息消费的示例代码。详细信息请参考示例代码。

OpenAPI SDK

火山引擎提供管控面的多语言 SDK，供您调用火山引擎各个服务的 OpenAPI，通过调用 API 接口实现管理云资源的需求，免去签名与鉴权的流程，快速接入云服务。

说明

消息队列 RocketMQ版暂未对接火山引擎 OpenAPI SDK，您可以通过火山引擎已提供多语言的 OpenAPI SDK 的认证模块进行 API 的签名与鉴权，但无法直接通过此 SDK 调用 RocketMQ OpenAPI 接口，必须自行处理 OpenAPI 接口调用部分的代码逻辑。

注意事项

  • 对于2022年12月16日及后续创建的 RocketMQ 实例，通过 Go、Python、C++ 等除 Java 以外其他语言的 SDK 收发消息时，无需在指定 Topic 或 Group 时拼接实例 ID。在此之前创建的 RocketMQ 实例，仍然需要通过拼接实例 ID 的格式指定 Topic 或 Group，即 InstanceID%GroupID，例如MQ_INST_85bclzugcfkd_nxxxx%demo-group。
    您可以通过实例 ID 格式快速判断某实例是否需要在指定 Topic 或 Group 时拼接 ID：

    实例创建时间

    实例 ID 格式及示例

    是否需要拼接 ID

    2022年12月15日及之前

    • 实例 ID 格式：MQ_INST_xxxxxx
    • 实例 ID 示例： MQ_INST_85bclzugcfkd_nxxxx

    需要，例如producer.WithGroupName("MQ_INST_85bclzugcfkd_nxxxx%demo-group")。

    2022年12月16日及以后

    • 实例 ID 格式：rocketmq-xxxxx
    • 实例 ID 示例： rocketmq-cnoe3ad4d317xxxx

    不需要，例如producer.WithGroupName("demo-group") 。

  • 消息队列 RocketMQ版提供各种协议的接入点供您连接使用，访问私有网络 VPC 类型的接入点时，需要对私网域名进行解析，但私网域名默认必须在火山引擎私网环境下才能成功解析为私网 IP 地址。您可以为实例开启公网解析功能，开启后，即使在公网环境下也可以成功将私网域名解析为私网 IP 地址。
    使用公网解析需要注意以下注意事项：

    • 公网解析适用于测试环境等非生产环境场景，例如测试环境直连消息队列 RocketMQ版实例、个人设备访问私网域名等。
    • 私网域名经过公网解析之后得到的是火山引擎私网 IP 地址，您的本地环境需要通过 VPN 等方式打通火山引擎私网，否则无法成功访问该私网 IP 地址。
    • 由于公网环境复杂，无法确保域名解析的准确性与时效性，因此公网 DNS 解析功能仅可用于非生产环境。生产环境强烈建议采用 DNS Forward 方案，在本地 DNS Server 中配置 Forward 到火山引擎 DNS，实现私网域名解析。
    • 火山引擎私网解析（PrivateZone）提供了 DNS 高可用插件，能把 DNS 查询结果缓存到本地，并在 DNS 服务不可用时返回缓存的查询结果，避免因 DNS 服务不可用导致客户端无法正常访问资源。如需了解更多信息，请参见DNS 高可用插件介绍、为消息队列 RocketMQ 版集成 DNS 高可用插件。

示例代码

消息队列 RocketMQ版提供多语言的示例代码供您参考，包括收发普通消息、顺序消息和事务消息的基本流程，详细信息请参考：

开发语言

示例代码

Java

Go

Python

C++