好得很程序员自学网

<tfoot draggable='sEl'></tfoot>

读写分离,就该这么改进

读写分离,就该这么改进

读写分离,就该这么改进

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

一般做数据库读写分离的标准情况是: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.com/  
博客地址: http://www.cnblogs.com/happyframework/

 

分类:  .NET

作者: Leo_wl

    

出处: http://www.cnblogs.com/Leo_wl/

    

本文版权归作者和博客园共有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接,否则保留追究法律责任的权利。

版权信息

查看更多关于读写分离,就该这么改进的详细内容...

  阅读:45次