消息中间件 PaaS 平台解决方案

构建企业级云原生消息基础设施

在云原生技术蓬勃发展和企业数字化转型加速推进的时代背景下，消息中间件作为企业应用架构的核心支撑，正面临着从传统单体架构向微服务架构的全面升级，以及从静态部署向弹性云原生管理的深度变革。
谙流 ASP 消息中间件 PaaS 平台提供了金融级、云原生的企业级消息流解决方案，支持从新建、替换、补强到双轨并存等多种落地路径，能够满足不同发展阶段和业务需求的企业。

立即咨询

业务痛点

在企业级消息中间件建设过程中，传统架构普遍存在多重挑战，严重影响了业务的高效运行和创新发展：

云原生转型能力不足，难以应对弹性扩容需求

传统消息中间件架构在面对业务快速增长和波动性需求时，扩容效率低下、资源配置僵化。许多企业的消息系统无法实现动态弹性伸缩，导致资源浪费或性能瓶颈，严重影响业务敏捷性和成本控制。

多系统孤岛问题严重，缺乏统一管控平台

企业内部往往并存多套消息中间件系统，缺乏统一的管控体系，运维复杂度呈指数级增长。不同业务线使用不同的消息技术栈，导致技术债务累积、人员成本攀升，且无法实现资源的统一调度和优化。

跨地域数据协同能力薄弱，容灾保障不足

现有架构在跨数据中心数据同步方面能力有限，缺少系统性的跨地域复制和容灾机制。当面临区域性故障或业务全球化扩展时，数据一致性和业务连续性难以得到有效保障。

缺乏企业级功能支撑，难以满足复杂业务场景

开源或自建的消息中间件往往功能单一，缺乏多租户隔离、精细化权限管控、全链路监控等企业级特性，无法满足大型企业复杂的业务场景和合规要求。

解决方案

谙流 ASP 平台基于 Apache Pulsar 构建四层企业级架构体系，通过云原生部署、企业级功能增强、跨地域数据协同、多种容灾支持等核心技术，
全面提升消息中间件平台能力：

云原生架构优势：
支持水平无限扩容

针对传统架构扩容能力不足的痛点，ASP 通过云原生架构设计，实现真正的弹性扩展和高可用保障：

Kubernetes 原生支持：ASP 使用自研 Pulsar Operator for K8S 帮助企业快速上云，通过自定义 K8S 的 CRD 资源，大大简化集群的部署和配置，同时便于提供自动化的升级、扩缩容、故障恢复等运维能力。
计算存储分离架构：无状态 Broker 计算，存储分片快速扩容，优化过的负载均衡算法，更加流畅的支撑水平无限扩容，PB 级数据管理，数据快速均衡能力。
多租户体系增强：支持从数据、权限和操作层面做租户隔离，这对企业做资源管控和数据安全提供了核心保障，同时最大化利用硬件投资。
统一运维与监控体系：基于 K8S 的集群管控能力让企业可以将消息中间件纳入统一的云原生运维体系中。ASP 集成了标准的 Prometheus 监控、Grafana 可视化、以及标准的日志聚合能力。

企业级功能增强：
构建完整生态体系

针对传统中间件功能单一的痛点，ASP 从核心功能和管控体系双层齐下，有力支撑企业核心业务需求：

Functions 轻量级计算：提供完整的、一站式的 Serverless 计算，支持 Java、Python、Go 等多种编程语言，快速拥有任务管理、包管理、任务编排、任务自动扩缩容能力，避免部署复杂流处理框架的开销。通过 Web 控制台提供完整的 Functions 生命周期管理能力。
消息轨迹追踪：支持追踪每条消息从产生到消费的完整生命周期，提供完整的消息路径、处理时间、错误信息等详细信息，大大简化问题排查和性能优化工作。
统一管控平台：提供行业领先的 Web 管理控制台，多集群管理，可视化运维，智能运维，故障快速定位，开发和运维效率极速提升。
企业级连接器生态：提供丰富的数据源连接器，也可与企业系统做定制化集成，同时快速提供新兴组件的连接器，帮助企业快速业务创新。

跨地域数据协同：
实现全球化数据流转

针对跨地域数据协同能力薄弱的痛点，ASP GEO 构建企业级跨地域复制能力：

原生跨地域数据同步：通过在不同地理位置部署 ASP 集群节点，实现业务数据的实时跨地域复制，支持数据复制、消费进度复制等多种复制模式。
灵活的复制策略配置：支持界面化配置复制，支持在 Namespace、Topic 和分区级别定义控制复制速率，可根据数据重要性、合规要求进行精细化控制。
高可靠容灾保障：构建单集群高可用和跨区域容灾架构，支持同城主备、异地多活等多种部署模式，确保业务连续性。

协议兼容性：
支持平滑迁移

针对异常场景应对能力薄弱的痛点，ASP GEO 设计多重防护机制：

Kafka 100% 兼容：原生支持 Pulsar，同时通过接入 ASK 可 100% Kafka 兼容协议支持，支持存量系统无缝迁移。
多协议支持：支持多种消息协议和接口，降低迁移成本和技术风险。

架构设计

ASP 采用"分层解耦、云原生协同"架构，核心为统一管控层，支持多种架构的企业级消息中间件部署：

核心管控层

基于 Apache Pulsar 构建的四层企业级架构体系，覆盖从基础消息引擎到企业级功能增强的完整解决方案：

底层消息引擎：提供 Apache Pulsar 企业级发行版，更高的稳定性、更快速的问题修复和发版速度
云原生平台层： Kubernetes 原生部署与管理，自动化运维与监控体系
企业级功能层： Functions 计算、消息轨迹、统一管控、连接器生态
业务应用层：支持多种业务场景和行业应用

部署架构模式

单集群高可用：基于跨 K8S 集群的单集群高可用架构
跨区域容灾：支持同城主备、异地多活等多种部署模式
多租户隔离：从数据、权限和操作层面实现完整的租户隔离

立即使用，搭建企业级云原生消息基础设施。

免费开始

方案优势

性能优势突破

订阅中心性能飞跃：通过 ASP Functions 分布式计算框架，某头部券商订阅中心处理性能提升 15 倍，为交易业务创造显著经济效益
传输延迟控制：某电信运营商通过存算分离方案，单节点传输性能提升 30%，整体时延从 2.25 小时降至 20 秒内
扩容性能无衰减：利用分片动态均衡技术支持从 128 个分区扩展至上千分区且无性能衰减

运维效率提升

自动化运维：日常运维工作量减少 60%，故障处理效率提升 3 倍，为企业节省大量人力成本
故障自愈机制：节点故障恢复时间从 4 小时缩短至 15 分钟，人工干预频次减少 80%，运维效率提升 16 倍
智能监控告警：异常秒级感知、分钟级响应，彻底摆脱"人工救火"状态

资源利用优化

存储资源优化：存储资源利用率整体提升 60%以上，磁盘有效利用率提升至 85%以上
成本控制：通过分层存储功能，热冷数据自动分层，存储成本显著降低
硬件投资最大化：多租户机制最大化利用硬件投资，在海量机器场景，整体流程承载得到大幅提升

客户案例

华泰证券

华泰证券基于 ASP 构建云原生消息中间件 PaaS 平台。通过 Functions 轻量级计算和 GEO 跨地域复制，订阅中心处理性能提升 15 倍，日常运维工作量减少 60%，故障处理效率提升 3 倍，系统可用性从 99.9% 提升至 99.999%，单次故障恢复时间从 10-30 分钟缩短至 10-30 秒。

了解更多