Bu konuda, C# için Apache RocketMQ 5.x SDK kullanarak mesaj gönderme ve alma işlemlerine yönelik örnek kodlar açıklanmaktadır.
Önkoşullar
Başlamadan önce aşağıdaki ön koşulları karşıladığınızdan emin olun:
Uç noktası alınmış bir ApsaraMQ for RocketMQ örneği. Daha fazla bilgi için bkz. Örnek uç noktasını alma
Örnek üzerinde oluşturulmuş bir konu ve bir tüketici grubu
Hazır bir C# geliştirme ortamı. Daha fazla bilgi için bkz. Ortam hazırlığı
(Koşullu) Örneğe İnternet üzerinden erişiyorsanız veya örnek, VPC'lerde kimlik doğrulamasız erişimi devre dışı bırakılmış bir sunucusuz örnekse örnek kullanıcı adı ve parolası alınmalıdır
Örnek koda genel bakış
Parametreler
Tüm örnek kodlardaki aşağıdaki yer tutucuları gerçek değerlerinizle değiştirin:
| Parametre | Örnek | Açıklama |
|---|---|---|
Endpoint |
rmq-cn-xxx.{regionId}.rmq.aliyuncs.com:8080 |
|
InstanceId |
rmq-cn-xxx |
|
topic |
normal_test |
|
consumerGroup |
GID_test |
|
AccessKey |
1XVg0hzgKm****** |
|
SecretKey |
ijSt8rEc45****** |
|
Sunucusuz örneklere İnternet üzerinden erişme
Sunucusuz bir ApsaraMQ for RocketMQ örneğine İnternet üzerinden erişmek için istemci yapılandırmasına SetNamespace ekleyin ve değerini örnek kimliğiniz olarak ayarlayın:
InstanceId yerine gerçek örnek kimliğinizi yazın.
var clientConfig = new ClientConfig.Builder()
.SetEndpoints(endpoints)
.SetNamespace("<your-instance-id>") // Replace with your actual instance ID, for example, rmq-cn-xxx.
.SetCredentialsProvider(credentialsProvider)
.Build();