大搜车:云上多地域高可用消息系统的构建

简介: 大搜车利用云上MQTT+消息队列RocketMQ+全球消息路由+消息队列Kafka构建了完整的云上消息系统。

汽车产业互联网平台大搜车由姚军红创立于2012年12月,先后获得阿里巴巴集团、蚂蚁金服、晨兴资本、华平投资、春华资本等机构超过12亿美元融资。2017年12月,大搜车列入由硅谷全球数据研究机构PitchBook评选的“2017年全球新晋独角兽”名单。

目前,大搜车已经搭建起比较完整的汽车产业互联网协同生态。随着业务业务的快速发展,大搜车遇到了一系列的问题:

  • 大量微服务系统,总数在2000以上,这些系统之间的异步通信全部都需要通过消息队列MQ,导致消息量大幅增加,日均消息TPS在6000以上,消息系统的稳定性成为云上业务稳定保障的重中之重。
  • 由于有杭州和北京两大研发中心,客户在杭州和北京都部署了大量业务系统,多地域应用的消息同步需要有稳定可靠的机制。
  • 物联网设备的管理和接入对消息系统提出了更高的要求。
  • 大数据领域大量应用Kafka,需要更稳定可靠的商业版Kafka产品,减少运维工作量。

为了更好地支撑业务,大搜车利用云上MQTT+消息队列RocketMQ+全球消息路由+消息队列Kafka构建了完整的云上消息系统。

  1. 通过全球消息路由功能将杭州地域的消息同步到北京地域,做到业务分地区就近部署。
  2. 独立消息队列实例管理不同业务,可用性更高。
  3. 利用消息队列Kafka对接大数据生态,即开即用,快速扩容,可靠性更高。物联网设备通过MQTT进行接入,后台开发物联网设备管理平台,通过MQTT连接设备端,并对设备的能力进行管理,可通过平台调用设备端能力(比如发起会议、下发开机图片、获取设备信息等)。
  4. MQTT与RocketMQ后台消息打通,后端应用服务器无需保持设备端连接,以通用的RocketMQ消息进行对接,服务器端更稳定,连接管理更可靠。

56.png

  • 业务稳定性:阿里云RocketMQ提供99.99999999%的数据可靠性和99.95%的服务可用性SLA,确保服务高可用以及数据不丢失。
  • 高性能:RocketMQ支持千万级TPS以及亿级消息堆积,在业务高峰期依然可以保持高性能。
  • 全球消息路由:利用稳定可靠的路由功能,将客户多个地域的消息系统打通,实现业务就近访问,满足跨地域、远距离、毫秒级消息流转的需求。
  • 海量物联网设备管理:利用阿里云消息队列MQTT,实现物联网设备与云上业务应用可靠连接,轻松管理海量物联网设备。
  • 云上托管版Kafka:兼容开源Kafka协议,全托管,高可用,高安全。无缝对接开源及云上大数据生态。
相关文章
|
JSON 算法 物联网
物联网中利用OTA技术升级的基本原理与方法
物联网中利用OTA技术升级的基本原理与方法
853 0
|
5月前
|
人工智能 运维 安全
一文看懂函数计算 AgentRun,让 Agentic AI 加速进入企业生产环境
AgentRun 的愿景很简单:让 AI Agent 从 Demo 到生产级部署,变得前所未有的简单。通过 Serverless 架构持续优化成本并解放运维负担,通过企业级 Runtime 提供生产级的执行环境和安全保障,通过开源生态集成避免框架锁定,通过全链路可观测让每个环节都清晰可控——这就是 AgentRun 要为企业提供的完整解决方案。
|
存储 SQL 人工智能
Hologres 4.0全新发布:AI时代的一站式多模态分析平台
2025年云栖大会,Hologres发布全新4.0版本升级,以“AI时代的一站式多模态分析平台”为核心理念,全面展示了Hologres在结构化、半结构化与非结构化数据分析能力上的重大突破,特别是在OLAP分析、点查、向量检索、全文检索、湖仓协同及AI Function集成等方面的领先优势,刷新ClickBench、JSONBench、VectorDBBench等多项榜单,登顶第一。
|
11月前
|
运维 监控 关系型数据库
AI 时代的 MySQL 数据库运维解决方案
本方案将大模型与MySQL运维深度融合,构建智能诊断、SQL优化与知识更新的自动化系统。通过知识库建设、大模型调用策略、MCP Server开发及监控闭环设计,全面提升数据库运维效率与准确性,实现从人工经验到智能决策的跃迁。
1105 27
|
消息中间件 运维 监控
小麦助教:通过阿里云原生中间件产品组合,加速微服务架构落地
通过深度的使用阿里云丰富的云原生中间件产品,助力小麦微服务架构的快速落地,借助可观测、消息等产品,极大地提升了开发和运维效率,使小麦在降本增效上有了新的突破,真正做到了只关注业务本身。
4994 93
|
11月前
|
消息中间件 存储 大数据
阿里云消息队列 Kafka 架构及典型应用场景
阿里云消息队列 Kafka 是一款基于 Apache Kafka 的分布式消息中间件,支持消息发布与订阅模型,满足微服务解耦、大数据处理及实时流数据分析需求。其通过存算分离架构优化成本与性能,提供基础版、标准版和专业版三种 Serverless 版本,分别适用于不同业务场景,最高 SLA 达 99.99%。阿里云 Kafka 还具备弹性扩容、多可用区部署、冷热数据缓存隔离等特性,并支持与 Flink、MaxCompute 等生态工具无缝集成,广泛应用于用户行为分析、数据入库等场景,显著提升数据处理效率与实时性。
|
运维 监控 Cloud Native
茶百道全链路可观测实战
茶百道全链路可观测实战
2332 108
|
消息中间件 监控 Apache
RocketMQ助力编程猫构建稳定的业务系统
通过使用商业版本的RocketMQ,依赖于有保障的SLA(99.99999999%数据可靠性,99.95%服务可用性),就像是站在巨人的肩膀上构建系统。
4706 107
RocketMQ助力编程猫构建稳定的业务系统

热门文章

最新文章