All Products
Search

This Product

    ApsaraMQ for RocketMQ:Sample code

    Document Center

    ApsaraMQ for RocketMQ:Sample code

    Last Updated:Mar 05, 2025

    This topic describes the sample code for sending and receiving messages by using the Apache RocketMQ SDK for Go.

    Message type

    Sample code for sending messages

    Sample code for receiving messages (SimpleConsumer)

    Normal messages

    ExampleSimpleConsumer.go

    Ordered messages

    ExampleProducerWithFifoMessage.go

    Scheduled and delayed messages

    ExampleProducerDelayMessage.go

    Transactional messages

    ExampleProducerWithTransactionalMessage.go

    Parameters

    Parameter

    Example

    Description

    Endpoint

    rmq-cn-xxx.{regionId}.rmq.aliyuncs.com:8080

    The endpoint of the ApsaraMQ for RocketMQ instance. For information about how to obtain the endpoint, see Obtain the endpoint of an instance.

    • If you access the instance over the Internet, specify the public endpoint.

    • If you access the instance in a VPC, specify the VPC endpoint.

    InstanceId

    rmq-cn-xxx

    The ID of the ApsaraMQ for RocketMQ instance.

    Topic

    normal_test

    The topic to which messages are sent or from which messages are consumed in the ApsaraMQ for RocketMQ instance.

    You must create the topic on the ApsaraMQ for RocketMQ instance in advance. For more information, see Create a topic.

    ConsumerGroup

    GID_test

    The consumer group that is used by consumers to consume messages in the ApsaraMQ for RocketMQ instance.

    You must create the consumer group on the ApsaraMQ for RocketMQ instance in advance. For more information, see Create a consumer group.

    AccessKey

    1XVg0hzgKm******

    The username of the ApsaraMQ for RocketMQ instance. If you access the instance over the Internet, you must specify the username. If you access the instance in a VPC, you need to specify the username only if the instance is a serverless instance and the authentication-free in VPCs feature is disabled for the instance.

    For information about how to obtain the username, see Obtain the username and password of an instance.

    SecretKey

    ijSt8rEc45******

    The password of the ApsaraMQ for RocketMQ instance. If you access the instance over the Internet, you must specify the password. If you access the instance in a VPC, you need to specify the password only if the instance is a serverless instance and the authentication-free in VPCs feature is disabled for the instance.

    For information about how to obtain the password, see Obtain the username and password of an instance.

    Description for accessing serverless instances over the Internet

    If you access a serverless ApsaraMQ for RocketMQ instance over the Internet to send and receive messages, you must add the following information in the messaging code:

    Note

    Replace InstanceId with the ID of your ApsaraMQ for RocketMQ instance.

    Producers

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

    Consumers

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