ApsaraMQ for RocketMQ：Langkah 3: Gunakan SDK untuk mengirim dan menerima pesan

Instal pustaka dependensi Java

1. Buat proyek Java di IntelliJ IDEA.

2. Tambahkan dependensi berikut ke file pom.xml untuk mengimpor pustaka dependensi Java:

   <dependency>
       <groupId>org.apache.rocketmq</groupId>
       <artifactId>rocketmq-client-java</artifactId>
       <version>5.0.7</version>
   </dependency>

Hasilkan pesan

Dalam proyek Java yang dibuat, buat program untuk mengirim pesan normal dan jalankan program tersebut. Contoh kode:

import org.apache.rocketmq.client.apis.*;
import org.apache.rocketmq.client.apis.message.Message;
import org.apache.rocketmq.client.apis.producer.Producer;
import org.apache.rocketmq.client.apis.producer.SendReceipt;

public class ProducerExample {
    public static void main(String[] args) throws ClientException {
        /**
         * Titik akhir dari instance. Anda dapat melihat titik akhir pada tab Endpoints halaman Detail Instance di konsol ApsaraMQ for RocketMQ.
         * Jika klien instance ApsaraMQ for RocketMQ ditempatkan pada instance ECS dan Anda ingin mengakses instance ApsaraMQ for RocketMQ dalam jaringan internal, kami sarankan Anda menentukan titik akhir VPC.
         * Jika Anda mengakses instance melalui Internet atau dari pusat data, Anda dapat menentukan titik akhir publik. Jika Anda mengakses instance melalui Internet, Anda harus mengaktifkan fitur akses Internet untuk instance tersebut.
         */
        String endpoints = "rmq-cn-xxx.{regionId}.rmq.aliyuncs.com:8080";
        // Nama topik tempat pesan dikirim. Sebelum Anda menggunakan topik untuk menerima pesan, Anda harus membuat topik tersebut di konsol ApsaraMQ for RocketMQ. Jika tidak, kesalahan akan dikembalikan.
        String topic = "Topik Anda";
        ClientServiceProvider provider = ClientServiceProvider.loadService();
        ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
                .setEndpoints(endpoints)
                /**
                 * Jika instance ApsaraMQ for RocketMQ adalah instance serverless dan Anda menggunakan titik akhir publik untuk mengakses instance, Anda harus menentukan ID instance.
                 */
                //.setNamespace("InstanceId")
                /**
                 * Jika Anda menggunakan titik akhir publik untuk mengakses instance ApsaraMQ for RocketMQ, Anda harus menentukan nama pengguna dan kata sandi instance. Anda dapat memperoleh nama pengguna dan kata sandi pada tab Otentikasi Cerdas halaman Kontrol Akses yang sesuai dengan instance di konsol ApsaraMQ for RocketMQ.
                 * Jika klien instance ApsaraMQ for RocketMQ ditempatkan pada instance ECS dan Anda ingin mengakses instance ApsaraMQ for RocketMQ dalam jaringan internal, Anda tidak perlu menentukan nama pengguna atau kata sandi. Broker secara otomatis mendapatkan nama pengguna dan kata sandi berdasarkan informasi VPC.
                 * Jika instance adalah instance ApsaraMQ for RocketMQ serverless, Anda harus menentukan nama pengguna dan kata sandi untuk mengakses instance melalui Internet. Jika Anda mengaktifkan fitur tanpa otentikasi di VPC untuk instance serverless dan mengakses instance dalam VPC, Anda tidak perlu menentukan nama pengguna atau kata sandi.
                 */
                //.setCredentialProvider(new StaticSessionCredentialsProvider("Instance UserName", "Instance Password"))
                .build();
        /**
         * Saat Anda menginisialisasi produser, Anda dapat menentukan topik yang ingin Anda gunakan untuk memeriksa apakah pengaturan topik valid dan mencegah topik tidak valid dimulai.
         * Anda tidak perlu menentukan topik untuk pesan non-transaksional. Broker secara dinamis memeriksa apakah topik valid.
         * Catatan: Untuk mencegah operasi API yang dipanggil untuk memeriksa pesan transaksional gagal, Anda harus menentukan topik untuk pesan transaksional sebelumnya.
         */
        Producer producer = provider.newProducerBuilder()
                .setTopics(topic)
                .setClientConfiguration(clientConfiguration)
                .build();
        // Kirim pesan normal.
        Message message = provider.newMessageBuilder()
                .setTopic(topic)
                // Kunci pesan. Anda dapat menggunakan kunci untuk mencari pesan.
                .setKeys("kunciPesan")
                // Tag pesan. Konsumen dapat menggunakan tag untuk memfilter pesan.
                .setTag("tagPesan")
                // Tubuh pesan.
                .setBody("isiPesan".getBytes())
                .build();
        try {
            // Kirim pesan. Perhatikan hasilnya dan tangkap pengecualian seperti kegagalan.
            SendReceipt sendReceipt = producer.send(message);
            System.out.println(sendReceipt.getMessageId());
        } catch (ClientException e) {
            e.printStackTrace();
        }
    }
}

Konsumsi pesan

Deskripsi versi untuk mengakses instance serverless melalui Internet

Hanya SDK versi tertentu yang dapat mengakses instance ApsaraMQ for RocketMQ serverless melalui Internet.

Parameter SDK

Verifikasi konsumsi pesan

Setelah Anda mengonsumsi pesan, Anda dapat memeriksa status konsumsi pesan tersebut di konsol ApsaraMQ for RocketMQ.

1. Masuk ke konsol ApsaraMQ for RocketMQ. Pada halaman Instances, klik nama instance yang ingin Anda kelola.

2. Di panel navigasi sisi kiri halaman yang muncul, klik Message Tracing.

Referensi SDK

Untuk informasi tentang cara menggunakan SDK untuk bahasa pemrograman lainnya untuk mengirim dan menerima pesan dari jenis lain, lihat Ikhtisar.