溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

ShardingSphere中配置體系是如何設計的

發(fā)布時間:2021-12-20 11:14:35 來源:億速云 閱讀:167 作者:小新 欄目:大數(shù)據(jù)

這篇文章給大家分享的是有關ShardingSphere中配置體系是如何設計的的內(nèi)容。小編覺得挺實用的,因此分享給大家做個參考,一起跟隨小編過來看看吧。

什么是行表達式?

行表達式是 ShardingSphere 中用于實現(xiàn)簡化和統(tǒng)一配置信息的一種工具,在日常開發(fā)過程中應用得非常廣泛。 它的使用方式非常直觀,只需要在配置中使用 ${expression} 或 $->{expression} 表達式即可。

基于行表達式語法,${begin..end} 表示的是一個從"begin"到"end"的范圍區(qū)間,而多個 ${expression} 之間可以用"."符號進行連接,代表多個表達式數(shù)值之間的一種笛卡爾積關系。

類似場景也可以使用枚舉的方式來列舉所有可能值。行表達式也提供了 ${[enum1, enum2,…, enumx]} 語法來表示枚舉值,所以"ds${0..1}.user${0..1}"的效果等同于"ds${[0,1]}.user${[0,1]}"。

由于 ${expression} 與 Spring 本身的屬性文件占位符沖突,而 Spring 又是目前主流的開發(fā)框架,因此在正式環(huán)境中建議你使用 $->{expression} 來進行配置。

ShardingSphere有哪些核心配置?

對于分庫分表、讀寫分離操作而言,配置的主要任務是完成各種規(guī)則的創(chuàng)建和初始化。配置是整個ShardingSphere的核心,也是我們?nèi)粘i_發(fā)過程中的抓藥工作。可以說,只要我們掌握了ShardingSphere的核心配置項,就相當于掌握了這個框架的使用方法。那么,ShardingSphere 有哪些核心配置呢?這里以分片引擎為例介紹最常用的幾個配置項,而與讀寫分離、數(shù)據(jù)脫敏、編排治理相關的配置項我們會在介紹具體的應用場景時再做展開。

ShardingRuleConfiguration

DataSource是我們使用ShardingSphere的入口,創(chuàng)建DataSource的過程中使用到了一個ShardingDataSourceFactory類,這個工廠類的構造函數(shù)中需要傳入一個ShardingRuleConfiguration對象。顯然,從命名上看,這個ShardingRuleConfiguration就是用于分片規(guī)則的配置入口。

ShardingRuleConfiguration中所需要配置的規(guī)則比較多,下面通過一張圖例來進行簡單說明

ShardingSphere中配置體系是如何設計的

事實上,對于ShardingRuleConfiguration而言,必須要設置的只有一個配置項,即TableRuleConfiguration。

TableRuleConfiguration

從命名上看,TableRuleConfiguration是表分片規(guī)則配置,但事實上,這個類同時包含了對分庫和分表兩種場景的設置,TableRuleConfiguration包含很多重要的配置項:

  • actualDataNodes:代表真實的數(shù)據(jù)節(jié)點,由數(shù)據(jù)源名+表名組成,支持行表達式。例如:ds${0..1}.user${0..1}

  • databaseShardingStrategyConfig:代表分表策略,如果不設置也會使用默認分表策略,這里的默認分表策略同樣來自ShardingRuleConfiguration中的defaultTableShardingStrategyConfig配置

  • keyGeneratorConfig:代表分布式環(huán)境下的自增列生成器配置,ShardingSphere中集成了雪花算法等分布式ID的生成器實現(xiàn)。

ShardingStrategyConfiguration

dataBaseShardingStrategyConfig和tableShardingStrategyConfig的類型都是一個ShardingStrategyConfiguration對象。在ShardingSphere中,ShardingStrategyConfiguration實際上是一個空接口,存在一系列的實現(xiàn)類,其中的每個實現(xiàn)類都代表一種分片策略:

ShardingSphere中配置體系是如何設計的

在這些具體的分片策略中,通常需要指定一個分片列 shardingColumn 以及一個或多個分片算法 ShardingAlgorithm。

KeyGeneratorConfiguration

可以想象,對于一個自增列而言,KeyGeneratorConfiguration 中首先需要指定一個列名 column。同時,因為 ShardingSphere 中內(nèi)置了一批自增列的實現(xiàn)機制(例如雪花算法 SNOWFLAKE 以及通用唯一識別碼 UUID),所以需要通過一個 type 配置項進行指定

