目錄業(yè)務整體場景場景 1計價規(guī)則高頻讀取規(guī)則可后臺動態(tài)修改業(yè)務場景痛點 難點設計思路技術選型Canal Redis MySQL場景 2充電樁設備長連接上報 設備告警實時推送業(yè)務場景痛點 難點設計思路技術選型WebSocket RocketMQ場景 3充電主鏈路解耦充電完成后賬單、通知、統(tǒng)計任務業(yè)務場景痛點 難點設計思路技術選型RocketMQ場景 4防止重復訂單設備重復上報、網絡重試產生臟數(shù)據(jù)業(yè)務場景痛點 難點設計思路技術選型MySQL 唯一索引 Redis場景 5大量異常訂單設備斷電、網絡異常導致訂單僵死業(yè)務場景痛點 難點設計思路技術選型XXL?Job 分布式定時任務場景 6整體微服務架構多模塊拆分、高可用保障業(yè)務場景痛點 難點設計思路技術選型Spring Cloud Alibaba Nginx整體技術棧選型總結面試口述版適配簡歷深挖、面試口述每一點業(yè)務場景 → 真實痛點難點 → 設計思路 → 技術選型 → 落地效果面試可以直接復述。業(yè)務整體場景智慧充電運營平臺面向充電運營商管理充電樁場站、充電設備、C 端用戶、充電訂單、計價計費、營銷活動充電樁硬件設備通過長連接實時上報充電數(shù)據(jù)、告警事件平臺需要做計費算價、訂單流轉、異常訂單兜底、運營可視化監(jiān)控。 業(yè)務流量特征充電樁設備海量并發(fā)上報充電過程持續(xù)上報電壓、電流計價規(guī)則會動態(tài)變更峰谷電價、服務費、優(yōu)惠策略運營商后臺隨時修改充電訂單狀態(tài)流轉復雜啟動、充電中、暫停、結束、設備異常斷電大量異常場景設備離線、網絡閃斷、上報亂序、中途斷電高并發(fā)寫訂單創(chuàng)建、狀態(tài)變更高頻讀計價規(guī)則查詢每一次充電上報都要讀取計價部分業(yè)務不能同步阻塞賬單生成、消息通知、統(tǒng)計數(shù)據(jù)同步做會拖垮主鏈路。場景 1計價規(guī)則高頻讀取規(guī)則可后臺動態(tài)修改業(yè)務場景每次設備上報充電數(shù)據(jù)都需要讀取最新計價規(guī)則峰谷時段、服務費、折扣來實時計算充電費用運營商后臺可以隨時修改計價規(guī)則表 MySQL。每次充電上報都要拿計價規(guī)則QPS 很高。痛點 難點如果每次算價直接查 MySQL高頻查詢壓垮 DB接口 RT 高原先平均 500ms如果單純使用 Redis 緩存修改 MySQL 之后Redis 緩存更新不及時DB 和 Redis 數(shù)據(jù)不一致會出現(xiàn)計費錯誤產生客訴不允許緩存長時間舊數(shù)據(jù)業(yè)務要求規(guī)則修改后生效延遲盡可能小。設計思路不能依靠開發(fā)手動更新緩存容易漏寫、代碼埋點侵入業(yè)務。采用binlog 監(jiān)聽準實時同步MySQL 計價規(guī)則表發(fā)生 insert/update/delete自動觸發(fā)同步邏輯刷新 Redis 緩存做到 DB 為源Redis 為副本。技術選型Canal Redis MySQLMySQL業(yè)務源庫存儲完整計價規(guī)則開啟 binlog row 模式Canal監(jiān)聽 binlog捕獲計價規(guī)則表變更事件Canal 客戶端消費變更事件直接對 Redis 做更新 / 刪除緩存延遲 1s業(yè)務代碼全部讀取 Redis 做計價不再大量查詢 MySQL兜底設置 Redis 短期過期時間防止 Canal 故障導致永久臟緩存。效果查詢 RT 從 500ms 降到 90msDB 壓力大幅下降規(guī)則變更秒級生效。場景 2充電樁設備長連接上報 設備告警實時推送業(yè)務場景充電樁設備和后端建立長連接持續(xù)上報充電數(shù)據(jù)設備發(fā)生故障溫度過高、過流平臺需要實時把告警推送到運營商管理后臺、手機端。痛點 難點設備分散服務多實例部署設備連接可能落在任意一個后端實例告警事件產生在 A 服務實例但用戶 web / 手機連接在 B 實例原生 WebSocket 無法跨機器推送消息網絡抖動、設備斷連重連消息丟失、重復推送不能輪詢數(shù)據(jù)庫拉告警輪詢延遲高、數(shù)據(jù)庫壓力大。設計思路設備與服務端建立 WebSocket 長連接維護會話映射設備 ID / 用戶 ID → 當前連接在哪臺服務實例產生告警事件發(fā)送消息到 MQ各個微服務消費 MQ判斷告警接收方的會話是否在本實例本地如果存在執(zhí)行推送增加告警持久化落庫作為兜底客戶端沒收到可以拉取歷史告警。技術選型WebSocket RocketMQWebSocket做客戶端與服務端雙向長連接RocketMQ實現(xiàn)跨實例消息廣播解決分布式環(huán)境下 WebSocket 跨機器推送問題。場景 3充電主鏈路解耦充電完成后賬單、通知、統(tǒng)計任務業(yè)務場景充電結束主鏈路需要完成訂單狀態(tài)更新同時要做賬單生成、用戶消息推送、運營統(tǒng)計數(shù)據(jù)更新。痛點 難點如果全部同步執(zhí)行主鏈路響應慢一旦賬單生成緩慢會阻塞訂單狀態(tài)返回下游業(yè)務短信、統(tǒng)計偶爾失敗不能影響核心訂單主流程充電結束并發(fā)量大同步處理會造成接口超時系統(tǒng)吞吐量上不去。設計思路核心流程只做訂單狀態(tài)落庫其余非強依賴業(yè)務全部異步化消息驅動。 充電完成發(fā)送 RocketMQ 事件消息多個消費端分別消費生成賬單、消息通知、統(tǒng)計指標。消息支持重試下游失敗不影響主業(yè)務。技術選型RocketMQ支持重試機制、消息可靠Topic 拆分不同業(yè)務消費組互不干擾。效果系統(tǒng)整體吞吐量提升 3 倍。場景 4防止重復訂單設備重復上報、網絡重試產生臟數(shù)據(jù)業(yè)務場景充電樁設備網絡不穩(wěn)定會重復上報充電啟動報文如果不做控制會生成多條重復充電訂單造成計費錯亂。痛點 難點設備側不可信會重復上報分布式多實例請求單機鎖無效不能靠業(yè)務代碼判斷高并發(fā)下判斷之后寫入會出現(xiàn)競態(tài)條件。設計思路使用設備上報攜帶的唯一業(yè)務報文 ID作為冪等標識MySQL 數(shù)據(jù)庫建立唯一索引數(shù)據(jù)庫層面攔截重復插入前置增加 Redis 冪等校驗做攔截減少 DB 報錯數(shù)據(jù)庫唯一索引作為最終兜底防線。技術選型MySQL 唯一索引 Redis效果杜絕重復訂單訂單數(shù)據(jù)準確率 100%。場景 5大量異常訂單設備斷電、網絡異常導致訂單僵死業(yè)務場景充電樁設備異常斷電、網絡斷開設備不會上報結束報文數(shù)據(jù)庫訂單一直停留在「充電中」僵死狀態(tài)不會閉環(huán)結算。靠人工排查成本極高。痛點 難點設備失聯(lián)不會主動通知后端訂單數(shù)量大人工排查處理成本高不能簡單寫死超時充電時長有長有短要結合業(yè)務規(guī)則判斷異常。設計思路分布式定時任務周期掃描訂單表按照業(yè)務規(guī)則識別僵死 / 異常訂單自動執(zhí)行訂單關閉、費用結算完成閉環(huán)。 需要解決集群多實例部署定時任務不能多機器同時執(zhí)行避免重復處理同一批訂單。技術選型XXL?Job 分布式定時任務分布式鎖保證任務只執(zhí)行一次自動掃描、自動閉環(huán)異常訂單。效果人工處理成本降低 90%。場景 6整體微服務架構多模塊拆分、高可用保障業(yè)務場景整個系統(tǒng)包含設備服務、訂單計價服務、場站管理、運營后臺、告警服務流量入口來自設備上報、運營后臺接口、C 端 H5。痛點 難點業(yè)務模塊耦合在一起迭代發(fā)布互相影響部分服務故障不能拖垮整個平臺需要統(tǒng)一的服務注冊發(fā)現(xiàn)、配置管理、熔斷降級前端、設備請求流量入口需要負載均衡。設計思路業(yè)務按領域拆分微服務訂單計價服務、設備服務、場站運營服務服務注冊發(fā)現(xiàn)統(tǒng)一配置中心接口熔斷降級防止雪崩Nginx 做反向代理負載均衡。技術選型Spring Cloud Alibaba NginxNacos注冊中心 配置中心Sentinel熔斷、限流、降級OpenFeign遠程調用Nginx請求負載均衡。整體技術棧選型總結面試口述版Spring Cloud Alibaba微服務底座Nacos 注冊配置Sentinel 熔斷OpenFeign 遠程調用解決模塊化拆分、高可用MySQL核心業(yè)務源數(shù)據(jù)庫訂單、場站、計價規(guī)則唯一索引做冪等兜底Redis緩存計價規(guī)則、冪等令牌配合 Canal 實現(xiàn)準實時緩存更新RocketMQ異步解耦賬單、通知分布式 WebSocket 告警跨實例推送消息重試保障下游可靠性Canal監(jiān)聽 MySQL binlog計價規(guī)則變更準實時同步 Redis解決 DB?Redis 一致性WebSocket接收設備上報、實時推送告警消息XXL?Job分布式定時任務自動處理僵死異常訂單Nginx反向代理、負載均衡。