メインコンテンツにスキップ
バージョン: 5.0

Go クライアント SDK

情報

このセクションでは、Apache RocketMQ 5.0 gRPC プロトコル Go SDK を使用したメッセージの送受信について説明します。

情報
  • このサンプルコードは、gRPC プロトコル SDK に基づいてビルドされています。したがって、サーバーはバージョン 5.0 以上にアップグレードされ、gRPC プロキシを有効にして互換性を持たせる必要があります。プロキシのデプロイについては、クイックスタートガイドを参照してください。
  • リモートプロトコル SDK を使用している場合は、実行のために以前のバージョン 4.x のサンプルコードを参照することをお勧めします。ご使用の SDK の種類を識別するには、概要を参照してください。

CodeExample

Apache RocketMQ gRPC プロトコル Go SDK を使用したメッセージの送受信に関するサンプルコードへのリンクを以下に示します。完全なコードプロジェクトとランタイム環境は、rocketmq-clientsリポジトリにあります。構成と実行については、そちらを参照してください。

MessageTypesプロデューサーのサンプルSimpleConsumer のサンプル
NormalMessage同期プロデューサー:ExampleProducerNormalMessage.go
非同期プロデューサー:AsyncExampleProducerNormalMessage.go
ExampleSimpleConsumer.go
FIFOMessageExampleProducerWithFifoMessage.goExampleSimpleConsumer.go
DelayMessageExampleProducerDelayMessage.goExampleSimpleConsumer.go
TransactionMessageExampleProducerWithTransactionalMessage.goExampleSimpleConsumer.go