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