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

Bagian ini menjelaskan contoh kode untuk mengirim dan menerima pesan menggunakan Apache RocketMQ SDK for Go.

Jenis pesan	Contoh kode untuk mengirim pesan	Contoh kode untuk menerima pesan (SimpleConsumer)
Pesan normal	Pengiriman sinkron: ExampleProducerNormalMessage.go Pengiriman asinkron: AsyncExampleProducerNormalMessage.go	ExampleSimpleConsumer.go
Pesan terurut	ExampleProducerWithFifoMessage.go
Pesan terjadwal dan tertunda	ExampleProducerDelayMessage.go
Pesan transaksional	ExampleProducerWithTransactionalMessage.go

Parameter

Parameter	Contoh	Deskripsi
Titik akhir	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 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.
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 di 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.
SecretKey	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 bebas autentikasi dalam 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 perpesanan:

Catatan

Ganti InstanceId dengan ID instance ApsaraMQ for RocketMQ Anda.

Produsen

producer, err := rmq_client.NewProducer(&rmq_client.Config{
	Endpoint: Endpoint,
	NameSpace: "InstanceId",
	Credentials: &credentials.SessionCredentials{
		AccessKey:    AccessKey,
		AccessSecret: SecretKey,
	},
},

Konsumen

simpleConsumer, err := rmq_client.NewSimpleConsumer(&rmq_client.Config{
	Endpoint: Endpoint,
	ConsumerGroup: ConsumerGroup,
	NameSpace: "InstanceId",
	Credentials: &credentials.SessionCredentials{
		AccessKey:    AccessKey,
		AccessSecret: SecretKey,
	},
},