Contoh kode untuk mengirim dan menerima pesan menggunakan Apache RocketMQ 5.x SDK untuk C# - ApsaraMQ for RocketMQ

Bagian 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
Pesan normal	ProducerNormalMessageExample.cs	SimpleConsumerExample.cs
Pesan terurut	ProducerFifoMessageExample.cs
Pesan terjadwal dan tertunda	ProducerDelayMessageExample.cs
Pesan transaksional	ProducerTransactionMessageExample.cs

Parameter

Parameter	Contoh	Deskripsi
Endpoint	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.
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.
consumerGroup	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.
AccessKey	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 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.
SecretKey	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 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

Jika Anda mengakses instance serverless ApsaraMQ for RocketMQ melalui Internet untuk mengirim dan menerima pesan, tambahkan informasi berikut dalam kode pesan:

Catatan

Ganti InstanceId dengan ID instance ApsaraMQ for RocketMQ Anda.

var clientConfig = new ClientConfig.Builder()
    .SetEndpoints(endpoints)
    .SetNamespace("InstanceId")
    .SetCredentialsProvider(credentialsProvider)
    .Build();