windows NLB實現MSSQL讀寫分離--從數據庫集群讀負載均衡
阿新 • • 發佈：2018-03-04
sql AC 安裝數據庫 track esp 清華 創建 schema brush
主從模式，幾乎大部分出名的數據庫都支持的一種集群模式。
當Web站點的訪問量上去之後，很多站點，選擇讀寫分離，減輕主數據庫的的壓力。當然，一主多從也可以作用多個功能，比如備份。這裏主要演示如何實現從數據庫集群的讀負載均衡
搭建一主三從的MSSQL集群
192.168.99.250 //主服務器 192.168.99.8 //從服務器(WIN-6S3JNU8C4TB) 192.168.99.10 //從服務器(WIN-HF1GQ5U288H) 192.168.99.11 //從服務器(WIN-EAPJ2QB5AGM)
本地發布
一般而言，我們只需要安裝數據庫引擎服務即可。復制服務需要另外安裝，所以我們進行發布/訂閱模式的話，需要安裝復制組件
192.168.99.250 主服務器發布數據同步，接三臺從服務器訂閱發布。
本地訂閱
同樣本地訂閱，也需要安裝復制組件。
模擬寫數據
using System; using System.ComponentModel.DataAnnotations; using System.ComponentModel.DataAnnotations.Schema; using Microsoft.EntityFrameworkCore; using System.Text; using System.Linq; namespace Write { class Program {static void Main(string[] args) { Console.WriteLine("開始寫入模擬數據"); var ef = new EFDbContext(); var rand = new Random(); StringBuilder str1 = new StringBuilder(); str1.Append("趙、錢、孫、李、周、吳、鄭、王、馮、陳、楮、衛、蔣、沈、韓、楊、朱、秦、尤、許、何、呂、施、張、孔、曹");var familyNameItems = str1.ToString().Split("、"); StringBuilder str2 = new StringBuilder(); str2.Append("宏子 婷婷 蓉蓉 麗娜 娜 鈺 天霞 官君 紅梅 淑慧 海娟 洪山 "); str2.Append("盼麗 艷紅 甜甜 璨 彬彬 銀紅 晨曦 婷 廣榮 蓓 小艷 欣如 輔仁 嘉 雯婷 玉紅 晨霞 "); str2.Append("涵 明 麗娜 青 茵 瑞微 逸群 思陽 臻 勇 誌光 克濤 靖華 慧霞 衛偉 藜文 清華 莎 曉新 "); str2.Append("安安 荌荌 安卉 安娜 安妮 安然 傲冬 傲晴 傲雪 白雪 白雲 碧螺 碧菡 碧玉 冰藍 "); str2.Append("含煙 含玉 涵菡 晗蕾 涵韻 晗玥 寒凝 寒香 寒雁 和悌 和美 和怡 和雅 和璧 和玉 "); str2.Append("紅螺 虹雨 虹彩 虹英 虹穎 虹影 懷玉 慧心 慧穎 慧雅 慕青 問蘭 爾嵐 元香 曼文"); var firstNameItems = str2.ToString().Split(" "); while (true) { string userName = "15" + rand.Next(100000000, 999999999).ToString(); ef.OAUser.Add(new OAUser { UserName = userName, PassWord = "123456", Salt = rand.Next(1111111, 6666666).ToString(), NickName = familyNameItems[rand.Next(0, familyNameItems.Count())] + firstNameItems[rand.Next(0, firstNameItems.Count())], IsFrozen = false, CreateTime = DateTime.Now }); ef.SaveChanges(); Console.WriteLine($"成功將用戶{userName}資料寫入"); } } } public class EFDbContext : DbContext { public EFDbContext() { base.ChangeTracker.AutoDetectChangesEnabled = false; } protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder) { optionsBuilder.UseSqlServer("Data Source=192.168.99.250;Initial Catalog=Test;User Id=sa;Password=123;", n => n.UseRowNumberForPaging()); } /// <summary> /// 用戶表 /// </summary> public DbSet<OAUser> OAUser { set; get; } } /// <summary> /// 用戶表 /// </summary> [Table("OAUser")] public class OAUser { /// <summary> /// 主健 /// </summary> [Key] public int Id { set; get; } /// <summary> /// 用戶賬號 /// </summary> [Required, MaxLength(15), MinLength(6)] public string UserName { set; get; } /// <summary> /// 用戶密碼 /// </summary> [Required, StringLength(64)] public string PassWord { set; get; } /// <summary> /// 昵稱 /// </summary> [Required, StringLength(30)] public string NickName { get; set; } /// <summary> /// 加密鹽 /// </summary> [Required, StringLength(20)] public string Salt { set; get; } /// <summary> /// 是否凍結 /// </summary> public bool IsFrozen { set; get; } /// <summary> /// 創建時間 /// </summary> public DateTime CreateTime { set; get; } } }
搭建NLB集群
192.168.99.120 //公共IP 192.168.99.8 192.168.99.10 192.168.99.11
模擬讀取數據庫
using System; using System.ComponentModel.DataAnnotations; using System.ComponentModel.DataAnnotations.Schema; using Microsoft.EntityFrameworkCore; using System.Text; using System.Linq; namespace Read { class Program { static void Main(string[] args) { Console.WriteLine("模擬大量讀取"); var ef = new EFDbContext(); var i = 0; while (i < 1000) { i++; var user = ef.OAUser.OrderBy(n => Guid.NewGuid()).Take(1).FirstOrDefault(); Console.WriteLine($"讀取用戶{user.UserName}資料"); } Console.WriteLine("讀取完畢"); } } public class EFDbContext : DbContext { public EFDbContext() { base.ChangeTracker.AutoDetectChangesEnabled = false; } protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder) { optionsBuilder.UseSqlServer("Data Source=192.168.99.120;Initial Catalog=oa;User Id=sa;Password=123;", n => n.UseRowNumberForPaging()); } /// <summary> /// 用戶表 /// </summary> public DbSet<OAUser> OAUser { set; get; } } /// <summary> /// 用戶表 /// </summary> [Table("OAUser")] public class OAUser { /// <summary> /// 主健 /// </summary> [Key] public int Id { set; get; } /// <summary> /// 用戶賬號 /// </summary> [Required, MaxLength(15), MinLength(6)] public string UserName { set; get; } /// <summary> /// 用戶密碼 /// </summary> [Required, StringLength(64)] public string PassWord { set; get; } /// <summary> /// 昵稱 /// </summary> [Required, StringLength(30)] public string NickName { get; set; } /// <summary> /// 加密鹽 /// </summary> [Required, StringLength(20)] public string Salt { set; get; } /// <summary> /// 是否凍結 /// </summary> public bool IsFrozen { set; get; } /// <summary> /// 創建時間 /// </summary> public DateTime CreateTime { set; get; } } }
經過多次測試發現，每次只在一臺從服務器上面進行讀取，納悶
後來輸出發現
Console.WriteLine(con.ClientConnectionId);
連接ID一樣，重新啟動，剛連接ID會有變動，然後果另一個從服務器進行大量讀取。
初步猜測，應該是連接池的搞的鬼，如果關閉連接，但是實際上，並沒有關閉數據庫連接，而是歸還連接池。重新打開數據庫，又重連接池分配一條連接。
目前不清楚連接池的分配規則，從結果來看，應該是每次都是分配了相同的程序池連接。
現在暫進不測了，下班走，改天，部署WEB結構，然後用壓力測試測試，看看數據庫讀取是否均衡。
windows NLB實現MSSQL讀寫分離--從數據庫集群讀負載均衡