このトピックでは、Message Queue for Apache RocketMQ SDK for Javaを使用してメッセージを送受信する前に環境を準備する方法について説明します。
重要
最新のRocketMQ 5.x SDKを使用することを推奨します。 これらのSDKは、ApsaraMQ for RocketMQ 5.xブローカーと完全に互換性があり、より多くの機能と強化された機能を提供します。 詳細については、「リリースノート」をご参照ください。
Alibaba Cloudは、RocketMQ 3.x、4.x、およびTCPクライアントSDKのみを保持します。 既存のビジネスにのみ使用することを推奨します。
手順
次のいずれかのメソッドを使用して依存関係を追加します。
Mavenを使用した依存関係のインポート:
<dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> <version>4.9.4</version> <!--We recommend that you update to the latest version--> </dependency> <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-acl</artifactId> <version>4.9.4</version> <!--We recommend that you update to the latest version--> </dependency>依存関係JARパッケージをダウンロードします。
依存関係JARパッケージをダウンロードするには、Apache RocketMQ公式Webサイトにアクセスしてください。
Alibaba Cloud ApsaraMQ for RocketMQコンソールのMessage Queue for Apache RocketMQ SDK for Javaのコードで参照されるリソースを作成する必要があります。 リソースには、Alibaba Cloud ApsaraMQ for RocketMQインスタンス、トピック、およびグループIDが含まれます。
詳細については、「リソースの作成」 をご参照ください。