全部产品
Search

搜索本产品

    ApsaraMQ for RocketMQ：Contoh kode

    文档中心

    ApsaraMQ for RocketMQ：Contoh kode

    更新时间：Jul 02, 2025

    Topik ini menjelaskan contoh kode untuk mengirim dan menerima pesan menggunakan Apache RocketMQ 5.x SDK for Python.

    Tipe pesan

    Contoh kode untuk mengirim pesan

    Contoh kode untuk menerima pesan

    Pesan normal

    simple_consumer_example.py

    Pesan terurut

    fifo_producer_example.py

    Pesan terjadwal dan tertunda

    delay_producer_example.py

    Pesan transaksional

    transaction_producer_example.py

    Parameter

    Parameter

    Contoh

    Deskripsi

    endpoints

    rmq-cn-xxx.{regionId}.rmq.aliyuncs.com:8080

    Titik akhir dari instance ApsaraMQ for RocketMQ. Untuk informasi tentang cara memperoleh titik akhir, lihat Memperoleh titik akhir sebuah instance.

    • Jika Anda mengakses instance melalui Internet, tentukan titik akhir publik.

    • Jika Anda mengakses instance di dalam VPC, tentukan titik akhir VPC.

    InstanceId

    rmq-cn-xxx

    ID dari instance ApsaraMQ for RocketMQ.

    topic

    normal_test

    Topik ke mana pesan dikirim atau dari mana pesan dikonsumsi dalam instance ApsaraMQ for RocketMQ.

    Anda harus membuat topik pada instance ApsaraMQ for RocketMQ terlebih dahulu. Untuk informasi lebih lanjut, lihat Membuat topik.

    consumer-group

    GID_test

    Grup konsumen yang digunakan oleh konsumen untuk mengonsumsi pesan dalam instance ApsaraMQ for RocketMQ.

    Anda harus membuat grup konsumen pada instance ApsaraMQ for RocketMQ terlebih dahulu. Untuk informasi lebih lanjut, lihat Membuat grup konsumen.

    ak

    1XVg0hzgKm******

    Nama pengguna dari instance ApsaraMQ for RocketMQ. Jika Anda mengakses instance melalui Internet, Anda harus menentukan nama pengguna. Jika Anda mengakses instance di dalam VPC, Anda hanya perlu menentukan nama pengguna jika instance tersebut adalah instance serverless dan fitur tanpa autentikasi di VPC dinonaktifkan untuk instance tersebut.

    Untuk informasi tentang cara memperoleh nama pengguna, lihat Memperoleh nama pengguna dan kata sandi sebuah instance.

    sk

    ijSt8rEc45******

    Kata sandi dari instance ApsaraMQ for RocketMQ. Jika Anda mengakses instance melalui Internet, Anda harus menentukan kata sandi. Jika Anda mengakses instance di dalam VPC, Anda hanya perlu menentukan kata sandi jika instance tersebut adalah instance serverless dan fitur tanpa autentikasi di VPC dinonaktifkan untuk instance tersebut.

    Untuk informasi tentang cara memperoleh kata sandi, lihat Memperoleh nama pengguna dan kata sandi sebuah instance.

    Deskripsi untuk mengakses instance serverless melalui Internet

    Untuk mengakses instance ApsaraMQ for RocketMQ serverless melalui Internet guna mengirim dan menerima pesan, Anda perlu menambahkan informasi berikut dalam kode pesan Anda:

    Catatan

    Ganti InstanceId dengan ID instance ApsaraMQ for RocketMQ Anda.

    config = ClientConfiguration(endpoints, credentials, "InstanceId")

    Referensi