資料庫中間件ShardingSphere-Proxy(一)

来源:https://www.cnblogs.com/yuxl01/archive/2022/03/27/16063976.html
-Advertisement-
Play Games

1.現實中的問題 我們知道資料庫的數據，基本80%的業務是查詢，20%的業務涵蓋了增刪改，經過長期的業務變更和積累資料庫的數據到達了一定的數量之後，直接影響的是用戶與系統的交互，查詢時的速度，插入數據時的流暢度，系統的可用性，這些指標對用戶體驗都是會有影響的，不說用戶，你自己用是什麼感覺？我經歷過且 ...


1.現實中的問題

我們知道資料庫的數據，基本80%的業務是查詢，20%的業務涵蓋了增刪改，經過長期的業務變更和積累資料庫的數據到達了一定的數量之後，直接影響的是用戶與系統的交互，查詢時的速度，插入數據時的流暢度，系統的可用性，這些指標對用戶體驗都是會有影響的，不說用戶，你自己用是什麼感覺？我經歷過且常見的無非以下幾個解決方案，從用戶，代碼，資料庫，不知道有沒有人跟我有相似的經歷

1.最簡單粗暴的就是從用戶下手，也就是通過業務的手段來約束，限定查詢時間，限定查詢條件，大批量需要申請後臺工程師導出，不是說對這些方法嗤之以鼻，在某些場景下這樣也是不錯的方法.

2.檢查代碼，查詢語句什麼的能優化的做下優化，這一點確實也是比較關鍵的，再好的架構和伺服器，也頂不住遞歸死迴圈查詢這些.

3.結合一些資料庫監控工具或者對常用查詢的表，做一些資料庫基本的屬性設定，例如資料庫加索引，分分區.

雖然確實可以使用這些技術手段來提升本身的查詢速度，但是達到一定量級，這些手段得到的改善也不是很大，因為數據的量是實實在在的存在，假設此時加上併發量的增大，資料庫引擎在查詢或者計算時，使用的是伺服器的CPU和記憶體，當資源消耗過高時，直接降低系統可用性，往往這個時候就需要通過整體業務上的變通或者技術架構的轉換上來著手解決問題了。
然而現實中業務上的改變，可能在落實上會存在很大的問題，但是可以從技術架構上來嘗試解決，主要在代碼整體架構或者資料庫存儲架構解決了，我們主要介紹數據架構層面的方案。

1.分庫

  • 在水平分庫中，就是將資料庫中的表，存到不同的資料庫，但是不同庫的表數量和結構是一樣的，只是每個庫的數據都不一樣，沒有交集，庫的並集是全量數據

  • 在垂直分庫中，以表為依據，按照業務歸屬不同，將不同的表拆分到不同的庫中，不同的庫存儲的可能是不同的表，庫的並集是全量數據

2.分表

  • 水平分表就是將一張表分為多張表，表的結構都一樣，每個表的數據都不一樣，沒有交集，所有表的並集是全量數據；

  • 垂直分表將一張表欄位拆分為不同的表，合併起來就是整個全量數據，但是這種可以歸屬於設計之初的設計缺陷

雖然使用分庫分表可以一定程度解決上面所說的問題，但是分了之後也有可能再變大，總不能一直無腦拆分下去把，此時應該使用讀寫分離，也就是說讀寫分離應該是在分庫分表的基礎之上來實施的。

2.什麼是ShardingSphere-Proxy？

在ShardingSphere中一共有3個核心組件 ShardingSphere-JDBC 定位是一個Java的框架 、ShardingSphere-Proxy、ShardingSphere-Sidecar 還在開發中，我們主要介紹ShardingSphere-Proxy和ShardingSphere-Proxy的實際應用。

ShardingSphere-Proxy定位為透明化的資料庫代理端，提供封裝了資料庫二進位協議的服務端版本，用於完成對異構語言的支持，主要目的對資料庫實現分庫分表和讀寫分離,應用場景不管是傳統的單體項目，或者現有流行的微服務項目中都可以使用，但是目前只支持 MySQL 和 PostgreSQL ， 它在整個系統架構中定位是一個資料庫中間件。

在這裡我們選擇使用ShardingSphere-Proxy中間件，來作為我們實現分庫分表的工具，寫這個的目的主要是記錄ShardingSphere-Proxy的使用和一些基本的概念，至於說具體分成什麼樣，如果您只想知道到底是分表，還是分庫，又或者是分庫分表，我可能幫不了什麼，但是您可以按照現在所困擾的問題展開分析，然後使用ShardingSphere-Proxy落地。

3.分庫分表方案

實現分庫分表的方案根據不同的需求可能會延伸出很多，但是我們在邏輯上抽象出2種，一種是進程內和業務系統集成，一種是拆分出分庫分表作為獨立進程，

1.進程內方案

