开发者如何使用云消息队列 RocketMQ 版-阿里云开发者社区

开发者如何使用云消息队列 RocketMQ 版

2024-10-22 5

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

Serverless 应用引擎 SAE，800核*时 1600GiB*时

性能测试 PTS，5000VUM额度

注册配置 MSE Nacos/ZooKeeper，118元/月

简介： 【10月更文挑战第12天】开发者如何使用云消息队列 RocketMQ 版

云消息队列 RocketMQ 版是阿里云基于 Apache RocketMQ 构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。它适用于各种应用场景，如异步通信、系统解耦、流量削峰等。

以下是如何在阿里云上使用 RocketMQ 的详细步骤，包括创建实例、配置生产者（Producer）和消费者（Consumer），并附上示例代码。

1. 创建阿里云 RocketMQ 实例

登录阿里云控制台：
打开阿里云官网，登录你的阿里云账号。在产品标签处找到云消息队列 RocketMQ 版。

创建消息队列 RocketMQ 实例：

在控制台首页，搜索“消息队列 RocketMQ”。

点击“创建实例”，选择实例版本，商品类型（serverless按累积量、按量付费、包年包月）。

配置实例的基本信息，如实例名称、地域、VPC 网络等。
完成支付并等待实例创建完成。

获取实例信息：

实例创建完成后，进入实例详情页面。
记录实例的接入点（Endpoint）、Namespace、Access Key ID 和 Access Key Secret。

2. 配置生产者（Producer）

生产者负责将消息发送到 RocketMQ。

2.1 引入依赖

如果你使用的是 Maven 项目，可以在 pom.xml 中添加以下依赖：

xml复制代码
<dependency>
<groupId>com.aliyun.openservices</groupId>
<artifactId>ons-client</artifactId>
<version>1.8.4.Final</version>
</dependency>

2.2 编写生产者代码

java复制代码
import com.aliyun.openservices.ons.api.ONSFactory;  
import com.aliyun.openservices.ons.api.Producer;  
import com.aliyun.openservices.ons.api.PropertyKeyConst;  
import com.aliyun.openservices.ons.api.SendResult;  
import com.aliyun.openservices.ons.api.exception.ONSClientException;  
public class RocketMQProducer {  
public static void main(String[] args) {  
// 阿里云 AccessKey ID 和 AccessKey Secret  
String accessKeyId = "yourAccessKeyId";  
String accessKeySecret = "yourAccessKeySecret";  
// 阿里云 RocketMQ 实例的接入点  
String producerGroup = "yourProducerGroup";  
String onsAddr = "yourOnsAddr"; // 例如：http://onsaddr-internet.aliyun.com/rocketmq/onsaddr4client-internet  
// 创建生产者实例  
Producer producer = ONSFactory.createProducer(producerGroup, onsAddr,  
new PropertyKeyConst.ProducerIdKey(accessKeyId),  
new PropertyKeyConst.SecretKeyKey(accessKeySecret));  
try {  
// 启动生产者实例  
            producer.start();  
// 发送消息  
for (int i = 0; i < 10; i++) {  
String topic = "yourTopic";  
String tags = "yourTag";  
String key = "yourKey" + i;  
String body = "Hello RocketMQ " + i;  
SendResult sendResult = producer.send(new com.aliyun.openservices.ons.api.message.Message(topic, tags, key, body.getBytes()));  
                System.out.printf("%s%n", sendResult);  
            }  
// 关闭生产者实例  
            producer.shutdown();  
        } catch (ONSClientException e) {  
            e.printStackTrace();  
        }  
    }  
}

3. 配置消费者（Consumer）

消费者负责从 RocketMQ 接收消息。

3.1 引入依赖

同样，在 pom.xml 中添加依赖：

xml复制代码
<dependency>
<groupId>com.aliyun.openservices</groupId>
<artifactId>ons-client</artifactId>
<version>1.8.4.Final</version>
</dependency>

3.2 编写消费者代码

java复制代码
import com.aliyun.openservices.ons.api.ONSFactory;  
import com.aliyun.openservices.ons.api.Consumer;  
import com.aliyun.openservices.ons.api.PropertyKeyConst;  
import com.aliyun.openservices.ons.api.MessageListener;  
import com.aliyun.openservices.ons.api.exception.ONSClientException;  
public class RocketMQConsumer {  
public static void main(String[] args) {  
// 阿里云 AccessKey ID 和 AccessKey Secret  
String accessKeyId = "yourAccessKeyId";  
String accessKeySecret = "yourAccessKeySecret";  
// 阿里云 RocketMQ 实例的接入点  
String consumerGroup = "yourConsumerGroup";  
String onsAddr = "yourOnsAddr"; // 例如：http://onsaddr-internet.aliyun.com/rocketmq/onsaddr4client-internet  
// 创建消费者实例  
Consumer consumer = ONSFactory.createConsumer(consumerGroup, onsAddr,  
new PropertyKeyConst.ConsumerIdKey(accessKeyId),  
new PropertyKeyConst.SecretKeyKey(accessKeySecret));  
try {  
// 订阅主题和标签  
            consumer.subscribe("yourTopic", "*");  
// 注册消息监听器  
            consumer.registerMessageListener(new MessageListener() {  
@Override
public Action consume(com.aliyun.openservices.ons.api.message.Message message, ConsumeContext context) {  
                    System.out.printf("Receive New Messages: %s %n", new String(message.getBody()));  
return Action.CommitMessage;  
                }  
            });  
// 启动消费者实例  
            consumer.start();  
// 保持消费者运行  
            System.out.printf("Consumer Started.%n");  
        } catch (ONSClientException e) {  
            e.printStackTrace();  
        }  
    }  
}

4. 运行代码

配置环境：

确保你的阿里云账号有正确的权限。
确保你的 Maven 项目已经正确引入了依赖。

运行生产者：

运行 RocketMQProducer 类，它将发送消息到指定的 RocketMQ 主题。

运行消费者：

运行 RocketMQConsumer 类，它将接收并处理来自 RocketMQ 的消息。

5. 监控和管理

阿里云提供了丰富的监控和管理功能，你可以在 RocketMQ 实例详情页面查看消息队列的状态、消费情况、延迟等。

总结

通过以上步骤，你可以在阿里云上创建并使用 RocketMQ 实例，实现消息的发送和接收。RocketMQ 提供了高性能、高可靠的消息传递服务，适用于各种分布式系统架构。希望这个指南能帮助你快速上手阿里云 RocketMQ。