TCP 経由のコミュニティ版 Java SDK を使用して ApsaraMQ for RocketMQ に接続し、メッセージを送受信します。
注意事項
オープンソース RocketMQ をクラウドに移行し、コードを変更したくない場合にのみ、コミュニティ版 SDK を使用してください。その他すべてのシナリオでは、ApsaraMQ for RocketMQ が提供する商用版 SDK を使用してください。商用版 SDK は、コミュニティ版 SDK よりも多くの機能と高い安定性を提供します。詳細については、「Java 用 SDK (商用版)」をご参照ください。
バージョンガイド
コミュニティエディション SDK for Java (TCP) には、バージョン 4.5.2 以降が必要です。最新バージョンの使用を推奨します。SDK は「コミュニティエディション TCP SDK for Java」からダウンロードできます。
事前準備
次の手順を順番に実行してください。
-
Maven 依存関係をインポートします。
-
ApsaraMQ for RocketMQ コンソールでリソースを作成します。
詳細については、「事前準備」をご参照ください。
(オプション) パラメーターの説明
コミュニティエディション SDK for Java (TCP) を使用してメッセージを送受信する前に、必要なパラメーターを設定してください。詳細については、「パラメーターの説明」をご参照ください。
パラメーターの説明は、SDK ソースコードのコメントでも確認できます。