1. 企业级供应链管理中台系统重构与性能优化
背景:重构单一架构的供应链系统,需支撑千万级日订单处理,并满足业务团队对前端应用独立、快速迭代的需求。
架构设计与核心方案:作为项目架构负责人,主导设计了 “微服务 + 微应用”一体化架构。
后端微服务治理:采用 Spring Cloud Alibaba 技术栈,以 Nacos 作为核心,统一实现服务注册发现、配置管理与动态路由,替代传统Dubbo+Zookeeper组合,大幅提升运维效率和配置灵活性。核心服务间通信通过 OpenFeign 与 Ribbon 实现,结合 Sentinel 完成熔断限流。
前端微应用解耦:为满足多团队并行开发,采用 微前端(Micro-Frontends)架构。将订单、仓储、物流等模块拆分为独立的 Vue.js 微应用,通过 qiankun 主框架进行集成。每个微应用可独立开发、测试、部署,实现了技术栈无关性与团队自治。
数据层与异步解耦:通过 Redis 分布式缓存热点数据,利用 RocketMQ 可靠消息实现库存扣减、日志记录等异步流程,确保核心链路的高吞吐。针对海量订单查询,实施基于 ShardingSphere 的分库分表方案。
2.实时数据管道与OLAP分析平台设计与实现(数据处理专项)
背景与挑战:为支持业务实时决策与多维灵活分析,需构建一个能整合多源异构数据(MySQL、日志、API),提供低延迟(秒级)数据服务与高效即席查询的统一数据平台。
我的职责与全过程实现:
架构设计与技术选型:主导设计并实现了 Lambda 架构的实时数据管道。选用 DataX 进行批式历史数据同步与初始化;使用 Flink 作为统一的实时计算引擎,消费 Kafka 消息流进行实时ETL、聚合与清洗;选择 StarRocks 作为实时OLAP核心,替代原有Hive+Impala方案,以支撑高并发点查与复杂多维分析;同时将明细与聚合数据导入 Elasticsearch,赋能全文检索与模糊查询场景。
核心开发与优化:
编写Flink DataStream/Table API作业,实现包括会话计算、实时风控指标在内的复杂业务逻辑,并解决状态管理与精准一次消费问题。
基于 StarRocks 特性,设计并实现分层物化视图与Colocate Join,将核心宽表查询性能提升至亚秒级。
开发 Kafka Connect 自定义连接器与 DataX 插件,实现异构数据源到Kafka及StarRocks的高效、可监控接入。
数据质量与运维保障:建立从Kafka→Flink→StarRocks/ES的全链路监控与数据一致性校验机制;通过Doris Manager与Grafana看板实现集群性能可视化。