-
状态码 - 分布式消息服务RocketMQ版
与地址的列表用于用户终端(例如:浏览器)选择。 301 Moved Permanently 永久移动,请求的资源已被永久的移动到新的URI,返回信息会包括新的URI。 302 Found 资源被临时移动。 303 See Other 查看其它地址。 使用GET和POST请求查看。
-
查询指定实例 - 分布式消息服务RocketMQ版
namesrv_address String 元数据地址。 broker_address String 业务数据地址。 public_namesrv_address String 公网元数据地址。 public_broker_address String 公网业务数据地址。 grpc_address
-
删除RocketMQ消费组 - 分布式消息服务RocketMQ版
选择以下任意一种方法删除消费组。 在待删除的消费组所在行,单击“删除”。 单击待删除的消费组名称,进入消费组详情页面。在页面右上角,单击“删除”。 如需批量删除消费组,勾选待删除的消费组,单击“删除消费组”。 单击“确定”,确认删除消费组。 父主题: 管理消费组
-
修改RocketMQ消费组配置 - 分布式消息服务RocketMQ版
是否设置为广播消费。 若开启广播消费,每条消息都会被消费组内的所有消费者消费一次。否则,每条消息只会被消费组内的某一消费者消费。 是否顺序消费 RocketMQ实例的版本为5.x时,需要设置此参数。 开启顺序消费后,消费者将顺序消费消息。 描述 消费组的描述信息。 修改完成后,单击“确定”。 父主题:
-
快速入门 - 分布式消息服务RocketMQ版
name:实例名称,由您自行定义。 engine:消息引擎,设置为reliability。 engine_version:消息引擎的版本。 storage_space:消息存储空间,单位MB。具体取值范围,请参考创建实例。 vpc_id:RocketMQ实例所在的VPC(虚拟私有云)的ID。您可
-
查看RocketMQ消息 - 分布式消息服务RocketMQ版
务端向生产者进行消息回查。 生产耗时 生产者发送消息的耗时。 生产地址 生产者的IP地址和端口号。 消费者状态 消费者状态如下: 消费成功 消费超时 消费异常 消费返回NULL 消费失败 消费时间 消费消息的时间。 消费耗时 消费者消费消息的耗时。 消费地址 消费者的IP地址和端口号。
-
使用控制台连接RocketMQ - 分布式消息服务RocketMQ版
ocketMQ实例,验证业务逻辑是否正常。 前提条件 仅在实例的“状态”为“运行中”时,才可以在Topic中生产消息。 操作步骤 登录管理控制台。 在管理控制台左上角单击,选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件 > 分布式消息
-
实现订阅关系一致 - 分布式消息服务RocketMQ版
g1。 订阅关系一致性保证了同一个消费组中消费者的正常运行,避免消息逻辑混乱和消息丢失。在实际使用中,生产者端要做好消息的分类,便于消费者可以使用Tag进行消息的准确订阅。而在消费者端,则要保证订阅关系的一致性。 错误的订阅关系 同一消费组下的消费者订阅了不同的Topic 例如,
-
变更RocketMQ实例计费模式为包周期 - 分布式消息服务RocketMQ版
变更RocketMQ实例计费模式为包周期 选择按需付费的用户,可以选择“转包周期”,变更实例计费模式为包年/包月。 公测实例与商用实例存在差距,公测实例不推荐用于商用业务,公测实例不支持转包周期,建议已有公测实例的用户删除公测实例,购买新的商用实例。 包周期转按需的操作请参见包年/包月转按需。 操作步骤
-
按需转包年/包月 - 分布式消息服务RocketMQ版
分布式消息服务RocketMQ版”。 通过以下任意一种方法,实现按需实例转包周期。 勾选RocketMQ实例名称左侧的方框,可选一个或多个,单击信息栏左上侧的“转包周期”,弹出“转包周期”对话框,单击“是”,跳转到“按需转包年/包月”页面。 在待转包周期的RocketMQ实例所在行,单击“更多 > 转包周期”,跳转到“按需转包年/包月”页面。
-
RocketMQ业务使用流程 - 分布式消息服务RocketMQ版
使用RocketMQ实例生产消费消息的流程如下图所示。 图1 RocketMQ业务使用流程 创建用户并授权使用DMS for RocketMQ 创建IAM用户,并授予DMS for RocketMQ的权限,以达到用户之间权限的隔离。 购买RocketMQ实例 RocketMQ实例采用物理隔离的方式部署,租户独占RocketMQ实例。
-
配置RocketMQ实例标签 - 分布式消息服务RocketMQ版
单击“确定”,成功为实例添加标签。 删除标签 通过以下任意一种方法,删除标签。 在待删除的标签所在行,单击“删除”,弹出“删除标签”对话框。单击“是”,完成标签的删除。 单击“创建/删除标签”,弹出“创建/删除标签”对话框。在待删除的标签后,单击,然后单击“确定”,完成标签的删除。 父主题: 管理实例
-
收发普通消息 - 分布式消息服务RocketMQ版
收发消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发普通消息前,需要确保Topic的消息类型为“普通”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为5.0.5。 使用Maven方式引入依赖。
-
收发普通消息 - 分布式消息服务RocketMQ版
SetKeys:输入消息的Key。 SetTag:输入消息的Tag。 异步发送 异步发送是指消息发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息的通讯方式。 使用异步发送需要客户端实现异步发送回调接口(SendCallback)。即消息发送方在发送了一条消息后,不需要等待
-
查看RocketMQ Topic详情 - 分布式消息服务RocketMQ版
tMQ专享版页面。 单击RocketMQ实例的名称,进入实例详情页面。 在左侧导航栏,单击“Topic管理”,进入“Topic管理”页面。 RocketMQ实例4.8.0版本:单击待查询的Topic名称,或者在待查询的Topic所在行,单击“更多 > 查看详情”,进入Topic详情页面。RocketMQ实例5
-
开启RocketMQ消息轨迹 - 分布式消息服务RocketMQ版
查询消息轨迹前,需要先在客户端开启消息轨迹。 本章节介绍使用Java和Go开启消息轨迹的方法。 前提条件 生产者Java客户端版本在4.9.0以上才支持事务消息的轨迹,如果版本不满足要求,请先升级。 开启SSL的RocketMQ实例,生产者和消费者的Java客户端版本在4.9.2以上才支持消息轨迹,如果版本不满足要求,请先升级。
-
查看RocketMQ审计日志 - 分布式消息服务RocketMQ版
Service,CTS)服务,您可以记录与分布式消息服务RocketMQ版相关的操作事件,便于日后的查询、审计和回溯。 前提条件 已开通CTS。 CTS支持的DMS for RocketMQ操作 表1 云审计服务支持的分布式消息服务RocketMQ版操作列表 操作名称 资源类型 事件名称
-
版本支持公告 - 分布式消息服务RocketMQ版
- - EOM:End of Marketing,停止该版本的销售。 EOS:End of Service & support,停止该版本的服务,建议您在执行作业时选择最新版本的引擎。在该日期之后,不再提供该软件版本的任何技术服务支持。 父主题: 版本公告
-
重置RocketMQ消费进度 - 分布式消息服务RocketMQ版
Topic名称 选择待重置消费进度的Topic。 时间 选择重置消费进度的时间点,重置完成后,将从此时间点开始消费。 自定义:自定义时间点 最早:最早偏移量 最晚:最晚偏移量 单击“确定”,弹出“重置消费进度确认”对话框。 单击“是”,完成消费进度的重置。 父主题: 管理消费组
-
配置RocketMQ ACL用户 - 分布式消息服务RocketMQ版
参数 说明 名称 自定义用户名称,用于识别不同的用户。 用户名创建成功后,不可修改。 IP白名单 如果请求的来源IP为IP白名单中的地址,不需要校验用户密钥是否正确,且具有所有Topic和消费组的发布+订阅权限。 IP白名单可以配置为具体的IP地址,也可以配置为网段。如:192.168