快捷導(dǎo)航

詳解在.net core中完美解決多租戶分庫分表的問題

更新時間：2020年04月14日 14:29:02 作者：hubro

這篇文章主要介紹了詳解在.net core中完美解決多租戶分庫分表的問題，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

前幾天有人想做一個多租戶的平臺,每個租戶一個庫,可以進(jìn)行水平擴(kuò)展,應(yīng)用端根據(jù)登錄信息,切換到不同的租戶庫

計劃用ef core實現(xiàn),他們說做不出來,需要動態(tài)創(chuàng)建dbContext,不好實現(xiàn)

然而這個使用CRL很輕松就能解決了

以下為演示數(shù)據(jù)庫,有兩個庫testdb和testdb2,查詢結(jié)果如下

目標(biāo):

根據(jù)傳入登錄信息連不不同的庫,查詢返回結(jié)果,如登錄人為01,返回d1.default,登錄人為02 返回 d2.default

實際上這個需求就是分庫分表的實現(xiàn),通過設(shè)置數(shù)據(jù)庫/表映射關(guān)系,根據(jù)傳入的定位數(shù)據(jù)進(jìn)行匹配,找到正確的庫表配置,生成數(shù)據(jù)訪問對象

以core控制臺程序為例

class Program
  {
    static IServiceProvider provider;
    static Program()
    {
      var services = new ServiceCollection();
      services.AddCRL<DBLocationCreator>();
      services.AddScoped<Code.Sharding.MemberManage>();

      provider = services.BuildServiceProvider();
      provider.UseCRL();
    }

    static void Main(string[] args)
    {

    label1:
      var instance = provider.GetService<Code.Sharding.MemberManage>();
      var data = new Code.Sharding.MemberSharding();

      data.Code = "01";
      instance.SetLocation(data);
      var find1 = instance.QueryItem(b => b.Id > 0)?.Name;
      Console.WriteLine($"定位數(shù)據(jù)輸入{data.Code},查詢值為{find1}");

      data.Code = "02";
      instance.SetLocation(data);
      var find2 = instance.QueryItem(b => b.Id > 0)?.Name;
      Console.WriteLine($"定位數(shù)據(jù)輸入{data.Code},查詢值為{find2}");
      Console.ReadLine();
      goto label1;
    }
  }

上面代碼中,通過SetLocation方法傳入定位數(shù)據(jù)Code,通過QueryItem方法查詢出數(shù)據(jù)并打印出來

通過services.AddCRL<DBLocationCreator>()注入定位配置,DBLocationCreator繼承了接口IDBLocationCreator

這里完全符合core注入規(guī)范,可以通過配置或數(shù)據(jù)庫存儲動態(tài)讀取定位設(shè)置

public class DBLocationCreator : IDBLocationCreator
  {
    ISettingConfigBuilder _settingConfigBuilder;
    public DBLocationCreator(ISettingConfigBuilder settingConfigBuilder)
    {
      _settingConfigBuilder = settingConfigBuilder;
    }

    public void Init()
    {
      //自定義定位
      _settingConfigBuilder.RegisterLocation<Code.Sharding.MemberSharding>((t, a) =>
      {
        var tableName = t.TableName;
        var dbName = a.Code == "02" ? "testdb2" : "testdb";
        var dataBase = $"Data Source=.;Initial Catalog={dbName};User ID=sa;Password=123";
        //返回定位庫和表名
        return new CRL.Sharding.Location(dataBase, tableName);
      });
      _settingConfigBuilder.RegisterDBAccessBuild(dbLocation =>
      {
        var connectionString = "Data Source=.;Initial Catalog=testdb;User ID=sa;Password=123";
        if (dbLocation.ShardingLocation != null)
        {
          connectionString = dbLocation.ShardingLocation.DataBaseSource;
        }
        return new CRL.DBAccessBuild(DBType.MSSQL, connectionString);
      });
    }
  }

在Init方法里,實現(xiàn)了兩個操作,通過RegisterLocation定義如何根據(jù)定位數(shù)據(jù)Code,返回不同的庫/表

通過RegisterDBAccessBuild實現(xiàn)數(shù)據(jù)訪問

運(yùn)行測試程序,結(jié)果輸出為