| 功能模块 | 细项功能 | 细项功能说明 | 上线批次要求 | 产品原生功能 |
| 消息组件通用能力 | 数据集成和数据管道 | 提供数据集成和构建数据管道的工具。 | 其他批次 | 可实施 |
| 消息可靠存储 | 具备多种存储方案以保证消息完全可靠不会丢失。 | 第一批次 | 是 |
| 不同的刷盘方式 | 提供同步落盘和异步落盘两种形式。 | 其他批次 | 可实施 |
| 多种部署架构 | 具备单机、集群和多中心等多种部署架构能力 | 第一批次 | 是 |
| 多种部署环境 | 需具备多种部署环境能力,包括单机部署、分布式部署、容器部署等 | 其他批次 | 可实施 |
| 多种消息机制 | 支持多种消息机制包括顺序消息、同步消息、异步消息、定时消息、延时消息、事务消息、重试机制等。 | 第一批次 | 是 |
| 可视化管理工具 | 具备可视化管理工具,通过该工具可以简易的监控消息组件的各项参数。 | 第一批次 | 是 |
| 云原生支持 | 可以与容器化、微服务架构无缝集成 | 其他批次 | 可实施 |
| 兼容支持多种协议或客户端 | 平台需要兼容常见的消息中间件协议或客户端,必须包括以下协议:(略) | 第一批次 | 是 |
| 平台需要兼容常见的消息中间件,包括以下协议:(略) | 其他批次 | 可实施 |
| 高可靠消息组件能力 | 可靠性传输 | 消息组件需要保证消息可靠性传输,做到不重、不漏。 | 其他批次 | 可实施 |
| 持久化可靠存储机制 | 支持持久化机制将消息存储到可靠的存储介质中。 | 第一批次 | 是 |
| 集群部署高可用 | 支持两地三中心的容灾部署模式,实现消息数据的异地备份存储。 | 第一批次 | 是 |
| 消息重试与重发 | 当网络出现故障时,自动进行消息重试与重发,直到消息成功投递为止 | 第一批次 | 是 |
| 消息幂等性 | 消费端对重复的消息进行幂等消费处理,即使处理多次也不会影响数据一致性。 | 其他批次 | 可实施 |
| 分布式部署和扩展性 | 支持以分布式的方式部署在多个服务器上,可以根据业务需求和数据量动态调整系统规模和容量。 | 第一批次 | 是 |
| 多种消息消费模式 | 支持多种消息消费模式,包括广播模式和集群模式,可通过消费者分组进行指定消费者消费消息。 | 其他批次 | 可实施 |
| 流量控制和流量削峰 | 流量控制可以平滑流量,保证系统稳定,通过设置消息生产和消费的速率限制,避免突发流量冲击 | 其他批次 | 可实施 |
| 分布式事务消息 | 提供分布式事务消息的支持,用于在分布式环境下实现消息的原子性和一致性。 | 第一批次 | 是 |
| 客户端负载均衡 | 防止单点过载。避免资源浪费,根据消费能力分配消息数量。 | 第一批次 | 是 |
| 消息轨迹管理 | 提供丰富的消息轨迹管理功能 | 第一批次 | 是 |
| 消息过滤 | 只将符合条件的消息发送给消费者,提高消费者的效率和系统的性能。 | 其他批次 | 可实施 |
| 消息重试和死信队列 | 当消费者无法正常处理消息时,MQ需自动进行消息重试,若重试次数达到上限,消息将被发送到死信队列,便于后续处理。 | 第一批次 | 是 |
| 消息过期处理 | 根据消息的时间戳或过期时间来自动删除已经过期的消息,避免过期消息堆积,节省存储资源。降低消费者处理无效消息的系统开销,同时提高有效消息的处理效率。 | 第一批次 | 是 |
| 安全性 | 限制不同用户或角色对消息队列和主题的访问权限,保护消息传递过程中的安全性和隐私性。 | 其他批次 | 可实施 |
| 批量消息处理 | 支持批量发送和消费消息,可以将多条消息打包成一个批次进行处理,提高系统的吞吐量和效率。 | 第一批次 | 是 |
| 高性能消息组件能力 | 高性能 | 消息组件需保证符合性能要求 | 第一批次 | 是 |
| 支持消息批量发送和消费 | 支持消息的批量发送和消费,避免了频繁的小包开销,提高了消息传递的效率。 | 第一批次 | 是 |
| 内存优化和零拷贝技术 | 采用内存优化以及零拷贝技术,减少了数据复制与传输的开销,提高了数据传输的效率。 | 其他批次 | 可实施 |
| 消息压缩传输 | 支持消息压缩传输技术,降低了网络IO,提高了数据传输的效率。 | 第一批次 | 是 |
| 消息预取和缓存机制 | 支持消息预取与缓存机制,可以提前加载热点数据到内存中,提高数据的访问速度; | 其他批次 | 可实施 |
| 弹性横向扩展能力 | 能够按需增加处理能力,以应对业务的高并发、高吞吐需求 | 第一批次 | 是 |
| 并行处理和流式计算 | 支持消息并行处理和流式计算,充分利用多核资源,提高数据处理的效率和性能; | 其他批次 | 可实施 |
| 实时日志收集和分析 | 支持实时消费并进行日志存储、分析或监控。从而实现高效的日志收集与处理 | 其他批次 | 可实施 |
| 流式数据处理 | 支持实时的数据处理和分析。可以及时地对大规模数据进行计算、分析和处理,支持实时决策和业务响应。 | 其他批次 | 可实施 |
| 海量日志存储与检索 | 支持高性能的日志存储和检索系统,支持快速地查询和分析大规模的日志数据。1K消息传输场景下,高可靠消息组件客户端>=(略)kTPS,高吞吐消息组件客户端>=(略)kTPS. | 其他批次 | 可实施 |
| 数据缓冲和削峰填谷 | 保护后端服务免受突发流量的冲击,并提高系统的可伸缩性和稳定性。 | 其他批次 | 可实施 |
| 数据备份和数据复制 | 通过设置合适的副本因子和复制策略,实现数据的冗余存储和故障恢复,提高数据的安全性和可靠性。 | 第一批次 | 是 |
| 数据流控和数据分发 | 根据业务需求和规则,将不同类型或优先级的消息分发到不同的主题中,实现数据的按需分发和灵活处理。 | 其他批次 | 可实施 |
| 实时监控和告警 | 对系统运行状态进行实时监控,并在发生异常或超出预设阈值时发送告警通知。 | 第一批次 | 是 |
| 消息SDK能力 | 订阅模式 | 消息PULL模式 | 消费端根据自身的消费能力拉取消息,且支持消息体自动类型转换。 | 其他批次 | 可实施 |
| 消息PUSH模式 | 消息组件具备推送消息给对应的订阅客户端实例的能力 | 其他批次 | 可实施 |
| 场景消息 | 同步发送 | 消息SDK需要支持同步消息,确保消息的可靠发送。 | 第一批次 | 是 |
| 异步发送 | 消息SDK需要支持异步消息。 | 第一批次 | 是 |
| 事务消息 | 消息SDK需要支持事务消息的解决方案,确保消息发送和本地业务逻辑处理的原子性。 | 第一批次 | 是 |
| 延迟消息 | 消息SDK需要支持延迟消息。 | 第一批次 | 可实施 |
| 顺序消息 | 消息SDK需要支持顺序消息的解决方案。包括支持全局顺序消息,局部顺序消息。 | 第一批次 | 是 |
| 定时消息 | 消息SDK需要支持定时消息。 | 第一批次 | 可实施 |
| 多种消费确认模式 | 支持消费的自动确认;支持消息同步/异步消费确认,异步模式提供确认回调 | 第一批次 | 是 |
| 手动消息确认模式 | 支持消费的手动确认;消息确认中,手动模式支持单笔和批量消费确认。 | 其他批次 | 可实施 |
| 可靠消息、幂等处理 | 消息的可靠性发送及幂等处理 | 可靠消息发送:(略) | 其他批次 | 可实施 |
| 多版本运行 | 多版本运行 | 支持版本切换时期,双版本或多版本平滑切换。 | 其他批次 | 可实施 |
| 典型业务场景功能 | 按业务类型划分消息通道 | 支持按业务类型划分消息通道。 | 其他批次 | 可实施 |
| 消息加密传输功能 | 保护消息内容的机密性,通过加密可以防止未经授权的第三方直接读取消息内容。确保消息完整性,加密可以检测消息在传输过程中是否被非法修改。 | 其他批次 | 可实施 |
| 消息批量发送功能 | 支持发送大批量小额交易消息,不会阻塞而影响吞吐。 | 其他批次 | 可实施 |
| 消息内容筛选功能 | 支持基于消息内容筛选订阅,仅接收匹配的消息类型。 | 第一批次 | 可实施 |
| 回调和确认功能 | 提供回调和确认机制,确保关键交易流程的可靠交付。 | 其他批次 | 可实施 |
| 消息平台能力 | 环境管理 | 系统管理功能 | 消息平台支持展示自身平台版本信息、所依赖底层组件信息等。 | 其他批次 | 可实施 |
| 消息平台支持展示组内物理节点信息,包括CPU、硬盘、内存等信息。 | 其他批次 | 可实施 |
| 节点管理 | 消息平台支持在总体资源池建设中可以新增物理节点用来丰富总体资源池。 | 第一批次 | 是 |
| 消息平台可以给资源池中的节点进行分组,做到组间物理隔离。 | 第一批次 | 是 |
| 资源池管理 | 消息平台支持对所创建的消息组件进行资源分配,包括CPU、内存、磁盘。 | 其他批次 | 可实施 |
| 消息平台支持对所创建的消息组件进行资源删除,并可以将相关CPU、内存和磁盘回收入资源池。 | 其他批次 | 可实施 |
| 消息平台支持对所有资源池中的资源进行统一监控,包括已使用资源和未使用资源。具体资源内容为CPU、内存和磁盘。 | 其他批次 | 可实施 |
| 存储管理 | 本地存储 | 消息平台应可以进行本地文件系统存储。通过文件系统去访问资源池中的硬盘空间进行消息存储。 | 第一批次 | 是 |
| 消息平台支持对所创建好的集群进行管理,包括文件系统本地存储的更改和删除。需要将节点上的可用磁盘映射成存储设备来使用和管理。 | 第一批次 | 是 |
| 需提供开箱即用的监控指标采集和告警提醒能力。开启平台监控组件后,可从存储集群、存储性能和存储容量等方面进行监控和告警,且支持配置通知策略。 | 第一批次 | 是 |
| 数据库存储 | 消息平台应可以进行数据库系统存储。通过数据库系统去访问资源池中或外部的硬盘空间进行消息存储。 | 其他批次 | 可实施 |
| 消息平台支持对所创建好的集群进行管理,包括数据库系统存储的更改和删除。 | 其他批次 | 可实施 |
| 需提供开箱即用的监控指标采集和告警提醒能力。直观呈现的监控数据可用于为运维巡检或性能调优提供决策支持,完善的告警机制也将帮助保障存储系统的稳定运行。 | 其他批次 | 可实施 |
| 分布式存储 | 消息平台应可以进行分布式存储系统存储。分布式存储需要实现自动管理、自动扩容、以及自动修复的分布式存储能力。 | 其他批次 | 可实施 |
| 接入平台内其他业务集群的分布式存储资源,确保存储和业务隔离便于管理和维护。 | 其他批次 | 可实施 |
| 同一存储集群中支持同时使用文件存储、块存储等不同类型的存储池,以支持不同业务需求。 | 其他批次 | 可实施 |
| 消息平台支持对所创建好的集群进行管理,包括分布式存储系统的更改和删除。 | 其他批次 | 可实施 |
| 分布式存储提供了开箱即用的监控指标采集和告警提醒能力。启用监控与告警功能后,可从存储集群、存储性能及存储组件等方面进行监控和告警,且支持配置通知策略。 | 其他批次 | 可实施 |
| 运维中心 | 平台运维监控 | 消息中心支持针对平台整体进行运维监控包括各组件实例信息监控。 | 第一批次 | 是 |
| 平台监控支持接入第三方监控平台。例如Prometheus+Grafana,zabbix等。 | 第一批次 | 可实施 |
| 组件运维监控 | 消息中心支持针对单独组件进行监控 | 第一批次 | 是 |
| 组件监控支持接入第三方监控平台。例如Prometheus+Grafana,zabbix等。 | 第一批次 | 可实施 |
| 日志格式 | 对接行内的日志平台的日志标准,无缝对接行内的日志要求。 | 其他批次 | 可实施 |
| 告警 | 告警模板是一组针对同类资源的告警规则及通知策略的组合。通过告警模板,可以方便、快捷地为平台上的集群、节点或计算组件创建告警策略。 | 第一批次 | 是 |
| 支持为不同级别的告警配置全局发送间隔,以限制发送消息频率,同时,支持为内置的监控组件配置告警通知策略,当检测到自身组件异常时触发告警并通知,方便用户了解内置告警组件状态。 | 第一批次 | 是 |
| 基于平台的监控、事件数据,并结合平台的通知功能,为集群及集群下节点、计算组件、服务创建指标告警、自定义告警、事件告警(仅计算组件)、黑盒告警(仅集群)类型的告警策略,当告警策略针对的资源发生异常或监控数据达到规则设定的预警状态时,即可自动触发告警并发送告警通知 | 第一批次 | 是 |
| 基于日志的告警策略,当告警策略针对的资源发生异常或监控数据达到规则设定的预警状态时,即可自动触发告警并发送告警通知 | 其他批次 | 可实施 |
| 通知 | 通知策略支持以邮件、短信、接口回调的形式发送通知,例如:(略) | 其他批次 | 可实施 |
| 通知联系组是一组具有相同逻辑特征的通知对象,是接受通知消息的一类实体。例如:(略) | 其他批次 | 可实施 |
| 通知模板是一个由自定义内容、内容变量和内容格式参数组成的标准化的结构体。用于为通知策略,标准化定制告警通知消息的内容及格式。 | 其他批次 | 可实施 |
| 事件 | 记录资源的重要状态变更及各种运行状态变化的事件,并且提供了存储、查询、可视化能力。 | 其他批次 | 可实施 |
| 平台健康状态 | 平台健康状态页面,需呈现平台已部署功能的健康状态统计数据。当您的账号拥有平台管理、平台审计相关权限时,您还可以查看指定组件的详细健康数据。 | 第一批次 | 是 |
| 组件管控能力 | 组件商店 | 版本管理:(略) | 其他批次 | 可实施 |
| 包管理:(略) | 其他批次 | 可实施 |
| 升级更新:(略) | 其他批次 | 可实施 |
| 平台支持依照模板创建组件配置,用户可以自行保存模板共后续使用。 | 其他批次 | 可实施 |
| 部署管理 | 用户可从此处进行组件SDK及相对应传输IP和端口的申请,通过SDK以及传输IP和端口可以进行消息的收发。 | 其他批次 | 可实施 |
| 平台支持提供组件回收和调整能力。 | 其他批次 | 可实施 |
| 组件管理 | 虚机部署完成之后,可以通过一键启动对所有已部署节点进行快速启动和停止。 | 其他批次 | 可实施 |
| 可以查看并修改节点配置。 | 其他批次 | 可实施 |
| 平台可以查看组件的操作日志和启动日志。 | 其他批次 | 可实施 |
| 平台可以监控组件的健康状态和资源使用情况。 | 第一批次 | 可实施 |
| 集群管理 | 消息组件采用集群部署模式部署服务。该模式相较于单机部署在性能和负载能力上有了进一步的提升。 | 第一批次 | 可实施 |
| 通过多中心完成同城灾备集群的部署以及监控,应展示同城机房的互备关系,运行监控等。 | 第一批次 | 可实施 |
| 通过多中心完成两地三中心集群的部署以及监控,应展示各个集群的互备关系,运行监控等。 | 其他批次 | 可实施 |
| 日志管理 | 平台支持展示所记录的所有平台级相关日志,包括登录信息,执行操作等。 | 其他批次 | 可实施 |
| 平台支持对所产生的平台级日志进行日志审计。 | 其他批次 | 可实施 |
| 用户角色管理 | 用户管理 | 支持拥有平台管理权限的用户,通过平台创建本地用户,并为用户添加角色。 | 第一批次 | 是 |
| 平台管理员可以为自己账号之外的指定的用户添加角色,使用户拥有相应角色的权限; | 第一批次 | 是 |
| 平台需提供灵活的用户管理方式,支持对指定的单个用户进行管理。 | 第一批次 | 是 |
| 用户组管理 | 通过在平台上创建本地用户组,对平台上的多个用户(任一来源)实现基于角色的访问权限控制。 | 第一批次 | 是 |
| 支持具有平台管理权限的用户管理本地用户组的成员。 | 第一批次 | 是 |
| 支持具有平台管理权限的用户管理用户组的角色。 | 第一批次 | 是 |
| 支持更新和删除用户组。 | 第一批次 | 是 |
| 角色管理 | 支持具有平台角色权限的用户根据实际使用场景创建小于等于自身角色权限的自定义角色。 | 第一批次 | 是 |
| 包括更新自定义角色基本信息、更新自定义角色权限信息、复制已有角色为新角色、删除自定义角色。 | 第一批次 | 是 |
| 通过导入/移除角色成员,灵活实现角色权限的下发/回收。 | 第一批次 | 是 |
| 更新用户安全策略 | 为确保用户登录安全,平台支持设置用户安全策略,包括密码安全、用户禁用、用户锁定、用户通知、访问控制策略。提升用户密码的安全性,降低恶意攻击风险。 | 第一批次 | 是 |
| 数据同步 | MySQL/TDSQL数据库CDC | 数据同步过程中,获取需要同步的数据,并将数据经过国密加密传输,进入消息中间件,进行后续同步处理。 | 其他批次 | 可实施 |
| 全量数据对比 | 针对突发数据量较大时binlog丢失情况下的数据同步,支持对源库表与目的库表的数据进行全量对比。 | 其他批次 | 可实施 |
| 主备切换时数据同步处理 | 数据库底层主备切换时进行数据同步的场景,保证目的库表的日志与主备切换后的源库表日志一致。 | 其他批次 | 可实施 |
| 数据库分片的CDC支持 | 支持数据库采用分片功能场景下的数据同步。 | 其他批次 | 可实施 |
| 数据ETL | 针对不同类型数据库之间的数据同步,支持数据增量同步、数据处理、数据插入、多份数据库核对等功能。 | 其他批次 | 可实施 |
| 审计日志管理 | 消息中心应提供各个维度的审计日志,方便开发运维进行问题的快速分析、排查、管控端操作的监控留痕。审计日志根据季度归档。 | 其他批次 | 可实施 |