Java クライアントSDK
情報
このセクションでは、Apache RocketMQ 5.0 gRPC プロトコル Java SDK を使用したメッセージの送受信について説明します。
情報
- このサンプルコードは、gRPC プロトコル SDK に基づいて構築されています。そのため、サーバーをバージョン 5.0 以上にアップグレードし、互換性のために gRPC プロキシを有効にする必要があります。プロキシのデプロイについては、クイックスタートガイドを参照してください。
- Remoting プロトコル SDK を使用している場合は、実行する前に以前のバージョン 4.x のサンプルコードを参照することをお勧めします。使用している SDK の種類を特定するには、概要を参照してください。
コード例
Apache RocketMQ gRPC プロトコル Java SDK を使用したメッセージの送受信に関するサンプルコードへのリンクを次に示します。完全なコードプロジェクトとランタイム環境は、rocketmq-clientsリポジトリにあります。構成と実行については、そちらを参照してください。
| メッセージタイプ | プロデューサーの例 | PushConsumer の例 | SimpleConsumer の例 |
|---|---|---|---|
| NormalMessage | 同期送信例:ProducerNormalMessageExample.java 非同期送信例:AsyncProducerExample.java | PushConsumerExample.java | 同期サブスクライブメッセージ: SimpleConsumerExample.java 非同期サブスクライブメッセージ: AsyncSimpleConsumerExample.java |
| FIFOMessage | ProducerFifoMessageExample.java | PushConsumerExample.java | 同期サブスクライブメッセージ: SimpleConsumerExample.java 非同期サブスクライブメッセージ: AsyncSimpleConsumerExample.java |
| DelayMessage | ProducerDelayMessageExample.java | PushConsumerExample.java | 同期サブスクライブメッセージ: SimpleConsumerExample.java 非同期サブスクライブメッセージ: AsyncSimpleConsumerExample.java |
| TransactionMessage | ProducerTransactionMessageExample.java | PushConsumerExample.java | 同期サブスクライブメッセージ: SimpleConsumerExample.java 非同期サブスクライブメッセージ: AsyncSimpleConsumerExample.java |