检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
分布式消息服务RocketMQ版 开源RocketMQ 延迟消息/定时消息 延迟消息:支持18个固定延迟时长,最长延迟2小时。 定时消息:支持任意延迟时长,最长延迟1年。 仅支持18个固定延迟时长,最长延迟2小时。 顺序消息 支持 支持 消息重试 支持 支持 死信消息 支持 支持 集群消费
RocketMQ实例状态为“运行中”。 在云服务控制台转按需 登录管理控制台。 单击左侧导航栏的图标,选择“应用中间件 > 分布式消息服务RocketMQ版”。 通过以下任意一种方法,设置包年/包月资源到期后转按需。 在需要更改计费模式的RocketMQ实例所在行,单击操作列“更多 > 到期转按需”。 勾选Ro
etMQ专享版页面。 单击RocketMQ实例的名称,进入实例详情页面。 在左侧导航栏,单击“消费组管理”,进入消费组列表页面。 选择以下任意一种方法修改消费组参数。 在待修改的消费组所在行,单击“编辑”,弹出“编辑消费组”页面。 单击待修改的消费组名称,进入消费组详情页面。在页
版页面。 单击RocketMQ实例的名称,进入实例详情页面。 在左侧导航栏,单击“Topic管理”,进入“Topic管理”页面。 选择以下任意一种方法修改Topic参数。 在待修改的Topic所在行,单击“编辑”,弹出“编辑Topic”页面。 单击待修改的Topic名称,进入To
在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务RocketMQ版”,进入分布式消息服务RocketMQ专享版页面。 选择以下任意一种方法删除按需的RocketMQ实例。 在待删除的RocketMQ实例所在行,单击“更多 > 删除”。 单击待删除的RocketMQ实例
RocketMQ实例状态为“运行中”。 操作步骤 登录管理控制台。 单击左侧导航栏的图标,选择“应用中间件 > 分布式消息服务RocketMQ版”。 通过以下任意一种方法,实现按需实例转包周期。 勾选RocketMQ实例名称左侧的方框,可选一个或多个,单击信息栏左上侧的“转包周期”,弹出“转包周期”
etMQ专享版页面。 单击RocketMQ实例的名称,进入实例详情页面。 在左侧导航栏,单击“死信队列”,进入“死信队列”页面。 选择以下任意一种方法,查询死信消息。 按Group查询:“Group”选择待查询消费组的名称,“存储时间”选择待查询死信消息的时间段,单击“查询”。 按Message
导出Topic或者消费组列表:单击“导出 > 导出全部数据到XLSX”/“导出 > 导出已选中数据到XLSX”。 删除Topic或者消费组:选择以下任意一种方法进行删除。 在待删除的Topic或者消费组所在行,单击“删除”。 勾选需要删除的Topic或者消费组,单击左上角的“批量删除”。 通过用户访问服务端
建议将访问DMS for RocketMQ实例方式设置为密码访问(即开启ACL访问控制),防止未经认证的客户端误操作实例。 您可以选择如下任意一种方法开启ACL访问控制。 在“购买实例”页面开启ACL访问控制,具体可参考购买RocketMQ实例。 购买实例后,在实例的“基本信息”
开启RocketMQ消息轨迹(Go) 在客户端开启消息轨迹的方法如下: 执行以下命令,检查是否已安装Go。 go version 返回如下回显时,说明Go已经安装。 [root@ecs-test sarama]# go version go version go1.16.5 linux/amd64
长度为1~128个字符(中文也可以输入128个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + - @ 首尾字符不能为空格。 value String 标签值。 长度为0~255个字符(中文也可以输入255个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_
用时间。 在云服务控制台续费 登录管理控制台。 单击左侧导航栏的图标,选择“应用中间件 > 分布式消息服务RocketMQ版”。 通过以下任意一种方法,为RocketMQ实例续费。 勾选RocketMQ实例名称左侧的方框,可选一个或多个,单击信息栏左上侧的“续费”,弹出“续费”对话框,单击“是”,跳转到“续费”页面。
消息类型为“事务”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖: 使用Maven方式引入依赖。 <dependency> <groupId>org.apache.rocketmq</groupId>
长度为1~128个字符(中文也可以输入128个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + - @ 首尾字符不能为空格。 value 否 String 标签值。 长度为0~255个字符(中文也可以输入255个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_
长度为1~128个字符(中文也可以输入128个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + - @ 首尾字符不能为空格。 value String 标签值。 长度为0~255个字符(中文也可以输入255个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_
长度为1~128个字符(中文也可以输入128个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + - @ 首尾字符不能为空格。 value String 标签值。 长度为0~255个字符(中文也可以输入255个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_
长度为1~128个字符(中文也可以输入128个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + - @ 首尾字符不能为空格。 value String 标签值。 长度为0~255个字符(中文也可以输入255个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_
消息类型为“顺序”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖: 使用Maven方式引入依赖。 <dependency> <groupId>org.apache.rocketmq</groupId>
tMQ版来收发消息的示例代码。 支持区域: 全部 收发普通消息 收发顺序消息 收发事务消息 定时消息 分布式消息服务RocketMQ版支持任意时间的定时消息,最大推迟时间可达到1年。同时也支持定时消息的取消。 定时消息即生产者生产消息到分布式消息服务RocketMQ版后,消息不会
定时消息:生产者生产消息到分布式消息服务RocketMQ版后,消息不会立即被消费,而是延迟到设定的时间点后才会发送给消费者进行消费。分布式消息服务RocketMQ版支持任意时间的定时消息,最大推迟时间可达到1年。同时也支持定时消息的取消。 2022年3月30日及以后购买的实例支持定时消息功能,在此之前购买的实例不支持此功能。