Siapkan Java SDK dan buat sumber daya cloud yang diperlukan sebelum mengirim dan menerima pesan dengan ApsaraMQ for RocketMQ.
ApsaraMQ for RocketMQ menyediakan beberapa generasi SDK. SDK RocketMQ 5.x terbaru sepenuhnya kompatibel dengan broker ApsaraMQ for RocketMQ 5.x serta menawarkan lebih banyak fungsi dan fitur yang ditingkatkan. Untuk detail selengkapnya, lihat Release notes.
Alibaba Cloud hanya memelihara SDK client RocketMQ 4.x, 3.x, dan TCP untuk kebutuhan bisnis yang telah ada. Untuk proyek baru, gunakan SDK versi 5.x.
Prasyarat
Sebelum memulai, pastikan Anda telah:
Build tool: Menginstal Maven atau memiliki kemampuan untuk mengunduh paket JAR secara manual.
Tambahkan dependensi
Tambahkan Message Queue for Apache RocketMQ SDK untuk Java ke dalam proyek Anda menggunakan salah satu metode berikut.
Maven (direkomendasikan)
Tambahkan dependensi berikut ke file pom.xml Anda:
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-client</artifactId>
<version>4.9.4</version>
<!--Kami merekomendasikan agar Anda memperbarui ke versi terbaru-->
</dependency>
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-acl</artifactId>
<version>4.9.4</version>
<!--Kami merekomendasikan agar Anda memperbarui ke versi terbaru-->
</dependency>Pengunduhan JAR manual
Unduh paket dependensi JAR dari situs web resmi Apache RocketMQ.
Buat sumber daya
Sebelum menulis kode produsen atau konsumen, buat sumber daya berikut di Konsol ApsaraMQ for RocketMQ: instans, topik, dan ID kelompok.
Untuk petunjuk langkah demi langkah, lihat Buat sumber daya.
Kirim dan terima pesan pertama Anda
Setelah membuat sumber daya yang diperlukan, lihat Kode contoh untuk contoh lengkap produsen dan konsumen.