正在生成
详细信息:
检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
梳理消息的消费耗时需要注意以下几点: 消息消费逻辑的计算复杂度是否过高,代码是否存在复杂的递归和循环处理。 消息消费逻辑中的I/O操作是否是必须,是否可以使用本地缓存等方案规避。 消息消费逻辑中的复杂耗时操作是否可以做异步化处理。 设置消费并发度 对于消费并发度的计算,可以按如下方法进行处理:
是否支持自动创建Topic? RocketMQ实例不支持自动创建Topic。 父主题: Topic问题
RocketMQ实例的SSL开关是否支持修改? SSL开关支持修改,具体步骤请参考修改SSL。 父主题: 实例问题
RocketMQ是否支持自建Broker连接云上nameserver? 不支持。自建Broker连接到云上RocketMQ的nameserver,会影响管理面功能,导致查询不到Topic等问题。 父主题: 连接问题
诊断完成后,在“诊断记录”区域,新增一条诊断记录。 单击“查看报告”,进入“实例诊断”页面,查看诊断结果。 您可以查看到消费组状态是否在线、消费者数量、订阅关系是否一致和消息堆积量,并根据结果分析处理生产和消费消息时所遇到的问题。 图1 诊断结果 消费组不在线时,可以诊断成功,但是会显示1项异常。
主节点重启过程中,客户端的生产和消费请求会被拒绝,持续时间不超过30s,建议在业务量少时重启节点。重启备节点,不会影响业务的使用。 怎么判断哪个是主节点? 主节点为“Broker ID”显示“0”的节点。 图1 重启节点 仅在RocketMQ实例4.8.0版本支持重启节点,5.x版本不支持。
续费”,跳转到“续费”页面。 单击RocketMQ实例名称,进入实例详情页面。单击右上角的“续费”,跳转到“续费”页面。 选择RocketMQ实例的续费时长,判断是否勾选“统一到期日”,将RocketMQ实例到期时间统一到各个月的某一天(详细介绍请参见统一包年/包月资源的到期日)。确认配置费用后单击“去支付”。
跟唐老师学习云网络 唐老师将自己对网络的理解分享给大家 智能客服 您好!我是有问必答知识渊博的智能问答机器人,有问题欢迎随时求助哦! 社区求助 华为云社区是华为云用户的聚集地。这里有来自容器服务的技术牛人,为您解决技术难题。
晰,提高效率。可以根据如下几方面判断Topic和Tag的具体使用场景: 根据消息类型判断:RocketMQ的消息可分为普通消息、顺序消息、定时/延迟消息、事务消息,不同类型的消息需要用不同的Topic来区分,无法通过Tag区分。 根据消息优先级判断:在业务中紧急程度高和紧急程度一
x版本:单击RocketMQ实例名称,进入实例详情页面。单击右上角的“转包周期”,跳转到“按需转包年/包月”页面。 选择RocketMQ实例的购买时长,判断是否勾选“自动续费”,确认预计到期时间和配置费用后单击“去支付”。 图1 按需转包年/包月 进入支付页面,选择支付方式,确认付款,支付订单后即可完成按需转包年/包月。
ms:)仅适用于对应服务的操作。运算符与条件键一起使用,构成完整的条件判断语句。 DMS for RocketMQ通过IAM预置了一组条件键,例如,您可以先使用dms:ssl条件键检查RocketMQ实例是否开启SSL,然后再允许执行操作。下表显示了适用于DMS for RocketMQ服务特定的条件键。
在购买时会一次性付费,服务将在到期后自动停止使用。 如果在计费周期内不再使用包年/包月资源,您可以执行退订操作,系统将根据资源是否属于五天无理由退订、是否使用代金券和折扣券等条件返还一定金额到您的账户。详细的退订规则请参见云服务退订规则概览。需要注意,如果实例开启了回收站策略,包
连接信息。 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 准备环境 执行以下命令,检查是否已安装Go。 go version 返回如下回显时,说明Go已经安装。 go version go1.16.5 linux/amd64 如果未安装Go,请下载并安装。
消息对应的业务逻辑有时间窗口要求,如电商交易中超时未支付关闭订单的场景。在订单创建时发送一条定时消息,5分钟以后投递给消费者,消费者收到此消息后需要判断对应订单是否完成支付,如果未完成支付,则关闭订单。如果已完成,则忽略。 通过消息触发定时任务的场景,如在某些固定时间点向用户发送提醒消息。 注意事项
消息对应的业务逻辑有时间窗口要求,如电商交易中超时未支付关闭订单的场景。在订单创建时发送一条定时消息,5分钟以后投递给消费者,消费者收到此消息后需要判断对应订单是否完成支付,如果未完成支付,则关闭订单。如果已完成,则忽略。 通过消息触发定时任务的场景,如在某些固定时间点向用户发送提醒消息。 注意事项
签名SDK只提供签名功能,与服务提供的SDK不同,使用时请注意。 Token认证 Token的有效期为24小时,需要使用一个Token鉴权时,可以先缓存起来,避免频繁调用。 Token在计算机系统中代表令牌(临时)的意思,拥有Token就代表拥有某种权限。Token认证就是在调用API的时
/v2/{project_id}/instances 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见获取项目ID。 表2 Query参数 参数 是否必选 参数类型 描述 engine 是 String 消息引擎:rocketmq。
连接信息。 客户端连接RocketMQ实例5.x版本收发事务消息前,需要确保Topic的消息类型为“事务”。 准备环境 执行以下命令,检查是否已安装Go。 go version 返回如下回显时,说明Go已经安装。 go version go1.16.5 linux/amd64 如果未安装Go,请下载并安装。
TransactionStatus.ROLLBACK:回滚事务,消息将被丢弃不允许消费。 TransactionStatus.UNKNOWN:无法判断状态,期待服务端向生产者再次回查该消息的状态。 订阅事务消息 订阅事务消息的代码与订阅普通消息的代码相同。 父主题: Python(TCP协议)
变更配置列表(RocketMQ实例5.x版本) 变更配置类型 是否支持扩容 是否支持缩容 存储空间(单机实例) √ × 实例规格(单机实例) × × 存储空间(集群实例) √ × 实例规格(集群实例) √ × 约束与限制 扩容存储空间有次数限制,只能扩容20次。 扩容代理个数时,系统会根据