消息队列RocketMQ版：定时消息通知功能体验-阿里云开发者社区

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

2023-09-16 668

版权

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

简介： 本实验场景介绍消息队列RocketMQ版的定时（延时）消息收发功能，体验发送若干条自定义延迟触发的消息，观察消息是否按照预期的投递时间投递。

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

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

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

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

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

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

2. 创建RocketMQ Topic、Group资源

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

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

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

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

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

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

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

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

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

参数	说明
-Dendpoints	实例接入点信息。在RocketMQ控制台>实例详情>TPC协议接入点>VPC专有网络的接入点信息中查看。在本实验中，为了方便用户的操作，您可在云产品资源列表中查到VPC专有网络的接入点信息。 VPC专有网络的接入点信息格式一般为rmq-cn-{xxx}-vpc.cn-{xxx}.rmq.aliyuncs.com:8080。说明：您可在云产品资源列表中查看VPC接入点信息，复制粘贴即可。
-Dtopic	实际发送的主题名称，输入步骤二创建的Topic名称。
-Dgroup	实际订阅消费使用的消费者分组，输入步骤二创建的Group名称。
-DdelaySecond	输入希望延迟触发的时间间隔，单位是秒。例如希望发送延迟10秒的消息，则输入10，最小支持5秒，最长支持86400秒。
-Dnum	输入希望发送的消息条数，例如10，代表10条消息。