Java Client SDK

資訊

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

資訊

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

CodeExample

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

MessageTypes	Producer 範例	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