ApsaraMQ for MQTT:Jalankan demo cloud SDK

Prasyarat

Sebelum memulai, pastikan Anda telah:

• IntelliJ IDEA Ultimate Edition atau Eclipse terinstal

• JDK 1.8 atau versi lebih baru terinstal

• Instans ApsaraMQ for MQTT, topik, dan group yang telah dibuat di Konsol

• Pasangan AccessKey (ID AccessKey dan Rahasia AccessKey) untuk Pengguna Resource Access Management (RAM)

• Titik akhir instans ApsaraMQ for MQTT Anda

Kelas sampel

Proyek demo berisi tiga kelas:

Langkah 1: Unduh dan impor demo

1. Klon atau unduh demo dari mqtt-server-sdk-demo. Setelah diekstraksi, folder mqtt-server-sdk-demo-main berisi kode contoh di:

      java-demo\src\main\java\com\aliyun\openservices\lmq\example

2. Buka IntelliJ IDEA dan impor proyek mqtt-server-sdk-demo-main.

Langkah 2: Konfigurasikan parameter koneksi

Buka kelas contoh dan ganti parameter berikut dengan informasi resource Anda:

// Titik akhir instans ApsaraMQ for MQTT Anda.
// Untuk format titik akhir, lihat Parameter umum.
String domain = "<your-instance-endpoint>";

// Port Cloud SDK. Nilai tetap: 5672.
int port = 5672;

// ID instans ApsaraMQ for MQTT Anda.
String instanceId = "<your-instance-id>";

// ID AccessKey dan Rahasia AccessKey Pengguna RAM Anda.
String accessKey = "<your-access-key-id>";
String secretKey = "<your-access-key-secret>";

// Topik induk yang dibuat di Konsol untuk pengiriman pesan.
String firstTopic = "<your-parent-topic>";

// Subtopik. Tidak perlu dibuat di Konsol.
// Untuk konvensi penamaan, lihat Istilah.
String secondTopic = "<your-subtopic>";

// ID group yang dibuat di Konsol untuk pengiriman pesan.
String mqttGroupId = "<your-group-id>";

Tabel berikut menjelaskan setiap parameter:

Langkah 3: Jalankan demo

Setelah mengonfigurasi parameter, klik kanan kelas contoh di IntelliJ IDEA dan jalankan fungsi main().

Verifikasi hasil

Kueri jejak pesan di Konsol ApsaraMQ for MQTT untuk memastikan pesan telah dikirim dan diterima. Untuk petunjuknya, lihat Kueri jejak pesan.