You need to enable JavaScript to run this app.
文档中心
消息队列 RocketMQ版

消息队列 RocketMQ版

复制全文
下载 pdf
RocketMQ 4.x
概述
复制全文
下载 pdf
概述
SDK 类型​
消息队列 RocketMQ版实例完全兼容开源 RocketMQ 协议,可以直接使用 RocketMQ 开源客户端连接。​
​
SDK类型​
用途及说明​
开源 RocketMQ SDK​
消息队列 RocketMQ版与开源 Apache RocketMQ 完全兼容,支持通过开源 RocketMQ SDK 生产和消费消息。开源 RocketMQ SDK 通常集成在客户端程序中,用于管理 RocketMQ 实例中的资源和数据,例如生产消息、消费消息。​
消息队列 RocketMQ版提供 Go、Java 等语言的示例项目供您参考,其中包括各种机制下的消息生产与消息消费的示例代码。详细信息请参考示例代码。​
Volcengine OpenAPI SDK​
火山引擎提供管控面的多语言 SDK,供您调用火山引擎各个服务的 OpenAPI,通过调用 API 接口实现管理云资源的需求,免去签名与鉴权的流程,快速接入云服务。​
消息队列 RocketMQ版已对接火山引擎 OpenAPI SDK,您可以参考以下文档安装并使用 Volcengine SDK。​
​
注意事项​
  • 对于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,实现私网域名解析。​
示例代码​
消息队列 RocketMQ版提供多语言的示例代码供您参考,包括收发普通消息、顺序消息和事务消息的基本流程,详细信息请参考:​
​
最近更新时间:2025.07.09 16:22:42
这个页面对您有帮助吗?
有用
有用
无用
无用