程序聚合 软件案例 大数据平台

大数据平台

2025-09-09 21:02:33
行业:政务服务
载体:网站
技术:Java

业务和功能介绍

“蜂巢”是一个旨在应对千万级日活用户和高并发场景的新一代B2C电商平台。项目采用基于Spring Cloud Alibaba的微服务架构,彻底重构了原有的单体应用,旨在提升系统性能、可扩展性和开发迭代效率。项目核心模块包括用户中心、商品服务、订单服务、库存服务、支付服务和积分服务。

项目实现

微服务设计与开发:

独立负责订单服务和积分服务的数据库设计、接口开发和业务逻辑实现。

使用 Spring Cloud OpenFeign 声明式调用用户服务和商品服务,实现了服务间的解耦与高效通信。

基于 Spring Cloud Gateway 编写全局过滤器,实现了统一的用户鉴权(JWT)、接口限流和日志记录。

高并发与性能优化:

应对秒杀场景: 在商品详情页和秒杀接口中,使用 Redis 预减库存,并通过 Redis分布式锁 防止超卖。将验证、库存、订单等步骤异步化,最终将下单流程提升至可支撑5000+ QPS。

解决缓存热点问题: 针对热门商品缓存击穿问题,采用 Redis 互斥锁(SETNX) 策略;对于缓存穿透,使用布隆过滤器(通过Redisson实现)进行无效请求过滤。

数据库优化: 对订单表进行了水平分表(按用户ID取模),并针对慢查询SQL进行了索引优化和Explain分析,使核心接口响应时间从平均500ms降低到80ms以下。

分布式系统问题解决:

分布式事务: 在“下单”业务中,涉及扣库存、创建订单、增加积分等多个微服务。采用 Seata 的AT模式保障了核心业务流程的最终一致性,避免了人工对账补数据的麻烦。

接口幂等性: 为防止用户重复提交订单,利用 Redis + Token机制 实现了下单接口的幂等性设计。

消息可靠性: 在使用RabbitMQ处理订单超时取消时,采用了确认(Confirm)机制和持久化方案,并通过死信队列(DLX)进行失败消息的重试与补偿,保证了消息100%不丢失。

示例图片视频


