：解決億級數據性能瓶頸)
1. 數據庫分庫分表從理論到實戰(zhàn)的全方位解析作為經歷過多個億級用戶系統(tǒng)的架構師我深刻理解當數據量突破單機數據庫承載能力時的痛苦。記得有一次凌晨三點我們的訂單數據庫因為單表數據量超過2億條導致核心交易接口響應時間從200ms飆升到8秒整個技術團隊被迫通宵緊急擴容。正是這次事故讓我意識到分庫分表不是可選項而是高并發(fā)系統(tǒng)發(fā)展到一定階段的必選項。2. 為什么需要分庫分表2.1 單機數據庫的性能瓶頸當數據量達到千萬級甚至億級時單機數據庫會面臨四大核心問題查詢性能斷崖式下跌以MySQL的InnoDB引擎為例當單表數據超過500萬行后即使有索引查詢延遲也會顯著增加。這是因為B樹索引的層級會隨著數據量增長而加深通常數據量500萬B樹3層數據量5000萬B樹4層數據量5億B樹5層 每增加一層就意味著多一次磁盤I/O性能自然下降。索引效率降低我曾經處理過一個案例某用戶表有3億數據雖然建立了手機號的唯一索引但由于索引樹過高簡單的SELECT * FROM users WHERE mobile13800138000查詢也需要300ms這在業(yè)務高峰期是完全不可接受的。連接數成為瓶頸MySQL默認的最大連接數是1515.7版本在高并發(fā)場景下很容易被打滿。雖然可以通過參數調整但單機連接數超過1000后上下文切換的開銷會顯著增加CPU負載。存儲空間限制即使使用SSD單塊磁盤的容量和IOPS也是有限的。我們曾經有個日志表每月增長1TB不到半年就把服務器磁盤撐爆了。實戰(zhàn)經驗不要等到系統(tǒng)報警才考慮分庫分表。建議單表數據量達到以下閾值時開始規(guī)劃OLTP業(yè)務表500萬行日志類表2000萬行配置類表可適當放寬到1000萬行3. 分庫分表的核心策略3.1 垂直拆分按業(yè)務維度切分垂直拆分是最容易理解的拆分方式它遵循專業(yè)的人做專業(yè)的事原則。以電商系統(tǒng)為例拆分前單一數據庫(ecommerce_db) ├── users ├── orders ├── products ├── payments └── logistics拆分后用戶庫(user_db) └── users 訂單庫(order_db) └── orders 商品庫(product_db) └── products實施要點拆分后各庫應部署在不同物理服務器上避免共享資源需要重構事務代碼跨庫事務要改為分布式事務公共配置數據如地區(qū)編碼需要同步或冗余踩坑記錄我們曾經在拆分后將用戶庫和訂單庫放在同一臺物理機結果高峰期兩個業(yè)務互相影響。后來發(fā)現即使做了容器隔離底層磁盤IO仍然是共享的。3.2 水平拆分按數據規(guī)則切分水平拆分是解決單表數據過大的終極方案。常見的分片算法包括3.2.1 哈希取模法-- 按user_id分4個表 SELECT * FROM users_${user_id % 4} WHERE user_id 12345優(yōu)點數據分布均勻缺點擴容困難需要遷移數據3.2.2 范圍分片-- 按創(chuàng)建時間分表 SELECT * FROM orders_2023 WHERE created_at BETWEEN 2023-01-01 AND 2023-12-31優(yōu)點易于擴容冷熱數據分離方便缺點可能產生熱點問題3.2.3 一致性哈希使用虛擬節(jié)點解決擴容問題適合需要頻繁擴容的場景。分片鍵選擇對比表分片鍵類型適用場景優(yōu)點缺點用戶ID用戶中心系統(tǒng)用戶數據集中大用戶可能成熱點訂單ID交易系統(tǒng)避免熱點關聯查詢困難時間日志/統(tǒng)計系統(tǒng)方便冷熱分離近期數據可能成熱點地理區(qū)域本地生活服務符合業(yè)務特性跨區(qū)域查詢性能差實戰(zhàn)技巧分片鍵的選擇要同時考慮數據的分布均勻性和查詢模式。我們曾經用訂單ID做分片鍵結果發(fā)現90%的查詢都帶有用戶ID條件導致大量跨庫查詢。后來改為(user_id, order_id)聯合分片鍵才解決問題。4. 分庫分表中間件深度解析4.1 ShardingSphere實戰(zhàn)ShardingSphere是目前最流行的分庫分表中間件支持JDBC和Proxy兩種模式。以下是一個完整的配置示例# application-sharding.yml spring: shardingsphere: datasource: names: ds0,ds1 ds0: type: com.zaxxer.hikari.HikariDataSource driver-class-name: com.mysql.cj.jdbc.Driver jdbc-url: jdbc:mysql://db-host-1:3306/order_db?useSSLfalse username: root password: 123456 ds1: type: com.zaxxer.hikari.HikariDataSource driver-class-name: com.mysql.cj.jdbc.Driver jdbc-url: jdbc:mysql://db-host-2:3306/order_db?useSSLfalse username: root password: 123456 rules: sharding: tables: t_order: actual-data-nodes: ds$-{0..1}.t_order_$-{0..15} database-strategy: standard: sharding-column: user_id precise-algorithm-class-name: com.example.algorithm.UserIdPreciseShardingAlgorithm table-strategy: standard: sharding-column: order_id precise-algorithm-class-name: com.example.algorithm.OrderIdPreciseShardingAlgorithm key-generate-strategy: column: id key-generator-name: snowflake key-generators: snowflake: type: SNOWFLAKE props: worker-id: 123關鍵配置解析actual-data-nodes定義物理表分布支持Groovy表達式sharding-column分片字段建議選擇區(qū)分度高且查詢頻繁的字段precise-algorithm-class-name自定義分片算法實現PreciseShardingAlgorithm接口性能優(yōu)化在高并發(fā)場景下建議啟用ShardingSphere的SQL緩存功能props: sql-show: true sql-simple: true max.connections.size.per.query: 54.2 MyCat與ShardingSphere對比特性ShardingSphereMyCat架構模式JDBC/ProxyProxy性能損耗低JDBC直連中等網絡跳轉功能完整性完善較完善社區(qū)活躍度高一般學習曲線中等簡單適合場景中大型互聯網公司傳統(tǒng)企業(yè)選型建議新項目建議直接用ShardingSphere-JDBC老系統(tǒng)改造可以考慮MyCat。5. 跨庫查詢解決方案實戰(zhàn)5.1 禁止跨庫JOIN的替代方案原始SQLSELECT o.*, u.name FROM orders o JOIN users u ON o.user_id u.id WHERE o.status PAID改造方案先查詢用戶ID列表ListLong userIds orderMapper.selectUserIdsByStatus(PAID);批量查詢用戶信息MapLong, User userMap userMapper.selectByIds(userIds).stream() .collect(Collectors.toMap(User::getId, Function.identity()));業(yè)務層組裝數據ListOrderDTO dtos orders.stream() .map(o - { OrderDTO dto convert(o); dto.setUserName(userMap.get(o.getUserId()).getName()); return dto; }) .collect(Collectors.toList());5.2 異構表設計技巧對于頻繁需要關聯查詢的場景可以采用數據冗余方案CREATE TABLE t_order ( id BIGINT PRIMARY KEY, user_id BIGINT NOT NULL, user_name VARCHAR(50) COMMENT 冗余字段, user_level INT COMMENT 冗余字段, amount DECIMAL(10,2), status VARCHAR(20), created_at DATETIME, INDEX idx_user_id (user_id) );同步方案使用觸發(fā)器不推薦影響性能應用層雙寫需要保證事務通過CDC工具如Canal捕獲變更5.3 搜索引擎整合對于復雜的多維度查詢可以引入Elasticsearch// 數據同步邏輯 Transactional public void createOrder(Order order) { // 1. 寫入數據庫 orderMapper.insert(order); // 2. 異步寫入ES CompletableFuture.runAsync(() - { esClient.index( IndexRequest.of(ir - ir .index(orders) .id(order.getId().toString()) .document(convertToEsDoc(order)) ) ); }, esThreadPool); }性能數據我們某個系統(tǒng)的訂單查詢接口從直接查分庫分表平均120ms改為查ES后P99降到了35ms。6. 分布式ID生成方案對比6.1 Snowflake算法優(yōu)化原生Snowflake算法存在時鐘回撥問題改進方案public class EnhancedSnowflake { private long lastTimestamp -1L; private long sequence 0L; public synchronized long nextId() { long timestamp timeGen(); if (timestamp lastTimestamp) { // 時鐘回撥處理 long offset lastTimestamp - timestamp; if (offset 5) { try { wait(offset 1); timestamp timeGen(); } catch (InterruptedException e) { throw new RuntimeException(e); } } else { throw new RuntimeException(Clock moved backwards); } } if (lastTimestamp timestamp) { sequence (sequence 1) sequenceMask; if (sequence 0) { timestamp tilNextMillis(lastTimestamp); } } else { sequence 0L; } lastTimestamp timestamp; return ((timestamp - twepoch) timestampLeftShift) | (datacenterId datacenterIdShift) | (workerId workerIdShift) | sequence; } }6.2 其他ID方案對比方案優(yōu)點缺點適用場景數據庫自增簡單可靠有性能瓶頸小規(guī)模系統(tǒng)Redis INCR性能好依賴Redis需要高QPS生成UUID無中心化無序、存儲空間大臨時數據標識Leaf-segment高性能、可擴展需要DB支持中大型互聯網公司7. 分庫分表后的運維挑戰(zhàn)7.1 擴容數據遷移方案雙寫遷移流程上線新分片規(guī)則同時寫新舊庫后臺任務逐步遷移歷史數據數據校驗確保一致性切換讀請求到新庫下線舊庫寫入// 雙寫示例 public void createOrder(Order order) { // 獲取新老分片目標 String newTarget calculateNewShard(order); String oldTarget calculateOldShard(order); // 開啟事務 TransactionTemplate template new TransactionTemplate(transactionManager); template.execute(status - { // 寫入新庫 newOrderMapper.insert(newTarget, order); // 寫入舊庫 oldOrderMapper.insert(oldTarget, order); return null; }); }7.2 分頁查詢優(yōu)化方案深分頁優(yōu)化方案對比方案實現復雜度性能適用場景游標分頁低優(yōu)有序ID分頁二次查詢中良非主鍵排序搜索引擎高優(yōu)復雜條件分頁內存分頁低差小數據量游標分頁實現示例-- 第一頁 SELECT * FROM orders WHERE user_id 123 ORDER BY id LIMIT 10; -- 后續(xù)頁使用上一頁最后一條記錄的ID SELECT * FROM orders WHERE user_id 123 AND id 上一頁最后ID ORDER BY id LIMIT 10;8. 分布式事務解決方案8.1 Seata AT模式實戰(zhàn)GlobalTransactional public void placeOrder(OrderRequest request) { // 1. 扣減庫存 productService.reduceStock(request.getProductId(), request.getQuantity()); // 2. 創(chuàng)建訂單 Order order createOrder(request); orderMapper.insert(order); // 3. 扣減余額 accountService.debit(request.getUserId(), order.getAmount()); }AT模式執(zhí)行流程解析SQL生成前后鏡像注冊分支事務報告全局事務狀態(tài)異步進行二階段提交/回滾8.2 TCC模式設計要點public interface OrderTccService { TwoPhaseBusinessAction(name createOrder, commitMethod commit, rollbackMethod rollback) boolean tryCreateOrder(Order order); boolean commit(Order order); boolean rollback(Order order); }TCC注意事項空回滾問題需要判斷try是否執(zhí)行冪等控制網絡重試可能導致重復調用懸掛問題cancel比try先執(zhí)行9. 監(jiān)控與調優(yōu)實戰(zhàn)9.1 關鍵監(jiān)控指標# ShardingSphere監(jiān)控指標示例 shardingsphere_statement_latency_milliseconds_sum{typeSELECT} 1500 shardingsphere_statement_total{typeINSERT} 12000 shardingsphere_routed_data_sources_total 4 shardingsphere_routed_tables_total 32監(jiān)控大盤建議分庫分表路由統(tǒng)計SQL執(zhí)行耗時分布分布式事務成功率連接池使用情況9.2 性能調優(yōu)案例問題現象某系統(tǒng)分庫分表后查詢性能反而下降。排查過程發(fā)現大量IN查詢跨多個分片跟蹤SQL日志確認分片鍵使用不當分析業(yè)務場景90%查詢都帶有create_time條件解決方案將分片鍵從user_id改為(create_time, user_id)組合建立月份分表如orders_202301增加本地緩存減少跨分片查詢優(yōu)化效果平均響應時間從320ms降到85ms數據庫CPU使用率從70%降到35%10. 分庫分表的最佳實踐經過多個項目的實戰(zhàn)我總結了以下黃金法則分片鍵選擇三原則查詢必須帶分片鍵條件數據分布均勻避免跨分片查詢擴容預留空間初始設計時就考慮2-3倍的擴容空間比如預計3年數據量按6年容量設計分片數冷熱據分離熱數據最近3個月用SSD存儲溫數據3-12個月用普通磁盤冷數據歸檔到對象存儲避免過度設計單表百萬級不必分表單庫千萬級不必分庫能用讀寫分離解決的不用分庫分表工具鏈建設數據遷移工具分片鍵在線修改工具數據校驗工具最后給個實用建議在實施分庫分表前先用現有數據做全量壓測模擬分片后的查詢模式這樣可以提前發(fā)現大部分潛在問題。我們曾經用這個方法避免了上線后的三次重大事故。 數據庫分庫分表實戰(zhàn)：解決億級數據性能瓶頸
1. 數據庫分庫分表從理論到實戰(zhàn)的全方位解析作為經歷過多個億級用戶系統(tǒng)的架構師我深刻理解當數據量突破單機數據庫承載能力時的痛苦。記得有一次凌晨三點我們的訂單數據庫因為單表數據量超過2億條導致核心交易接口響應時間從200ms飆升到8秒整個技術團隊被迫通宵緊急擴容。正是這次事故讓我意識到分庫分表不是可選項而是高并發(fā)系統(tǒng)發(fā)展到一定階段的必選項。2. 為什么需要分庫分表2.1 單機數據庫的性能瓶頸當數據量達到千萬級甚至億級時單機數據庫會面臨四大核心問題查詢性能斷崖式下跌以MySQL的InnoDB引擎為例當單表數據超過500萬行后即使有索引查詢延遲也會顯著增加。這是因為B樹索引的層級會隨著數據量增長而加深通常數據量500萬B樹3層數據量5000萬B樹4層數據量5億B樹5層 每增加一層就意味著多一次磁盤I/O性能自然下降。索引效率降低我曾經處理過一個案例某用戶表有3億數據雖然建立了手機號的唯一索引但由于索引樹過高簡單的SELECT * FROM users WHERE mobile13800138000查詢也需要300ms這在業(yè)務高峰期是完全不可接受的。連接數成為瓶頸MySQL默認的最大連接數是1515.7版本在高并發(fā)場景下很容易被打滿。雖然可以通過參數調整但單機連接數超過1000后上下文切換的開銷會顯著增加CPU負載。存儲空間限制即使使用SSD單塊磁盤的容量和IOPS也是有限的。我們曾經有個日志表每月增長1TB不到半年就把服務器磁盤撐爆了。實戰(zhàn)經驗不要等到系統(tǒng)報警才考慮分庫分表。建議單表數據量達到以下閾值時開始規(guī)劃OLTP業(yè)務表500萬行日志類表2000萬行配置類表可適當放寬到1000萬行3. 分庫分表的核心策略3.1 垂直拆分按業(yè)務維度切分垂直拆分是最容易理解的拆分方式它遵循專業(yè)的人做專業(yè)的事原則。以電商系統(tǒng)為例拆分前單一數據庫(ecommerce_db) ├── users ├── orders ├── products ├── payments └── logistics拆分后用戶庫(user_db) └── users 訂單庫(order_db) └── orders 商品庫(product_db) └── products實施要點拆分后各庫應部署在不同物理服務器上避免共享資源需要重構事務代碼跨庫事務要改為分布式事務公共配置數據如地區(qū)編碼需要同步或冗余踩坑記錄我們曾經在拆分后將用戶庫和訂單庫放在同一臺物理機結果高峰期兩個業(yè)務互相影響。后來發(fā)現即使做了容器隔離底層磁盤IO仍然是共享的。3.2 水平拆分按數據規(guī)則切分水平拆分是解決單表數據過大的終極方案。常見的分片算法包括3.2.1 哈希取模法-- 按user_id分4個表 SELECT * FROM users_${user_id % 4} WHERE user_id 12345優(yōu)點數據分布均勻缺點擴容困難需要遷移數據3.2.2 范圍分片-- 按創(chuàng)建時間分表 SELECT * FROM orders_2023 WHERE created_at BETWEEN 2023-01-01 AND 2023-12-31優(yōu)點易于擴容冷熱數據分離方便缺點可能產生熱點問題3.2.3 一致性哈希使用虛擬節(jié)點解決擴容問題適合需要頻繁擴容的場景。分片鍵選擇對比表分片鍵類型適用場景優(yōu)點缺點用戶ID用戶中心系統(tǒng)用戶數據集中大用戶可能成熱點訂單ID交易系統(tǒng)避免熱點關聯查詢困難時間日志/統(tǒng)計系統(tǒng)方便冷熱分離近期數據可能成熱點地理區(qū)域本地生活服務符合業(yè)務特性跨區(qū)域查詢性能差實戰(zhàn)技巧分片鍵的選擇要同時考慮數據的分布均勻性和查詢模式。我們曾經用訂單ID做分片鍵結果發(fā)現90%的查詢都帶有用戶ID條件導致大量跨庫查詢。后來改為(user_id, order_id)聯合分片鍵才解決問題。4. 分庫分表中間件深度解析4.1 ShardingSphere實戰(zhàn)ShardingSphere是目前最流行的分庫分表中間件支持JDBC和Proxy兩種模式。以下是一個完整的配置示例# application-sharding.yml spring: shardingsphere: datasource: names: ds0,ds1 ds0: type: com.zaxxer.hikari.HikariDataSource driver-class-name: com.mysql.cj.jdbc.Driver jdbc-url: jdbc:mysql://db-host-1:3306/order_db?useSSLfalse username: root password: 123456 ds1: type: com.zaxxer.hikari.HikariDataSource driver-class-name: com.mysql.cj.jdbc.Driver jdbc-url: jdbc:mysql://db-host-2:3306/order_db?useSSLfalse username: root password: 123456 rules: sharding: tables: t_order: actual-data-nodes: ds$-{0..1}.t_order_$-{0..15} database-strategy: standard: sharding-column: user_id precise-algorithm-class-name: com.example.algorithm.UserIdPreciseShardingAlgorithm table-strategy: standard: sharding-column: order_id precise-algorithm-class-name: com.example.algorithm.OrderIdPreciseShardingAlgorithm key-generate-strategy: column: id key-generator-name: snowflake key-generators: snowflake: type: SNOWFLAKE props: worker-id: 123關鍵配置解析actual-data-nodes定義物理表分布支持Groovy表達式sharding-column分片字段建議選擇區(qū)分度高且查詢頻繁的字段precise-algorithm-class-name自定義分片算法實現PreciseShardingAlgorithm接口性能優(yōu)化在高并發(fā)場景下建議啟用ShardingSphere的SQL緩存功能props: sql-show: true sql-simple: true max.connections.size.per.query: 54.2 MyCat與ShardingSphere對比特性ShardingSphereMyCat架構模式JDBC/ProxyProxy性能損耗低JDBC直連中等網絡跳轉功能完整性完善較完善社區(qū)活躍度高一般學習曲線中等簡單適合場景中大型互聯網公司傳統(tǒng)企業(yè)選型建議新項目建議直接用ShardingSphere-JDBC老系統(tǒng)改造可以考慮MyCat。5. 跨庫查詢解決方案實戰(zhàn)5.1 禁止跨庫JOIN的替代方案原始SQLSELECT o.*, u.name FROM orders o JOIN users u ON o.user_id u.id WHERE o.status PAID改造方案先查詢用戶ID列表ListLong userIds orderMapper.selectUserIdsByStatus(PAID);批量查詢用戶信息MapLong, User userMap userMapper.selectByIds(userIds).stream() .collect(Collectors.toMap(User::getId, Function.identity()));業(yè)務層組裝數據ListOrderDTO dtos orders.stream() .map(o - { OrderDTO dto convert(o); dto.setUserName(userMap.get(o.getUserId()).getName()); return dto; }) .collect(Collectors.toList());5.2 異構表設計技巧對于頻繁需要關聯查詢的場景可以采用數據冗余方案CREATE TABLE t_order ( id BIGINT PRIMARY KEY, user_id BIGINT NOT NULL, user_name VARCHAR(50) COMMENT 冗余字段, user_level INT COMMENT 冗余字段, amount DECIMAL(10,2), status VARCHAR(20), created_at DATETIME, INDEX idx_user_id (user_id) );同步方案使用觸發(fā)器不推薦影響性能應用層雙寫需要保證事務通過CDC工具如Canal捕獲變更5.3 搜索引擎整合對于復雜的多維度查詢可以引入Elasticsearch// 數據同步邏輯 Transactional public void createOrder(Order order) { // 1. 寫入數據庫 orderMapper.insert(order); // 2. 異步寫入ES CompletableFuture.runAsync(() - { esClient.index( IndexRequest.of(ir - ir .index(orders) .id(order.getId().toString()) .document(convertToEsDoc(order)) ) ); }, esThreadPool); }性能數據我們某個系統(tǒng)的訂單查詢接口從直接查分庫分表平均120ms改為查ES后P99降到了35ms。6. 分布式ID生成方案對比6.1 Snowflake算法優(yōu)化原生Snowflake算法存在時鐘回撥問題改進方案public class EnhancedSnowflake { private long lastTimestamp -1L; private long sequence 0L; public synchronized long nextId() { long timestamp timeGen(); if (timestamp lastTimestamp) { // 時鐘回撥處理 long offset lastTimestamp - timestamp; if (offset 5) { try { wait(offset 1); timestamp timeGen(); } catch (InterruptedException e) { throw new RuntimeException(e); } } else { throw new RuntimeException(Clock moved backwards); } } if (lastTimestamp timestamp) { sequence (sequence 1) sequenceMask; if (sequence 0) { timestamp tilNextMillis(lastTimestamp); } } else { sequence 0L; } lastTimestamp timestamp; return ((timestamp - twepoch) timestampLeftShift) | (datacenterId datacenterIdShift) | (workerId workerIdShift) | sequence; } }6.2 其他ID方案對比方案優(yōu)點缺點適用場景數據庫自增簡單可靠有性能瓶頸小規(guī)模系統(tǒng)Redis INCR性能好依賴Redis需要高QPS生成UUID無中心化無序、存儲空間大臨時數據標識Leaf-segment高性能、可擴展需要DB支持中大型互聯網公司7. 分庫分表后的運維挑戰(zhàn)7.1 擴容數據遷移方案雙寫遷移流程上線新分片規(guī)則同時寫新舊庫后臺任務逐步遷移歷史數據數據校驗確保一致性切換讀請求到新庫下線舊庫寫入// 雙寫示例 public void createOrder(Order order) { // 獲取新老分片目標 String newTarget calculateNewShard(order); String oldTarget calculateOldShard(order); // 開啟事務 TransactionTemplate template new TransactionTemplate(transactionManager); template.execute(status - { // 寫入新庫 newOrderMapper.insert(newTarget, order); // 寫入舊庫 oldOrderMapper.insert(oldTarget, order); return null; }); }7.2 分頁查詢優(yōu)化方案深分頁優(yōu)化方案對比方案實現復雜度性能適用場景游標分頁低優(yōu)有序ID分頁二次查詢中良非主鍵排序搜索引擎高優(yōu)復雜條件分頁內存分頁低差小數據量游標分頁實現示例-- 第一頁 SELECT * FROM orders WHERE user_id 123 ORDER BY id LIMIT 10; -- 后續(xù)頁使用上一頁最后一條記錄的ID SELECT * FROM orders WHERE user_id 123 AND id 上一頁最后ID ORDER BY id LIMIT 10;8. 分布式事務解決方案8.1 Seata AT模式實戰(zhàn)GlobalTransactional public void placeOrder(OrderRequest request) { // 1. 扣減庫存 productService.reduceStock(request.getProductId(), request.getQuantity()); // 2. 創(chuàng)建訂單 Order order createOrder(request); orderMapper.insert(order); // 3. 扣減余額 accountService.debit(request.getUserId(), order.getAmount()); }AT模式執(zhí)行流程解析SQL生成前后鏡像注冊分支事務報告全局事務狀態(tài)異步進行二階段提交/回滾8.2 TCC模式設計要點public interface OrderTccService { TwoPhaseBusinessAction(name createOrder, commitMethod commit, rollbackMethod rollback) boolean tryCreateOrder(Order order); boolean commit(Order order); boolean rollback(Order order); }TCC注意事項空回滾問題需要判斷try是否執(zhí)行冪等控制網絡重試可能導致重復調用懸掛問題cancel比try先執(zhí)行9. 監(jiān)控與調優(yōu)實戰(zhàn)9.1 關鍵監(jiān)控指標# ShardingSphere監(jiān)控指標示例 shardingsphere_statement_latency_milliseconds_sum{typeSELECT} 1500 shardingsphere_statement_total{typeINSERT} 12000 shardingsphere_routed_data_sources_total 4 shardingsphere_routed_tables_total 32監(jiān)控大盤建議分庫分表路由統(tǒng)計SQL執(zhí)行耗時分布分布式事務成功率連接池使用情況9.2 性能調優(yōu)案例問題現象某系統(tǒng)分庫分表后查詢性能反而下降。排查過程發(fā)現大量IN查詢跨多個分片跟蹤SQL日志確認分片鍵使用不當分析業(yè)務場景90%查詢都帶有create_time條件解決方案將分片鍵從user_id改為(create_time, user_id)組合建立月份分表如orders_202301增加本地緩存減少跨分片查詢優(yōu)化效果平均響應時間從320ms降到85ms數據庫CPU使用率從70%降到35%10. 分庫分表的最佳實踐經過多個項目的實戰(zhàn)我總結了以下黃金法則分片鍵選擇三原則查詢必須帶分片鍵條件數據分布均勻避免跨分片查詢擴容預留空間初始設計時就考慮2-3倍的擴容空間比如預計3年數據量按6年容量設計分片數冷熱據分離熱數據最近3個月用SSD存儲溫數據3-12個月用普通磁盤冷數據歸檔到對象存儲避免過度設計單表百萬級不必分表單庫千萬級不必分庫能用讀寫分離解決的不用分庫分表工具鏈建設數據遷移工具分片鍵在線修改工具數據校驗工具最后給個實用建議在實施分庫分表前先用現有數據做全量壓測模擬分片后的查詢模式這樣可以提前發(fā)現大部分潛在問題。我們曾經用這個方法避免了上線后的三次重大事故。