服务器证书管理
步骤三：使用服务器证书启动服务 启动服务会重启 云消息队列 MQTT 版 实例，重启时间预计5～10分钟，重启后客户端即可使用服务器证书做服务端认证。启动服务后，8883端口将开启双向认证，同时关闭单向认证。警告 使用服务器证书启动服务，...
基本概念
定时消息 Scheduled message，Producer 将消息发送到消息队列服务端，但并不期望这条消息立马投递，而是推迟到在当前时间点之后的某一个时间投递到 Consumer 进行消费，该消息即定时消息。详情请参见 消息类型>定时和延时消息。地址配置...
证书管理概述
服务器证书需要您自行购买或自行签发后，托管到 数字证书管理服务，并通过服务器证书重启 云消息队列 MQTT 版 服务。具体操作，请参见 服务器证书管理。服务端认证客户端 云消息队列 MQTT 版 服务端对客户端的认证通过对设备证书的认证完成...
使用异常
收到消息后，如果直接进入业务逻辑，一旦代码遗漏某个逻辑分支，就会导致消息信息没有被留在业务日志里，造成没有收到消息的假象。建议您收到消息后，立即打印消息信息留存 messageId、timestamp、reconsumeTime 等。消费端部署了多个消费...
集群消费和广播消费
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
集群消费和广播消费
广播模式下，消息队列保证每条消息至少被每台客户端消费一次，但是并不会重投消费失败的消息，因此业务方需要关注消费失败的情况。广播模式下，客户端每一次重启都会从最新消息消费。客户端在被停止期间发送至服务端的消息将会被自动跳过，...
客户端证书认证
服务器证书需要您自行购买或自行签发后，托管到 数字证书管理服务，并通过服务器证书重启 云消息队列 MQTT 版 服务。具体操作，请参见 服务器证书管理。服务端认证客户端 云消息队列 MQTT 版 服务端对客户端的认证通过对设备证书的认证完成...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
购买企业版实例
物联网平台提供标准型和尊享型的企业版实例，帮助您针对不同业务需求管理产品、设备、消息转发、数据服务和监控运维等资源，进而实现对物联网设备业务的提效目的。背景信息 物联网平台实例的使用说明，请参见 实例概述。企业版实例分为标准...
升级Broker可能产生哪些影响？
此外，升级和重启Broker期间，各个分区处理的消息量也会出现一定的不均衡，需要您评估一下升级变更对您业务可能产生的影响。升级所有Broker大概需要5分钟~15分钟。如果有多个实例，可以考虑先升级测试集群，验证通过后再升级生产集群。说明...
应用场景
事务型业务流程编排 复杂的业务场景如电商网站、酒店和机票预定等应用通常要访问多个远程服务，并且对操作事务性语义（即所有步骤全部成功或全部失败，不存在中间状态）有较高要求。在流量较小、数据存储集中的应用中，事务性可以通过关系...
消费者分类
SimpleConsumer SimpleConsumer是一种接口原子型的消费者类型，消息的获取、消费状态提交以及消费重试都是通过消费者业务逻辑主动发起调用完成。使用方式 SimpleConsumer的使用涉及多个接口调用，由业务逻辑按需调用接口获取消息，然后分发...
注意要点
这种情况下客户端看到的现象是服务端间歇性推送消息，并且重启消费者后消息恢复，建议通过增强消费者的消费能力解决。消费者提交的ack如果不在指定时间内，则触发消费重试。消息将会被重新投递，最多重试16次。若重试16次还未成功，则消息...
开通冷存储
警告 开通过程中需要滚动重启实例，可能会导致部分业务的读写请求出现延迟波动或连接中断的现象，建议您在业务低峰期操作。详细说明，请参见 实例运维常见问题。登录 Lindorm管理控制台。在页面左上角，选择实例所属的地域。在 实例列表 页...
迁移上云操作
重要 开源Apache RocketMQ 4.x版本没有消息类型的概念，阿里云 云消息队列 RocketMQ 版 会对Topic的消息类型和Message的类型进行一致性校验，因此在元数据迁移时，您需要根据实际业务场景手动录入Topic的消息类型。如果消息类型选择错误，...
配额与限制
云消息队列 RocketMQ 版 对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值，避免应用出现异常。参数限制 以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...
存储引擎对比
碎片化存储 否 是 Compact 不支持 支持 幂等 不支持 支持 事务 不支持 支持 消息类型 普通消息 集群重启或者宕机时，会导致极少量乱序。分区顺序消息 集群宕机时，会自动从ISR中选取新Leader。相关文档 如何为专业版实例在创建Topic时选择...
主题（Topic）
云消息队列 RocketMQ 版 支持的主题类型如下：Normal：普通消息，消息本身无特殊语义，消息之间也没有任何关联。FIFO：顺序消息，云消息队列 RocketMQ 版 通过消息分组MessageGroup标记一组特定消息的先后顺序，可以保证消息的投递顺序严格...
消费幂等
为了防止消息重复消费导致业务处理异常，消息队列RocketMQ版 的消费者在接收到消息后，有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
消息幂等
负载均衡时消息重复（包括但不限于网络抖动、服务端重启以及Consumer应用重启）当 云消息队列 RabbitMQ 版 的服务端或客户端重启、扩容或缩容时，会触发Rebalance，此时Consumer可能会收到重复消息。处理方法 以Message ID为幂等键对消息...
消息幂等
为了防止消息重复消费导致业务处理异常，SOFAStack 消息队列的消费者在接收到消息后，有必要根据业务上的唯一 Key 对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
功能特性
极速型NAS CPFS 100MB/s基线 CPFS的细分存储类型，适用HPC高性能计算、AI训练、自动驾驶、基因计算、影视渲染、EDA仿真、油气勘探、气象分析等高吞吐、高IOPS、海量文件的IO密集型业务。CPFS存储规格 200MB/s基线 CPFS的细分存储类型，适用...
使用流程
如果业务中有类似电商网站的商品ID、大型网站的用户ID、论坛帖子的ID、聊天工具的消息ID等使用主键列自增的场景，您可以配置主键列自增。4 读写数据 在数据表中写入、更新、读取或者删除数据。5 使用SQL查询数据 重要 只有支持SQL查询的...
消费重试
了解 云消息队列 RocketMQ 版 的消息确认机制以及消费重试策略可以帮助您分析如下问题：如何保证业务完整处理消息：了解消费重试策略，可以在设计实现消费者逻辑时保证每条消息处理的完整性，避免部分消息出现异常时被忽略，导致业务状态不...
应用场景
业务复杂度高是该类业务的典型特征 典型的应用场景如下：分库分表后的跨数据库分布式事务 例如支付宝的交易服务，随着业务规模的增大，单个交易流水表已经不能满足业务需求，需要通过分库分表实现数据水平拆分。但是水平拆分后，单表的数据...
实例类型
本文介绍 云消息队列 MQTT 版 的实例类型。地域限制 专业版实例和Serverless版实例仅华东1（杭州）、华东2（上海）、华北3（张家口）、华北2（北京）和华南1（深圳）地域支持，其他地域暂不支持。表 1.实例类型 项目 Serverless版 专业版 ...
升级共享代理为独享型代理
切换到独享型代理后，新增只读实例或只读实例重启，只有新的连接的请求才会路由到新的只读实例或重启的只读实例，老的连接请求不会路由过去。主实例与只读实例的参数 max_prepared_stmt_count 需要保持一致。若您的数据库代理进行过共享型...
实例运维常见问题
本文汇总了Lindorm实例在扩缩容、升降配、实例重启、版本升级等实例运维场景中的常见问题，包括但不限于操作耗时、业务影响及费用说明，帮助您快速了解运维操作中的相关细节和注意事项。问题导览 扩容、升配、服务开通 实例扩容节点需要...
共享订阅
使用场景 服务端负载均衡 当大量设备接入物联网平台并向物联网平台发送消息时，需要有多个业务服务端来处理这些消息，物联网平台的共享订阅特性可以帮助客户将消息分发到多个业务服务端，实现负载均衡。在下图中，业务服务端A、B使用相同的...
在边缘场景无缝运行使用InClusterConfig的业务Pod
问题二：在解决问题一后，如果云边网络断开时业务Pod容器出现重启等状况，边缘Pod将无法从kube-apiserver获取到业务配置，这会影响到业务Pod的重启运行。关于如何从Pod访问API的更多信息，请参见 从Pod中访问API。解决方案 通过边缘节点上...
版本管理
云消息队列 RocketMQ 版 为您提供全托管的版本管理服务，服务端版本更新后，系统会在后台自动完成升级，不影响消息收发，业务侧无感知。您可以根据波峰谷时间修改后台升级的执行时间和可维护时间段。使用限制 仅铂金版实例支持版本管理功能...
死信消息
死信消息保存规则 云消息队列 RocketMQ 版 默认不保存死信消息，消息转为死信状态后将被丢弃。您可以通过控制台开启死信消息保存功能，开启后，死信消息将被存储至指定的Topic中，该Topic被称为死信Topic。具体操作，请参见 配置死信消息...
生产者（Producer）
预绑定主题列表 定义：云消息队列 RocketMQ 版 的生产者需要将消息发送到的目标主题列表，主要作用如下：事务消息（必须设置）：事务消息场景下，生产者在故障、重启恢复时，需要检查事务消息的主题中是否有未提交的事务消息。避免生产者...
新功能发布记录
您可以根据告警消息及时提前申请提升配额，避免业务受到影响。创建NLB配额告警 NLB 调度算法支持加权最小连接数 更新 网络型负载均衡NLB 调度算法支持加权最小连接数。功能特性 创建和管理服务器组 2024年01月 功能名称 变更类型 功能概述 ...
应用场景
互联网类应用 Cassandra能够支持大并发低延时的访问需求，具备高可用和弹性扩容能力，适合日志、消息、feed流、订单、账单、网站等各种大数据量的互联网在线应用场景。多活 Cassandra原生支持多DC部署方式，实现更好的可用性和容灾能力。云...
如何选择合适的文件系统？
CPFS：HPC高性能计算、AI训练、自动驾驶、基因计算、影视渲染、EDA仿真、油气勘探、气象分析等高吞吐、高IOPS、海量文件的IO密集型业务。CPFS智算版：适用AIGC、自动驾驶等智算场景。目前，仅支持搭配PAI灵骏智算服务使用。重要 不同存储...
消息重试
消息重试策略概述 云消息队列 RocketMQ 版 消息收发过程中，若Consumer消费某条消息失败或消费超时，则 云消息队列 RocketMQ 版 会在重试间隔时间后，将消息重新投递给Consumer消费，若达到最大重试次数后消息还没有成功被消费，则消息将被...
什么是Topic
消息内容（Payload）：消息的具体内容。MQTT协议消息的传输过程，以业务服务器向设备下发消息为例 设备订阅相应的主题（Topic）。服务器发送消息给物联网平台。物联网平台接收消息，根据消息的主题（Topic）确定设备并发送消息。业务服务器...
变更配置
警告 根据变更项不同，切换过程中可能会出现业务闪断或实例重启，而且与数据库、账号、网络等相关的大部分操作都无法执行，请选择在 可维护时间段 内执行变配操作。变更项 说明 业务影响 系列 支持 PostgreSQL基础系列升级高可用系列。会...
- 产品推荐
- 这些文档可能帮助您