读写分离,就该这么改进

读写分离,就该这么改进

本文是自己对读写分离数据库方面的一些改进想法

一般做数据库读写分离的标准情况是:1台写入数据库+2台查询数据库+1个请求转发器
这样的配置容易出现这样的问题:

1. 写数据库的写入成为瓶颈

2. 查询所需时间还是很长(由于表很大导致)

下面这些办法是最近思考得出的,没有经过实践的验证,欢迎大家给出各自的看法

解决办法一:


1.
 查询数据库:增加内存,以达到通过内存就可以获取大多数的数据,较少I/O耗时带来的延迟


2.
 写入数据库:删除索引,以达到最快速的I/O写入耗时


这样做的问题是:没有针对特别耗时的查询单独处理,因此当执行某些耗时的查询时,会显得特别慢

解决办法二:


1. 查询数据库分成2种,分别为:普通数据读取数据库特别耗时查询数据库


2. 针对“特别耗时查询数据库”进行优化,比如:定制索引、分区表、多物理磁盘等


程序中需要为上面这些点进行编码,比如要辨别出哪些是耗时的查询、自动辨别以便下次直接转发查询请求到“特别耗时查询数据库”

欢迎大家pk出不同的想法,哈哈。

自省推动进步,视野决定未来。
心怀远大理想。
为了家庭幸福而努力。
 

.NET:脏读、不可重复读和幻读代码示例

 

并发可能产生的三种问题

脏读

定义:A事务执行过程中B事务读取了A事务的修改,但是A事务并没有结束(提交),A事务后来可能成功也可能失败。

比喻:A修改了源代码并且并没有提交到源代码系统,A直接通过QQ将代码发给了B,A后来取消了修改。

代码示例

复制代码
 1         [TestMethod]
 2         public void 脏读_测试()
 3         {
 4             //前置条件
 5             using (var context = new TestEntities())
 6             {
 7                 Assert.AreEqual(1, context.Tables.Count());
 8             }
 9 
10             var autoResetEvent = new AutoResetEvent(false);
11 
12             var transactionOptions1 = new TransactionOptions { IsolationLevel = IsolationLevel.ReadCommitted };
13             var transactionOptions2 = new TransactionOptions { IsolationLevel = IsolationLevel.ReadUncommitted };
14 
15             using (var ts1 = new TransactionScope(TransactionScopeOption.Required, transactionOptions1))
16             {
17                 //添加数据
18                 using (var context = new TestEntities())
19                 {
20                     context.Tables.Add(new Table() { Id = Guid.NewGuid(), Name = "段光伟" });
21                     context.SaveChanges();
22                 }
23 
24                 ThreadPool.QueueUserWorkItem(data =>
25                 {
26                     using (var ts2 = new TransactionScope(TransactionScopeOption.Required, transactionOptions2))
27                     {
28                         //脏读测试
29                         using (var context = new TestEntities())
30                         {
31                             Assert.AreEqual(2, context.Tables.Count());
32                         }
33                     }
34 
35                     autoResetEvent.Set();
36                 });
37 
38                 autoResetEvent.WaitOne();
39             }
40 
41             //前置条件
42             using (var context = new TestEntities())
43             {
44                 Assert.AreEqual(1, context.Tables.Count());
45             }
46         }
复制代码

不可重复读

定义:A事务读取了两次数据,在这两次的读取过程中B事务修改了数据,A事务的这两次读取出来的数据不一样了(不可重复读)。

比喻:A在做源代码审查,在审查的过程中获取了两次源代码,在这两次获取期间B修改了源代码,B修改的很可能是A审查过的代码,而这部分代码可能不符合规范了。

代码示例

复制代码
 1         [TestMethod]
 2         public void 不可重复读_测试()
 3         {
 4             var autoResetEvent = new AutoResetEvent(false);
 5 
 6             var transactionOptions1 = new TransactionOptions { IsolationLevel = IsolationLevel.ReadCommitted };
 7             var transactionOptions2 = new TransactionOptions { IsolationLevel = IsolationLevel.ReadCommitted };
 8 
 9             using (var ts1 = new TransactionScope(TransactionScopeOption.Required, transactionOptions1))
10             {
11                 //前置条件
12                 using (var context = new TestEntities())
13                 {
14                     Assert.AreEqual("李妞妞", context.Tables.First().Name);
15                 }
16 
17                 ThreadPool.QueueUserWorkItem(data =>
18                 {
19                     using (var ts2 = new TransactionScope(TransactionScopeOption.Required, transactionOptions2))
20                     {
21                         //修改数据
22                         using (var context = new TestEntities())
23                         {
24                             context.Tables.First().Name = "段光伟";
25                             context.SaveChanges();
26                         }
27 
28                         ts2.Complete();    
29                     }
30 
31                     autoResetEvent.Set();
32                 });
33 
34                 autoResetEvent.WaitOne();
35 
36                 //不可重复读测试
37                 using (var context = new TestEntities())
38                 {
39                     Assert.AreEqual("段光伟", context.Tables.First().Name);
40                 }
41             }
42         }
复制代码

幻读

定义:A事务读取了两次数据,在这两次的读取过程中B事务添加了数据,A事务的这两次读取出来的集合不一样了(幻读)。

比喻:A在统计文件数据,为了统计精确A统计了两次,在这两次的统计过程中B添加了一个文件,A发现这两次统计的数量不一样(幻读),A会感觉自己的脑袋有点头疼。

代码示例

复制代码
 1         [TestMethod]
 2         public void 幻读_测试()
 3         {
 4             var autoResetEvent = new AutoResetEvent(false);
 5 
 6             var transactionOptions1 = new TransactionOptions { IsolationLevel = IsolationLevel.RepeatableRead };
 7             var transactionOptions2 = new TransactionOptions { IsolationLevel = IsolationLevel.ReadCommitted };
 8 
 9             using (var ts1 = new TransactionScope(TransactionScopeOption.Required, transactionOptions1))
10             {
11                 //前置条件
12                 using (var context = new TestEntities())
13                 {
14                     Assert.AreEqual(1, context.Tables.Count());
15                 }
16 
17                 ThreadPool.QueueUserWorkItem(data =>
18                 {
19                     using (var ts2 = new TransactionScope(TransactionScopeOption.Required, transactionOptions2))
20                     {
21                         //添加数据
22                         using (var context = new TestEntities())
23                         {
24                             context.Tables.Add(new Table() { Id = Guid.NewGuid(), Name = "段光伟" });
25                             context.SaveChanges();
26                         }
27 
28                         ts2.Complete();
29                     }
30 
31                     autoResetEvent.Set();
32                 });
33 
34                 autoResetEvent.WaitOne();
35 
36                 //幻读测试
37                 using (var context = new TestEntities())
38                 {
39                     Assert.AreEqual(2, context.Tables.Count());
40                 }
41             }
42         }
复制代码

四种隔离级别如何处理并发问题

  脏读 不可重复读 幻读
读未提交 允许 允许 允许
读已提交 不允许 允许 允许
可重复读 不允许 不允许 允许
串行化 不允许 不允许 不允许
 
分类: .NET
原文地址:https://www.cnblogs.com/Leo_wl/p/3023122.html