このトピックでは、Community EditionのTCPクライアントSDK for Javaを使用してApsaraMQ for RocketMQにアクセスし、メッセージを送受信する方法について説明します。
使用上の注意
Community EditionのSDKは、コードを変更せずにApache RocketMQクラスターのビジネスをApsaraMQ for RocketMQインスタンスに移行するシナリオでのみ使用されます。 その他のシナリオでは、Commercial EditionのSDKを使用してApsaraMQ For RocketMQに接続することを推奨します。 Commercial EditionのSDKは、Community EditionのSDKと比較して、より多くの機能とより高い安定性を提供します。 詳細については、「リリースノート」をご参照ください。
バージョン
Community EditionのTCPクライアントSDK for Javaを使用してApsaraMQ for RocketMQにアクセスする場合は、SDKバージョン4.5.2以降をダウンロードする必要があります。 最新バージョンの SDK を使用することを推奨します。 ダウンロードリンク: TCP client SDK for Java of the Community Edition
準備
次の操作を順番に実行します。
Mavenの依存関係をインポートします。
ApsaraMQ for RocketMQコンソールで必要なリソースを作成します。
詳細については、「 準備」をご参照ください。
(オプション) パラメータ
Community EditionのTCPクライアントSDK for Javaを使用してApsaraMQ for RocketMQに接続してメッセージを送受信する前に、必要なパラメーターを設定する必要があります。 詳細は、「パラメーター」をご参照ください。
また、Community EditionのJava用TCPクライアントSDKにコメントを表示して、パラメーターの詳細を取得することもできます。