進程內的方案通常是將分庫分表實現業務放到系統內部,通常存在以下缺陷

  • 1.系統和分庫分表會存在資源競爭

  • 2.一個異常的話，另外一個也會異常，依賴性太強。

  • 3.無法適應異構，對其他語言的支持

2.進程外方案

進程外方案將分庫分表邏輯拆分，使用單獨的工具實現客戶端將請求發送到系統， 系統通過資料庫中間件在內部進行分庫分表邏輯，然後存儲資料庫，通常存在以下缺陷

  • 1.維護量上升

  • 2.相對進程內，性能會差一點，但是如果內網部署基本可以接受

4.ShardingSphere-Proxy基本概念

使用ShardingSphere-Proxy在進行實現分庫分表或者查詢時，主要有6個階段，這整個階段中的核心步驟是由中間件來實現的。

  • 1.選擇具體資料庫

  • 2.sql解析將中間件連接成為真實資料庫連接

  • 3.sql路由，選擇一個真實資料庫執行

  • 4.sql重寫優化

  • 5.sql執行真實資料庫獲取結果

  • 6.結果合併從多個表或者庫中獲取結果

用戶主要是針對路由規則的配置，實現將數據分片到不同表以及不同的庫，那我們應該思考如何對數據進行分片呢，需要哪些條件？

  • 1.分片鍵:數據表中的欄位，選擇以哪個欄位作為分片的條件。

  • 2.分片演算法：它的作用就是根據分片數據欄位如何去實現數據的分片。

5.項目環境及搭建

ShardingSphere-Proxy是由java開發，所以首先我們需要準備java的基本環境。

1.環境準備
6.分庫分表配置
1.ShardingSphere-Proxy 分表

1.以數據採集資料庫的電源信息數據表為例,如果沒有資料庫就創建資料庫

2.在ShardingSphere-Proxy中的conf下找到config-sharding.yaml配置文件進行配置

3.在config-sharding.yaml中配置資料庫連接

dataSources:
  dataacquisitionsources_0:
    url: jdbc:mysql://localhost:3306/dataacquisition?serverTimezone=UTC&useSSL=false
    username: root
    password: 123456
    connectionTimeoutMilliseconds: 30000
    idleTimeoutMilliseconds: 60000
    maxLifetimeMilliseconds: 1800000
    maxPoolSize: 50
    minPoolSize: 1

4.配置表和數據的分片規則

    1. actualDataNodes節點用來配置分成幾張表{0..1}就是2張，如果配置10張那就{0..9}
    1. 如果多張表分表就使用多個邏輯表名和節點，註意一定要註意配置格式
rules:
- !SHARDING
  tables:
    powerinformation:# 邏輯表名
      actualDataNodes: dataacquisitionsources_0.powerinformation_${0..1} #分表
      tableStrategy: #數據分表策略
        standard:
          shardingColumn: id #分表欄位
          shardingAlgorithmName: powerinformation_MOD
  shardingAlgorithms:
    powerinformation_MOD:
      type: MOD
      props:
        sharding-count: 2

5.配置客戶端連接虛擬資料庫，一般和真實庫名對應

schemaName: dataacquisition

6.打開配置目錄的server.yaml配置文件，來設置用戶和密碼

rules:
  - !AUTHORITY
    users:
      - root@%:root
      - sharding@:sharding
    provider:
      type: ALL_PRIVILEGES_PERMITTED

7.啟動bin目錄下的start.bat,如果出現以下畫面，那麼恭喜你中間件被成功配置

8.使用客戶端連接虛擬伺服器3307埠

9.執行腳本在虛擬伺服器上創建表結構，那麼中間件會預設按照預定的規則分表

create table powerinformation
(
 id int not null  AUTO_INCREMENT PRIMARY key,
 Station Text,
 voltage DECIMAL,
 resistance DECIMAL,
 electricity DECIMAL,
 createDate DATETIME
)
COLLATE='utf8_general_ci'
ENGINE=InnoDB
AUTO_INCREMENT=2
;

10.打開客戶端查看真實庫已經分表成功

2.ShardingSphere-Proxy 分庫

1.創建2個資料庫分別取名為dataacquisition_0和dataacquisition_1

2.打開配置文件,對代理配置不同資料庫連接

dataSources:
  dataacquisitionsources_0:
    url: jdbc:mysql://127.0.0.1:3306/dataacquisition_0?serverTimezone=UTC&useSSL=false #連接庫0
    username: root
    password: sa@123456
    connectionTimeoutMilliseconds: 30000
    idleTimeoutMilliseconds: 60000
    maxLifetimeMilliseconds: 1800000
    maxPoolSize: 50
    minPoolSize: 1
  dataacquisitionsources_1:
    url: jdbc:mysql://127.0.0.1:3306/dataacquisition_1?serverTimezone=UTC&useSSL=false #連接庫1
    username: root
    password: sa@123456
    connectionTimeoutMilliseconds: 30000
    idleTimeoutMilliseconds: 60000
    maxLifetimeMilliseconds: 1800000
    maxPoolSize: 50
    minPoolSize: 1

