ApsaraMQ for MQTT：Demo

Prasyarat

• IntelliJ IDEA telah diinstal.

  Pastikan IntelliJ IDEA Edisi Ultimate telah diunduh dan diinstal sesuai kebutuhan. Untuk informasi lebih lanjut, kunjungi alamat unduhan. Sebagai alternatif, Anda dapat menggunakan Eclipse. Dalam contoh ini, IntelliJ IDEA digunakan.

• JDK 1.8 atau versi lebih baru telah diinstal. Untuk informasi lebih lanjut, kunjungi Unduhan Java.
• Sumber daya telah dibuat.

  Untuk menggunakan demo dalam mengirim dan berlangganan pesan, Anda perlu membuat sumber daya seperti instance, topik, dan grup terlebih dahulu di konsol. Selain itu, Anda juga harus memperoleh pasangan AccessKey dan titik akhir instance.

Jalankan demo

1. Unduh dan ekstrak paket demo.
   Untuk mengunduh demo, kunjungi mqtt-server-sdk-demo. Setelah diekstrak, folder mqtt-server-sdk-demo-main akan dihasilkan. Kode contoh untuk mengirim dan berlangganan pesan serta berlangganan notifikasi status klien tersimpan di direktori java-demo\src\main\java\com\aliyun\openservices\lmq\example.

   • Kelas MQTTProducerDemo: digunakan oleh aplikasi layanan backend untuk mengirim pesan ke broker ApsaraMQ for MQTT.
   • Kelas MQTTConsumerDemo: digunakan oleh aplikasi layanan backend untuk berlangganan pesan dari broker ApsaraMQ for MQTT.
   • Kelas MQTTClientStatusNoticeProcessDemo: digunakan oleh aplikasi layanan backend untuk berlangganan notifikasi status klien.
2. Impor demo yang diekstrak ke IntelliJ IDEA.
3. Modifikasi kode contoh sesuai kebutuhan bisnis Anda. Atur parameter dalam kode berdasarkan informasi sumber daya aktual.

   // Titik akhir instance Message Queue for MQTT. Untuk informasi tentang format titik akhir, lihat Antarmuka dan parameter.
   String domain = "domain";
   // Port yang digunakan oleh cloud SDK. Protokol dan port yang digunakan oleh cloud SDK harus cocok. Atur nilainya menjadi 5672.
   int port = "port";
   // ID instance Message Queue for MQTT yang Anda buat.
   String instanceId = "instanceId";
   // ID AccessKey dan Rahasia AccessKey Pengguna Resource Access Management (RAM).
   String accessKey = "accessKey";
   String secretKey = "secretKey";
   // Topik induk yang Anda buat untuk mengirim dan berlangganan pesan.
   String firstTopic = "firstTopic";
   // Subtopik yang akan digunakan. Anda dapat menentukan subtopik dalam kode tanpa perlu membuatnya terlebih dahulu di konsol. Untuk informasi lebih lanjut tentang konvensi penamaan subtopik, lihat Istilah.
   String secondTopic = "secondTopic";
   // ID grup yang Anda buat untuk mengirim dan berlangganan pesan.
   String mqttGroupId = "mqttGroupId";

4. Setelah konfigurasi selesai, jalankan fungsi main() untuk mengeksekusi kode contoh yang telah dimodifikasi.

Verifikasi hasil

Setelah menjalankan demo untuk mengirim dan berlangganan pesan, Anda dapat memeriksa jejak pesan di konsol ApsaraMQ for MQTT untuk memverifikasi hasil pesan. Untuk informasi lebih lanjut, lihat Kueri jejak pesan.