- Notifications
You must be signed in to change notification settings - Fork 893
读写分离
2881099 edited this page May 6, 2025 · 25 revisions
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 ..."); //强制读【主库】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; } };