本文介紹Apache RocketMQ Go SDK的訊息收發範例程式碼。
訊息類型 | 發送訊息範例程式碼 | 訂閱訊息範例程式碼（SimpleConsumer） |
參數說明
參數 | 樣本值 | 描述 |
Endpoint | rmq-cn-xxx.{regionId}.rmq.aliyuncs.com:8080 | 雲訊息佇列 RocketMQ 版執行個體的存取點。擷取方式，請參見擷取執行個體存取點。
|
InstanceId | rmq-cn-xxx | 雲訊息佇列 RocketMQ 版執行個體ID。 |
Topic | normal_test | 雲訊息佇列 RocketMQ 版的Topic，用於指定生產者將訊息發送到哪個Topic，或者指定消費者要消費哪個Topic的訊息。 Topic需要提前在雲訊息佇列 RocketMQ 版執行個體下建立。具體操作，請參見建立Topic。 |
ConsumerGroup | GID_test | 雲訊息佇列 RocketMQ 版的ConsumerGroup，用於指定消費者使用哪個消費者分組消費訊息。 Group需要提前在雲訊息佇列 RocketMQ 版執行個體下建立。具體操作，請參見建立ConsumerGroup。 |
AccessKey | 1XVg0hzgKm****** | 雲訊息佇列 RocketMQ 版執行個體的使用者名稱。公網訪問時，必須填寫執行個體的使用者名稱；VPC訪問時，若Serverless執行個體未開啟內網免身份識別功能，則也必須填寫執行個體的使用者名稱。 擷取方式，請參見擷取執行個體使用者名稱密碼。 |
SecretKey | ijSt8rEc45****** | 雲訊息佇列 RocketMQ 版執行個體的使用者密碼。公網訪問時，必須填寫執行個體的使用者密碼；VPC訪問時，若Serverless執行個體未開啟內網免身份識別功能，則也必須填寫執行個體的使用者密碼。 擷取方式，請參見擷取執行個體使用者名稱密碼。 |
Serverless版執行個體公網訪問說明
使用公網訪問接入雲訊息佇列 RocketMQ 版Serverless執行個體時，需要在訊息收發代碼中補充如下內容：
其中，InstanceId需要替換為您實際使用的執行個體ID。
生產者
producer, err := rmq_client.NewProducer(&rmq_client.Config{
Endpoint: Endpoint,
NameSpace: "InstanceId",
Credentials: &credentials.SessionCredentials{
AccessKey: AccessKey,
AccessSecret: SecretKey,
},
},消費者
simpleConsumer, err := rmq_client.NewSimpleConsumer(&rmq_client.Config{
Endpoint: Endpoint,
ConsumerGroup: ConsumerGroup,
NameSpace: "InstanceId",
Credentials: &credentials.SessionCredentials{
AccessKey: AccessKey,
AccessSecret: SecretKey,
},
},