普通消息
普通消息为 云消息队列 RocketMQ 版 中最基础的消息，区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等...
邮件推送事件通知概述
通过创建事件通知规则，消息服务MNS 可以将邮件推送产生的事件以消息的方式推送到指定的接收端。本文介绍邮件推送事件通知的背景信息、适用场景、事件类型以及消息格式。背景信息 如下图所示，如果您在 邮件推送服务控制台 打开异步通知...
故障管理
故障管理概述 故障管理是源于ITIL的一个概念，在IT企业或者互联网企业进行故障管理的目的是当生产环境出现重大宕机时尽快恢复正常的服务运营，将组件失败对业务所造成的负面影响降到最低，从而确保满足事先与业务客户之间所约定的服务级别...
使用限制
故障切换 对于高可用系列、集群系列实例，当主节点出现故障时，RDS会在30秒内切换到备节点（某些主备不一致等特殊场景可能切换时间较长）。切换过程中有30秒左右的连接闪断，需要您设置好程序的自动重连，避免因为切换导致服务不可用。切换...
常见问题
如何配置MNS以支持更长的消息保留期 如何配置MNS以支持更大的消息大小 消息数、活跃消息数、延迟消息数分别表示哪些消息 消息服务消息批量操作注意事项 消息优先级为1，就一定优先吗 队列问题 不同地域中的同名队列是同一个队列吗 对于较长...
功能使用相关问题
本文汇总了 云消息队列 MQTT 版 功能使用相关的常见问题。离线消息最多能保留多久？3天。仅当 QoS=1且 cleanSession=false时，云消息队列 MQTT 版 才会保留离线消息，最多保留3天，超过时间将自动滚动删除。铂金版实例可支持定制。如需定制...
带宽扩展包
业务带宽超限有什么影响 如果接入WAF防护的网站的正常业务流量超出您已购买的WAF实例的业务带宽（即业务带宽超限），WAF会降低超用业务的网络、计算等资源分配的优先级，触发限流、随机丢包等动作，导致您的业务在一定时间内出现卡顿、延迟...
功能特性
跨数据库分布式事务 当业务规模增大，单库单表无法满足业务需求时，自然就会出现分库分表的情况。但是，单机事务又不能保证分库后的事务属性，分布式事务几乎无法避免。分布式事务可以让应用轻松具备跨库分布式事务处理能力，像使用单机...
仪表盘
业务背景 云消息队列 RocketMQ 版 的消息收发流程中，队列的堆积情况、缓冲情况以及消息处理各关节的耗时等，会直接反映当前业务处理的性能和服务端运行的状态。因此，云消息队列 RocketMQ 版 的重点指标主要涉及以下业务场景。消息堆积...
共享订阅
使用场景 服务端负载均衡 当大量设备接入物联网平台并向物联网平台发送消息时，需要有多个业务服务端来处理这些消息，物联网平台的共享订阅特性可以帮助客户将消息分发到多个业务服务端，实现负载均衡。在下图中，业务服务端A、B使用相同的...
TCP协议客户端大版本发布
该策略可能会出现以下问题：消费者数量比和Queue数量多时，部分消费者获取不到消息的现象。部分消费者异常或者处理缓慢，其他消费者空闲却无法共同分担堆积压力的情况。以消息为粒度进行负载，负载策略更加均衡。避免了队列级负载策略可能...
混沌工程缓存实战系列-Redis
Redis是一个开源高性能的Key-Value存储系统，虽然Redis本身具备了非常高的可用性，但是在实际应用中也会随着系统业务的复杂性以及不合理的使用，而导致很多的问题。本文将讲述如何通过混沌工程来暴露可能存在的使用风险，提升缓存问题的...
迁移上云概述
该方案具备如下优势：服务不中断、消息收发影响小 迁移方案支持无感切换，在切流期间消息收发不中断，业务应用无感知，出现消息延迟和消息重复问题几率非常小。无需额外资源 业务方应用无需为迁移上云进行扩容或部署多套集群，迁移过程仅...
实例的节点故障处理机制
本文档介绍云数据库MongoDB版实例的节点故障处理机制。单节点实例 由于单节点实例架构的特殊性，单节点实例仅拥有一个节点。当节点发生故障后，系统会对故障节点进行检查与修复。节点故障期间实例的相关服务不可用。说明 单节点实例适用于...
如何处理健康检查导致的大量日志
方案风险说明 延长健康检查的间隔时间后，后端ECS实例出现故障时，负载均衡发现故障ECS实例的时间也会变长。操作步骤 登录 传统型负载均衡CLB控制台。在 实例管理 页面中找到相应的CLB实例，单击实例ID。在 监听 页签下，找到目标监听，在 ...
普通型公网NAT网关升级至增强型公网NAT网关FAQ
增强型公网NAT网关依然是支持多可用区容灾的，在创建或者升级的时候只需要您选择主可用区的交换机，备可用区的交换机不需要您选择，在主可用区出现故障的时候，增强型公网NAT网关会自动完成可用区容灾的切换。关联NAT带宽包的实例如何升级...
自动SQL限流
SQL限流是限制数据库上执行SQL的并发度，通过限制问题SQL的并发度后，保障数据库正常响应业务请求，保障大部分的业务正常运转，即通过小部分业务受损，保障大部分业务正常运行。背景信息 随着技术的发展，尤其是云数据库的普及，数据库系统...
常见问题
本文汇总了接入及使用消息推送组件的过程中经常出现的一些问题及其解决方法。通用问题 关于权限的说明 Android 6.0 后，需要用户手动授予手机权限，如读写 SD 卡。为了更加精准的发送推送，建议开发者引导获取消息推送所需权限。日志无法...
什么是消息服务MNS
您可以将资源集中在处理自身业务的逻辑中，避免对其他消息服务产品客户端的依赖，避免因为过多代码引入而影响自身服务的稳定性。更多信息，请参见：Endpoint签名认证 主题使用手册 对于因为网络或者其他原因不方便提供回调地址的情况，消息...
iOS SDK集成
功能时序图 功能实现 初始化RTC引擎及回调注册 说明 SDK出现异常时内部会优先进行重试恢复，需要业务处理的异常SDK会通过明确的回调API通知。异常发生原因 回调及参数 解决方案 备注 鉴权失败 onJoinChannelResult回调result返回...
基本概念
订阅关系（Subscription）订阅关系是 云消息队列 RocketMQ 版 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端系统，并在后续的消息传输中按照订阅关系定义的过滤规则进行消息匹配和消费进度维护。...
设计方案
在故障应急响应中，风险预测可以作为重要参考，帮助快速识别问题的根本原因，提高故障处理效率和精度。故障响应 在发现故障后，需要快速定位问题，通常有以下做法：组织协调：故障发生后，需要迅速组织相关人员进行应急响应。组织协调包括...
开源对比
提供强大的索引能力，可根据Queue、消息ID、消息处理耗时等完成不同维度的查询。详细信息，请参见 消息轨迹。消息轨迹信息以文本格式存储在服务器的log文件中，查询和定位问题效率较低。服务和性能 项目 云消息队列 RabbitMQ 版 开源...
步骤五：应用容灾
故障恢复 本机出现故障后在云上拉起本地业务，待本地环境恢复后再将其恢复到本地。具体步骤如下：在 主站点管理 页签，单击+添加。在 添加计算平台 页面，填写计算平台 名称，选择 类型，填写 IP地址、用户名 和 密码。单击 创建。在连续...
集群消费和广播消费
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
Connection和Channel
Connection数量较少而消费的数据量较大时，可能会出现消费倾斜问题，您可以在保证每个消费者Connection数一致的同时，增加每个消费者的Connection数或增加消费者数量。建议所有消费者的Connection之和大于30。多个进程可以共享同一个...
实例规格
不支持 消息存储时长 3天 若您购买实例的存储空间规格不足时，云消息队列 RocketMQ 版 会按存储时间滚动删除最早的消息，此时消息的存储时长可能不足3天。说明 若您对消息存储时长有特殊要求，您可以联系 云消息队列 RocketMQ 版 技术支持...
消息收发常见问题
为什么会出现一条消息同一时间重试多次？为什么消息会一直重试？消息发送时提示GroupID没有权限。使用RocketMQ数据流入MQTT功能时，为什么子级Topic后会多了一个“/”?消息发送返回“Too many publishes in progress”错误。本地测试先发送...
监控数据相关问题
一般情况下，您只需关注以下指标项：实例消息生产流量 Topic消息生产流量 Group未消费消息总数 其他指标项（如实例/Topic消息生产条数、实例/Topic消息生产发送次数、实例/Topic消息消费次数等）数据在流量比较小或客户端版本比较低时，会...
CLB健康检查FAQ
如上所述，由于健康检查成功后，负载均衡服务器直接发送TCP RST包中断了连接，并没有做进一步的业务数据交互，导致上层业务（例如Java连接池等）认为相应的连接是异常的，所以会出现 Connection reset by peer 等错误信息。解决方案 更换...
订阅者最佳实践
消费失败 云消息队列 Kafka 版 是按分区逐条消息顺序向前推进消费的，如果消费端拿到某条消息后执行消费逻辑失败，例如应用服务器出现了脏数据，导致某条消息处理失败，等待人工干预，那么有以下两种处理方式：失败后一直尝试再次执行消费...
集群消费和广播消费
广播模式下，消息队列保证每条消息至少被每台客户端消费一次，但是并不会重投消费失败的消息，因此业务方需要关注消费失败的情况。广播模式下，客户端每一次重启都会从最新消息消费。客户端在被停止期间发送至服务端的消息将会被自动跳过，...
开源对比
千级分区就会出现大量抖动。巡检系统 针对死锁、宕机等问题进行自动发现和修复。无。Bug修复 及时发现并修复。只能等社区缓慢修复，且通常要等新版发布，周期长。内核能力 项目 云消息队列 Kafka 版 Apache Kafka 弹性能力 秒级弹缩，业务...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
示例代码
class ExampleMessageListener:public MessageListener { public:Action consume(Message&message,ConsumeContext&context){/此处为具体的消息处理过程，确认消息被处理成功请返回CommitMessage。如果有消费异常，或者期望重新消费，可以...
设置宕机自动迁移
如果本地SSD型DDH出现故障，您可以 提交工单 申请人工迁移，但迁移后本地盘数据会丢失。DDH因故障迁移完成后，DDH ID及ECS实例的元数据（例如实例ID、私有IP地址、公网IP地址）均保持不变，但是由于更换了物理服务器，DDH的机器码会改变。...
适用场景
定时处理任务的用户 对于定时处理业务的客户，Serverless Hbase版本天生的弹性能力非常符合业务需求，每天定时处理业务请求或者在夜间进行数据分析处理，这样的系统可以灵活的使用这种服务模型来做数据存取，在将后台运营工作降到最低的...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
Multi-Master基础架构
通常情况下，数据库实例中只有Main Master在工作，Standby Master节点作为高可用备份，当Main Master节点出现故障时，Standby Master才会切换成Main Master进行工作。随着业务的发展，例如实时数仓和HTAP场景需求的增加，Single-Master的...
事务消息
事务消息为 云消息队列 RocketMQ 版 中...一般出现消息回查时事务正在处理的原因为：事务执行较慢，消息回查太快。解决方案如下：将第一次事务回查时间设置较大一些，但可能导致依赖回查的事务提交延迟较大。程序能正确识别正在进行中的事务。
- 产品推荐
- 这些文档可能帮助您