3.配置分庫規則，由於現在是2個不同的庫,所以不需要配置數據分到表的規則

rules:
- !SHARDING
  tables:
    powerinformation:
      actualDataNodes: dataacquisitionsources_${0..1}.powerinformation  #庫名錶達式
      databaseStrategy: #數據分庫策略
          standard:
            shardingColumn: id
            shardingAlgorithmName: powerinformation_MOD     
  shardingAlgorithms:
    powerinformation_MOD:
      type: MOD
      props:
        sharding-count: 2

4.在虛擬庫中添加表和數據將會分配到2個不同的庫

3.ShardingSphere-Proxy 分庫分表

1.按照分庫的操作執行,分庫配置不變
2.配置文件配置分庫分表的規則

rules:
- !SHARDING
  tables:
    powerinformation:
      actualDataNodes: dataacquisitionsources_${0..1}.powerinformation_${0..1}
      tableStrategy:
        standard:
          shardingColumn: id
          shardingAlgorithmName: powerinformation_MOD
      databaseStrategy:
          standard:
            shardingColumn: id
            shardingAlgorithmName: powerinformation_MOD     
  shardingAlgorithms:
    powerinformation_MOD:
      type: MOD
      props:
        sharding-count: 2
7.搭建常見問題

1.由於是yaml文件，一定要註意對應節點的格式對齊

2.建議使用大於等於5.0.0+版本 折騰4.0.0版本被噁心吐了

3.如果出現 near 0這種錯誤就是在配置中使用了特殊符號 建議使用 下劃線的"_"


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 【C/C++】編程基礎
    博客推行版本更新，成果積累制度，已經寫過的博客還會再次更新，不斷地琢磨，高質量高數量都是要追求的，工匠精神是學習必不可少的精神。因此，大家有何建議歡迎在評論區踴躍發言，你們的支持是我最大的動力，你們敢投，我就敢肝 ...
  • Map集合（鍵-找值遍歷--------鍵值對對象遍歷）
    鍵值遍歷 package cn.itcast_01; import java.util.HashMap; import java.util.Map; import java.util.Set; /* * Map集合的遍歷。 * Map -- 夫妻對 * 思路： * A:把所有的丈夫給集中起來。 * ...
  • Java線程通信
    Java線程通信 螣蛇乘霧，終為土灰。 多個線程協同工作完成某個任務時就會涉及到線程間通信問題。如何使各個線程之間同時執行，順序執行、交叉執行等。 一、線程同時執行 創建兩個線程a和b，兩個線程內調用同一個列印 1-3 三個數字的方法。 1 package tjt; 2 3 import java. ...
  • request和response——請求響應對象
    請求對象——request 獲取get請求的值 一次請求，返回一個響應。 地址欄：http://127.0.0.1:8000/day3/get_request?lan=python 問號：代表請求參數 需求：拿到請求參數 傳入單個值 # views.py def get_request(reques ...
  • 網易互聯網筆試（3.27）
    網易互聯網筆試（3.27） 網易互聯網3.27日筆試，四道筆試題一道簡答題，四道筆試題AK，簡答題考察設計模式不會。 第一道題模擬使用單體技能和群體技能攻擊怪物的場景、第二題字元串處理、第三題構造具有限制條件的完全二叉樹、第四題動態規劃問題。 題目 第一題 題意 給定兩個怪，分別具有a，b血量；給定 ...
  • Java9的模塊化是什麼
    來源：https://zhenbianshu.github.io/ 將相似或重覆請求在上游系統中合併後發往下游系統，可以大大降低下游系統的負載，提升系統整體吞吐率。 文章介紹了 hystrix collapser、ConcurrentHashMultiset、自實現BatchCollapser 三種 ...
  • 老徐和阿珍的故事：ArrayList和LinkedList的效率到底哪個高？
    人物背景： 老徐，男，本名徐福貴，從事Java相關研發工作多年，職場老油條，摸魚小能手，雖然歲數不大但長的比較著急，人稱老徐。據說之前炒某幣敗光了所有家產，甚至現在還有欠債。 阿珍，女，本名陳家珍，剛剛入職不久的實習生，雖然是職場菜鳥但聰明好學。據說是學校的四大校花之一，追求她的人從旺角排到了銅鑼灣 ...
  • [WPF] 假裝可變字體
    1. 可變字體 上圖中的兩個動畫，一個文字直接變粗，一個漸漸變粗，我覺得後者會更有趣。但普通的字體可達不到這種效果，例如微軟雅黑，無論怎麼調整它的 FontWeight，實際上它也只有三種粗細： 這時候我們需要可變字體，可變字體（Variable fonts）是OpenType字體規範上的演進，它允 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類