FreeSql

Table of Contents

使用 FreeSqlCloud 另一种读写分离
参考资料

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

FreeSql 支持数据库读写分离，本功能是客户端的读写分离行为，数据库服务器该怎么配置仍然那样配置，不受本功能影响，为了方便描术后面讲到的【读写分离】都是指客户端的功能支持。

各种数据库的读写方案不一，数据库端开启读写分离功能后，读写分离的实现大致分为以下几种：

1、nginx代理，配置繁琐且容易出错；

2、中件间，如MyCat；

3、在client端支持；

FreeSql 实现了第3种方案，支持一个【主库】多个【从库】，【从库】的查询策略为随机方式。

若某【从库】发生故障，将切换到其他可用【从库】，若已全部不可用则使用【主库】查询。

出现故障【从库】被隔离起来间隔性的检查可用状态，以待恢复。

static IFreeSql fsql = new FreeSql.FreeSqlBuilder()
    .UseConnectionString(FreeSql.DataType.MySql, connectionString)
    .UseSlave("connectionString1", "connectionString2") //使用从数据库，支持多个
    //.UseSlaveWeight(10, 5) //读权重 v3.2.100
    .Build(); //请务必定义成 Singleton 单例模式

fsql.Select<T>().Where(a => a.Id == 1).ToOne(); //读【从库】（默认）

fsql.Select<T>().Master().WhereId(a => a.Id == 1).ToOne(); //强制读【主库】

fsql.Ado.Query<T>("/*master*/ select * from t where ..."); //强制读【主库】

使用 FreeSqlCloud 另一种读写分离

public enum DbEnum { db1, db2, db3 }

var fsql = new FreeSqlCloud();

fsql.Register(DbEnum.db3, () => new FreeSqlBuilder()
    .UseConnectionString(DataType.Sqlite, @"Data Source=:memory:;max pool size=1")
    .UseAutoSyncStructure(true).Build());
fsql.Register(DbEnum.db2, () => new FreeSqlBuilder()
    .UseConnectionString(DataType.Sqlite, @"Data Source=:memory:;max pool size=2")
    .UseAutoSyncStructure(true).Build());
fsql.Register(DbEnum.db1, () => new FreeSqlBuilder()
    .UseConnectionString(DataType.Sqlite, @"Data Source=:memory:;max pool size=3")
    .UseAutoSyncStructure(true).Build());

fsql.EntitySteering = (_, e) =>
{
    switch (e.MethodName)
    {
        case "Select":
            if (e.DBKey == DbEnum.db1) //判断主库时
            {
                var dbkeyIndex = new Random().Next(0, e.AvailableDBKeys.Length);
                e.DBKey = e.AvailableDBKeys[dbkeyIndex]; //重新定向到其他 db
            }
            break;
        case "Insert":
        case "Update":
        case "Delete":
        case "InsertOrUpdate":
            break;
    }
};

使用 FreeSqlCloud 另一种读写分离

参考资料

Basic

使用指南

学习与交流

信息