消息队列RocketMQ版：定时消息通知功能体验

消息队列RocketMQ版：定时消息通知功能体验

​

1. 实验资源方式简介及开始实验

云起实验室实验资源方式介绍

本实验支持实验资源体验一种实验资源方式。

• 实验资源体验

• • 资源归属于客户，仅供本次实验使用
    
  • 实验结束后，实验资源及实验记录将被释放。
    
  • 资源创建过程需要3～5分钟（视资源不同开通时间有所差异，ACK等资源开通时间较长）。完成实验资源的创建后，在实验室页面左侧导航栏中，单击云产品资源列表，可查看本次实验资源相关信息（例如子用户名称、子用户密码、AK ID、AK Secret、资源中的项目名称等）。
    
  • 说明：实验环境一旦开始创建则进入计时阶段，建议学员先基本了解实验具体的步骤、目的，真正开始做实验时再进行创建。
    

准备开始实验

在实验开始前，请您选择实验资源体验，单击确认开启实验。

说明：每个实验所支持的实验资源方式都不相同，实验不一定能满足有三种实验资源方式，请根据实验的实际情况，进行选择。

2. 创建RocketMQ Topic、Group资源

本步骤将指导您在RocketMQ实例上创建用于收发消息的Topic和Group资源。

1. 在实验室页面右侧功能栏中，单击 图标，切换至远程桌面。
   
2. 双击打开远程桌面的Chronmium网页浏览器。
   
3. 在RAM用户登录框中单击下一步，并复制粘贴页面左上角的子用户密码到用户密码输入框，单击登录。
   
4. 复制下方地址，在Chromium网页浏览器打开新页签，粘贴并访问消息队列RocketMQ版控制台。
   

https://ons.console.aliyun.com/overview

1. 在左侧导航栏中，单击实例列表。
   

1. 在实例列表页面顶部菜单栏中，切换到资源所在地域。
   

说明：您可在云产品资源列表中查看消息队列RocketMQ版资源所在地域。

1. 在实例列表页面，找到实验室分配的消息队列RocketMQ版实例，单击实例ID。
   

说明：您可在云产品资源列表中查看消息队列RocketMQ版的实例ID。

1. 在左侧导航栏中，单击Topic管理。
   

1. 在Topic管理页面，单击创建Topic。
   

1. 在创建Topic面板，根据如下说明配置参数，然后单击确定。
   

• 主题名称：输入Topic名称，例如demo_topic。
  
• 消息类型：本实验是基本消息收发体验，请选择定时/延时消息。
  
• 描述：输文字描述，用于标识这个topic的作用，例如test。
  

1. 在左侧导航栏中，单击Group管理。
   

1. 在Group管理页面，单击创建Group。
   

1. 在创建Group面板，根据如下说明配置参数，然后单击确定。
   

• GroupID：输入Group名称，例如demo_group。
  
• 投递顺序性：本实验是基本消息收发体验，请选择并发投递。
  
• 描述：输文字描述，用于标识这个group的作用，例如test。
  

3. 登录云服务器ECS，体验定时消息收发程序

本步骤将指导您如何体验定时消息收发程序。

1. 在实验室页面右侧功能栏中，单击 图标，切换至远程桌面。
   

1. 执行如下命令，运行定时消息收发程序，为降低体验复杂度，该程序中同时集成了生产和消费的业务逻辑。
   

说明：在本实验中，已在云服务器ECS中为您准备好Demo代码。

java -cp demo.jar -Dendpoints=xxx:8080  -Dtopic=xxx -Dgroup=xxx -DdelaySecond=xxx -Dnum=xxx workshop.DelayMessageDemo

其中，命令中的部分参数需要根据测试的实例资源的实际信息输入。

预期的输出结果如下。

1. 根据上述运行步骤，可以看出消息队列RocketMQ版支持发送任意延迟间隔的定时消息，消息并不会立即投递，而是在指定时间间隔到达后才会投递到消费方。这个功能广泛应用于订单超时、定时调度等生产业务场景。
   

实验链接：https://developer.aliyun.com/adc/scenario/e30d9a21d701465db857709c0feec4ce