ShardingSphere提供了哪些配置方式?

ShardingSphere提供了4種配置方式。用于不同的使用場景:

  • Java代碼配置

  • Yaml配置

  • Spring命名空間配置

  • Spring Boot配置

[詳細配置看官網(wǎng)](https://shardingsphere.apache.org/document/legacy/4.x/document/cn/manual/sharding-jdbc/configuration/ "詳細配置看官網(wǎng)")

ShardingSphere的配置體系是如何實現(xiàn)的?

ShardingRuleConfiguration配置體系

對于ShardingSphere而言,配置體系的作用本質(zhì)上就是用來初始化DataSource等JDBC對象。例如,ShardingDataSourceFactory就是基于傳入的數(shù)據(jù)源Map、ShardingRuleConfiguration以及Properties來創(chuàng)建一個ShardingDataSource對象:

public final class ShardingDataSourceFactory {

    public static DataSource createDataSource(
            final Map<String, DataSource> dataSourceMap, final ShardingRuleConfiguration shardingRuleConfig, final Properties props) throws SQLException {
        return new ShardingDataSource(dataSourceMap, new ShardingRule(shardingRuleConfig, dataSourceMap.keySet()), props);
	} 
}

在 ShardingSphere 中,所有規(guī)則配置類都實現(xiàn)了一個頂層接口 RuleConfiguration。RuleConfiguration 是一個空接口,ShardingRuleConfiguration 就是這個接口的實現(xiàn)類之一,專門用來處理分片引擎的應用場景。下面這段代碼就是 ShardingRuleConfiguration 類的實現(xiàn)過程:

public final class ShardingRuleConfiguration implements RuleConfiguration {
    //表分片規(guī)則列表
    private Collection<TableRuleConfiguration> tableRuleConfigs = new LinkedList<>();
    //綁定表規(guī)則列表
    private Collection<String> bindingTableGroups = new LinkedList<>();
    //廣播表規(guī)則列表
    private Collection<String> broadcastTables = new LinkedList<>();
    //默認數(shù)據(jù)源
    private String defaultDataSourceName;
    //默認分庫策略
    private ShardingStrategyConfiguration defaultDatabaseShardingStrategyConfig;
    //默認分表策略
    private ShardingStrategyConfiguration defaultTableShardingStrategyConfig;
    //默認自增列值生成器
    private KeyGeneratorConfiguration defaultKeyGeneratorConfig;
    //讀寫分離規(guī)則
    private Collection<MasterSlaveRuleConfiguration> masterSlaveRuleConfigs = new LinkedList<>();
    //數(shù)據(jù)脫敏規(guī)則
    private EncryptRuleConfiguration encryptRuleConfig;
}

可以看到,ShardingRuleConfiguration 中包含的就是一系列的配置類定義,通過前面的內(nèi)容介紹,我們已經(jīng)明白了這些配置類的作用和使用方法。其中,核心的 TableRuleConfiguration 定義也比較簡單,主要包含了邏輯表、真實數(shù)據(jù)節(jié)點以及分庫策略和分表策略的定義:

public final class TableRuleConfiguration {
    //邏輯表
    private final String logicTable;
    //真實數(shù)據(jù)節(jié)點
    private final String actualDataNodes;
    //分庫策略
    private ShardingStrategyConfiguration databaseShardingStrategyConfig;
    //分表策略
    private ShardingStrategyConfiguration tableShardingStrategyConfig;
    //自增列生成器
    private KeyGeneratorConfiguration keyGeneratorConfig;

    public TableRuleConfiguration(final String logicTable) {
        this(logicTable, null);
    }

    public TableRuleConfiguration(final String logicTable, final String actualDataNodes) {
        Preconditions.checkArgument(!Strings.isNullOrEmpty(logicTable), "LogicTable is required.");
        this.logicTable = logicTable;
        this.actualDataNodes = actualDataNodes;
    }
}

無論采用哪種配置方式,所有的配置項都是在這些核心配置類的基礎之上進行封裝和轉換。最終生成ShardingRuleConfiguration,然后通過ShardingDataSourceFatory生成ShardingDataSource獲取連接。

感謝各位的閱讀!關于“ShardingSphere中配置體系是如何設計的”這篇文章就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,讓大家可以學到更多知識,如果覺得文章不錯,可以把它分享出去讓更多的人看到吧!

向AI問一下細節(jié)

免責聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權內(nèi)容。

AI