Contoh kode untuk mengirim dan menerima pesan menggunakan Apache RocketMQ SDK untuk C++ - ApsaraMQ for RocketMQ

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

Jenis pesan	Contoh kode untuk mengirim pesan	Contoh kode untuk menerima pesan
		PushConsumer	SimpleConsumer
Pesan normal	Sinkron: ExampleProducer.cpp Asinkron: ExampleProducerWithAsync.cpp	ExamplePushConsumer.cpp	ExampleSimpleConsumer.cpp
Pesan terurut	ExampleProducerWithFifoMessage.cpp
Pesan terjadwal dan tertunda	ExampleProducerWithTimedMessage.cpp
Pesan transaksional	ExampleProducerWithTransactionalMessage.cpp

Parameter

Parameter	Contoh	Deskripsi
access_point	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 dalam VPC, tentukan titik akhir VPC.
topic	normal_test	Topik tempat 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.
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.
access_key	1XVg0hzgKm******	Nama pengguna dari instance ApsaraMQ for RocketMQ. Jika Anda mengakses instance melalui Internet, Anda harus menentukan nama pengguna. Jika Anda mengakses instance dalam VPC, Anda hanya perlu menentukan nama pengguna jika instance tersebut adalah instance serverless dan fitur bebas autentikasi dalam VPC dinonaktifkan untuk instance tersebut. Untuk informasi tentang cara memperoleh nama pengguna, lihat Memperoleh nama pengguna dan kata sandi sebuah instance.
access_secret	ijSt8rEc45******	Kata sandi dari instance ApsaraMQ for RocketMQ. Jika Anda mengakses instance melalui Internet, Anda harus menentukan kata sandi. Jika Anda mengakses instance dalam VPC, Anda hanya perlu menentukan kata sandi jika instance tersebut adalah instance serverless dan fitur bebas autentikasi dalam VPC dinonaktifkan untuk instance tersebut. Untuk informasi tentang cara memperoleh kata sandi, lihat Memperoleh nama pengguna dan kata sandi sebuah instance.