刘小康
24小时内活跃
方向: 后端-Java、
交付率:100.00%
相似推荐
数据同步系统
项目背景: T部门是某软件公司下的一个软件研发部门,现有员工20余人,每年承接软件开发项目较多。许多项目需要分级部署,不同层级需要同步数据。过去一直是每个项目组自行解决,投入重叠、效率低下、项目周期长。 为解决上述问题,T部门领导提出开发数据同步系统,作为部门的软件资产,其他项目组将来直接使用其解决数据同步需求,以便将更多精力投入在业务需求上。 项目目标: 开发一个数据同步系统(以下简称“DSW”),DSW 部署方便、配置简单,在源数据源和目标数据源之间可准实时同步数据,支持双向同步。 软件功能和核心模块: 1.支持定时同步数据 2.支持同一份数据复制到多个目标数据源 3.支持不同版本oracle 之间的数据同步 业务流程及功能路径: 1.提取数据库数据到消息队列 2.路由处理 3.传输数据 4.目标服务器整合数据 5.目标服务器加载数据到目标数据库
员工管理系统
注册登录功能:包含常用的注册信息录入,注册邮箱验证,并且系统预留了手机号验证接口,登录后在后端生成jwt标签用于标识登录用户,并结合redis技术实现标签的存储和核验。 角色权限分配功能:管理员可对系统用户分配角色和权限,该部分业务中角色实现的是权限组的控制功能,管理员可新建角色并为多个用户分配角色,从而实现多用户的权限控制功能。而权限分配功能仅针对单一用户,可为特殊用户分配各自的系统权限。 会议管理功能:包含会议录入,会议签到管理,会议记录导出功能,会议录入功能可实现excle文件识别,根据文件格式自动在数据库生成参会数据,会议签到管理功能,通过会议室安装的统一工牌读写设备可以实时录入到场的参会人员工牌,从而实现对人员参会的管理。
库存盘点管理系统
一、功能概述 某制造业公司库存管理系统,该系统利用 RFID 手持设备对生产零部件的入 库,出库,盘点等业务进行管理。包含 PC 端,小程序端及 RFID 手持设备端。 包含标签管理,据点管理,盘点任务,仓库管理等功能。 二、功能点划分 1、品番分类 维护品番分类信息,该数据来源是小程序,部品系统会从品番信息内进行更新。 2、品番信息 维护品番信息,数据从小程序同步过来,可以进行修改/同步操作。 3、基准值设定 对某个品番预警设置一个阈值 4、库位信息 维护库位信息,可以进行新增/修改/删除操作。 5、据点信息维护据点信息,可以进行新增/修改操作。 6、标签规则定义标签规则定义,定义各种标签的生成规则。分为四种:1、常量(固定不变),2、变量(根据一定的规则进行自动生成),3、日期(根据当前的日期进行生成,格式为yyyyMMdd),4、流水(4位的流水) 7、标签发行 标签发行,用于单个标签的发行,通过选择品番来进行控制,并且可以进行移库操作。 8、批量标签发行批量标签发行,根据导入的数据批量生成标签,需要根据模板内的收纳数和库位进行计算生成。 9、反却单据反却单据,从小程序同步过来形成单据,通过该单据删除出入库履历及恢复库存(软删除)。 10、盘点任务盘点任务,对现有的库存进行盘点,盘点结束后把实绩的库存数发送给小程序。 11、出入库履历出入库履历报表,可进行查询/导出/重打印操作 12、库存明细 存储各品番在库情况 13、库存预警 库存预警报表,可进行查询/导出操作 14、在途查询 存储标签制作出来后但是未被发行出来的标签数据信息 15、用户管理 管理当前系统可登录的用户信息 16、角色信息 管理当前系统所拥有的角色信息
访客登记管理系统
一、功能概述: 本项目聚焦集团内部出差管理场景,构建覆盖 PC 网页端与小程序端的一体化出差管理系统。系统核心宗旨在于优化集团内部员工出差全流程,通过数字化手段简化从出差申请发起、跨层级审批流转到结果反馈的全链路操作,有效降低人工沟通成本与流程冗余;同时,依托系统化的数据管理能力,实现对员工个人、各业务据点(或分支机构)出差数据的规范化采集、结构化存储与可追溯管理,为集团后续差旅成本分析、资源调配优化及管理决策提供精准的数据支撑。 二、功能划分: 1、我的出差,我的出差是整个出差单起始位置,也是出差单创建的位置。我的我的出差单创建时,需要选择出差对应的出差据点、出差据点接引人、本次出差协同人员、本次出差乘坐交通工具的方式、到达指定据点后是否需要专车接送、本次出差的旅途信息、本次出差是否需要入住酒店、入住酒店的人员信息签约酒店信息 2、我的接待,我的接待是对应出差据点的接待人员收到出差人员的出差信息通知后,会根据出差单的旅途日期在指定的日期前往接待。接待人员更新该出差单的通知后出差单对应的状态将会流转到我的审批 3、我的审批,我的审批是出差据点的接待担当接待完出差人员后,将此信息上报给领导给此时出差据点的领导收到通知后会进行出差单的审批。代表出差人员成功到达了出差地点 4、我的对应,我的对应是当出差人员由出差据点回来后。出差人员的领导进行审批作业代表本次出差圆满结束。数据会进行脱敏存档处理 5、车辆预约管理、该功能主要是为了记录每张出差单人员中出差的出行方式 6、酒店预约管理、该功能主要是为了记录每张出差单人员本次入住酒店的情况 7、访客需求管理、该功能主要是为了记录每张出差单出差人员的情况 8、签约酒店管理、该功能主要是为了管理每个据点的签约酒店信息的方便在新增出差单时选择签约酒店信息 9、目的地管理、该功能主要是为了管理本系统的出差地点的,及用户可选的出差地点
OPS
从0到1 参与了 工厂数据中台台的开发,负责了数字化日报模块,人员管理等核心模块的开发。 基于xxl-job实现工厂生产相关数据同步,计算功能以及企微消息推送功能。 基于ThreadPoolExcutor线程池和CompletableFuture优化数字化日报首页查询接口,使得响应速度提升,从原来的6s左右优化到1s以内。 基于 基于Redis和Caffeine构建多级缓存机制,存储数据计算结果,提升请求速度。
帮助文档   Copyright @ 2021-2024 程聚宝 | 浙ICP备2021014372号
人工客服