跳至主要内容
版本: 5.0

Go 客户端 SDK

信息​

本节介绍使用 Apache RocketMQ 5.0 gRPC 协议 Go SDK 发送和接收消息。

信息
  • 此示例代码基于 gRPC 协议 SDK 构建。因此，服务器需要升级到至少 5.0 版本并启用 gRPC 代理才能兼容。有关部署代理的信息，请参阅 快速入门指南。
  • 如果您使用的是 Remoting 协议 SDK，建议您参考 4.x 之前版本的示例代码进行运行。要识别您使用的 SDK 类型，请参阅 概述。

代码示例​

以下是使用 Apache RocketMQ gRPC 协议 Go SDK 发送和接收消息的示例代码链接。完整的代码项目和运行时环境可以在 rocketmq-clients 存储库中找到。请参考它进行配置和运行。

消息类型生产者示例简单消费者示例
普通消息同步生产者: ExampleProducerNormalMessage.go
异步生产者: AsyncExampleProducerNormalMessage.go		ExampleSimpleConsumer.go
FIFO 消息ExampleProducerWithFifoMessage.goExampleSimpleConsumer.go
延迟消息ExampleProducerDelayMessage.goExampleSimpleConsumer.go
事务消息ExampleProducerWithTransactionalMessage.goExampleSimpleConsumer.go