车联安是一个面向新能源充电基础设施与智能车联网融合运营的企业级平台,其核心目标是构建充电桩、车辆、用户与运营商之间的全链路数字化闭环,实现设备远程监控、智能调度、计费清分与安全预警的一体化管理。该平台整体采用Spring Cloud微服务架构,以Nacos作为服务注册与配置中心,Gateway网关统一处理认证鉴权与路由转发,业务层按领域拆分为设备管理、订单计费、充电调度、告警中心、用户账户等多个独立服务,服务间通过OpenFeign进行同步通信,异步场景则依赖RocketMQ解耦,例如充电订单创建后异步推送至计费引擎计算费用,超时未支付订单由延时消息触发自动取消并释放充电枪资源;同时利用RocketMQ的事务消息机制保证本地事务与消息发送的原子性,解决了充电启动与订单生成之间的分布式数据一致性问题。设备接入层基于Netty自研长连接网关,支持TCP和MQTT协议,负责与遍布各地的充电桩保持心跳连接并接收实时状态数据,如电压、电流、温度、枪锁状态、充电功率等,日均处理设备事件超两百万条,通过自定义协议编解码器和线程池隔离策略保障高吞吐下的稳定运行,当检测到设备异常数据或故障码时,网关立即将告警事件投递至Kafka,由告警中心消费后根据预设规则触发短信、邮件或站内通知,并生成工单推送给运维人员。在核心充电流程中,平台设计了多层级安全校验机制,用户扫码启动充电前会校验账户余额、设备状态、区域电网负载,再通过Redis分布式锁防止同一设备被并发抢占,充电过程中持续监控设备参数并支持远程停止和功率调节,充电结束后进入计费流程,计费规则支持按电量、按时间、分时电价等多种模式,最终通过对接微信支付和支付宝完成自动扣款并异步通知业务系统更新订单状态。数据存储方面使用MySQL存储订单、用户、设备档案等结构化数据,并按月对订单表进行分表,Redis缓存热点设备状态和用户会话,同时利用其Geospatial功能实现附近充电桩的位置查询,Elasticsearch用于存储设备历史日志和故障记录,为运维大屏提供实时检索和聚合分析能力。
需求方专属客服,免费梳理匹配