全部产品
Search

搜索本产品

    ApsaraMQ for RocketMQ：Kode contoh

    文档中心

    ApsaraMQ for RocketMQ：Kode contoh

    更新时间：Jan 10, 2026

    Topik ini menyediakan kode contoh untuk mengirim dan menerima pesan menggunakan kit pengembangan perangkat lunak (SDK) Python untuk ApsaraMQ for RocketMQ versi 5.x.

    Message type

    Sample code for sending messages

    Sample code for subscribing to messages

    Push consumer

    Simple consumer

    Normal messages

    None

    simple_consumer_example.py

    Ordered messages

    fifo_producer_example.py

    Scheduled and delayed messages

    delay_producer_example.py

    Transactional messages

    transaction_producer_example.py

    Lite messages

    lite_producer_example.py

    lite_push_consumer_example.py

    None

    Parameters

    Parameter

    Example value

    Description

    endpoints

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

    Titik akhir instans ApsaraMQ for RocketMQ. Untuk informasi tentang cara mendapatkan titik akhir, lihat Get the instance endpoint.

    • Jika Anda mengakses instans melalui Internet, tentukan Titik akhir publik.

    • Jika Anda mengakses instans dalam VPC, tentukan titik akhir VPC.

    InstanceId

    rmq-cn-xxx

    ID instans ApsaraMQ for RocketMQ.

    topic

    normal_test

    Topik tempat pesan dikirim atau dikonsumsi pada instans ApsaraMQ for RocketMQ.

    Anda harus membuat topik tersebut terlebih dahulu pada instans ApsaraMQ for RocketMQ. Untuk informasi selengkapnya, lihat Create a topic.

    consumer-group

    GID_test

    Kelompok konsumen yang digunakan oleh konsumen untuk mengonsumsi pesan pada instans ApsaraMQ for RocketMQ.

    Anda harus membuat kelompok konsumen tersebut terlebih dahulu pada instans ApsaraMQ for RocketMQ. Untuk informasi selengkapnya, lihat Create a consumer group.

    ak

    1XVg0hzgKm******

    Username instans ApsaraMQ for RocketMQ. Jika Anda mengakses instans melalui Internet, Anda harus menentukan username. Jika Anda mengakses instans dalam VPC, Anda hanya perlu menentukan username jika instans tersebut merupakan instans arsitektur tanpa server dan fitur authentication-free in VPCs dinonaktifkan untuk instans tersebut.

    Untuk informasi tentang cara mendapatkan username, lihat Get the instance username and password.

    sk

    ijSt8rEc45******

    Password instans ApsaraMQ for RocketMQ. Jika Anda mengakses instans melalui Internet, Anda harus menentukan password. Jika Anda mengakses instans dalam VPC, Anda hanya perlu menentukan password jika instans tersebut merupakan instans arsitektur tanpa server dan fitur authentication-free in VPCs dinonaktifkan untuk instans tersebut.

    Untuk informasi tentang cara mendapatkan password, lihat Get the instance username and password.

    Public network access for serverless instances

    Untuk mengakses instans arsitektur tanpa server ApsaraMQ for RocketMQ melalui jaringan publik, tambahkan konten berikut ke dalam kode messaging Anda:

    Catatan

    Ganti InstanceId dengan ID instans aktual Anda.

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

    Related documents