跳至主要內容
版本：5.0

Go 客戶端 SDK

資訊​

本節介紹如何使用 Apache RocketMQ 5.0 gRPC 協定 Go SDK 傳送和接收訊息。

資訊
  • 此範例程式碼是根據 gRPC 協定 SDK 建置的。因此，伺服器需要升級到至少 5.0 版本，並啟用 gRPC Proxy 才能相容。請參閱快速入門指南以部署 Proxy。
  • 如果您使用的是 Remoting 協定 SDK，建議參閱前一版本 4.x 的範例程式碼以執行。若要識別您正在使用的 SDK 類型，請參閱概觀。

CodeExample​

以下是使用 Apache RocketMQ gRPC 協定 Go SDK 傳送和接收訊息的範例程式碼連結。完整的程式碼專案和執行時間環境可以在rocketmq-clients儲存庫中找到。請參閱該儲存庫以進行設定和執行。

訊息類型生產者範例SimpleConsumer 範例
一般訊息同步生產者：ExampleProducerNormalMessage.go
非同步生產者：AsyncExampleProducerNormalMessage.go		ExampleSimpleConsumer.go
FIFO 訊息ExampleProducerWithFifoMessage.goExampleSimpleConsumer.go
延遲訊息ExampleProducerDelayMessage.goExampleSimpleConsumer.go
事務訊息ExampleProducerWithTransactionalMessage.goExampleSimpleConsumer.go