读写分离,就该这么改进
读写分离,就该这么改进
本文是自己对读写分离数据库方面的一些改进想法
一般做数据库读写分离的标准情况是: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 }
四种隔离级别如何处理并发问题 脏读 不可重复读 幻读 读未提交 允许 允许 允许 读已提交 不允许 允许 允许 可重复读 不允许 不允许 允许 串行化 不允许 不允许 不允许
框架地址: http://happy.codeplex测试数据/
博客地址: http://HdhCmsTestcnblogs测试数据/happyframework/
分类: .NET
作者: Leo_wl
出处: http://HdhCmsTestcnblogs测试数据/Leo_wl/
本文版权归作者和博客园共有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接,否则保留追究法律责任的权利。
版权信息