转载

Redis学习笔记~Redis事务机制与Lind.DDD.Repositories.Redis事务机制的实现

回到目录

Redis本身支持事务,这就是SQL数据库有Transaction一样,而Redis的驱动也支持事务,这在ServiceStack.Redis就有所体现,它也是目前最受业界认可的Redis驱动,而它将Redis的事务机制( MULTI ,Exec,Watch等)封装成了比较友好的实现方式,如下面的代码

using (IRedisClient RClient = prcm.GetClient()) { using (IRedisTransaction IRT = RClient.CreateTransaction())  {   IRT.QueueCommand(r => r.AddItemToList("zzl", "2"));   IRT.QueueCommand(r => r.AddItemToList("lr", "2"));   IRT.Commit(); // 提交事务  } }

当然上面漂亮的代码有一些功劳要归于C#漂亮的语法,你在JAVA里可以很难写出如此漂亮的东西,当然上面的代码是ServiceStack.Redis为我们封装的,平时我们可以直接使用,现在再说一下大叔Lind.DDD框架里的RedisRepository对它的支持!

如果大叔RedisRepository想支持redis事务,前提: 仓储的IRedisClient必须与产生事务的IRedisClient是同一个对象 ,否则redis事务在大叔框架里不会起作用

实现方法:

一 RedisRepository<T>实现SetDataContext方法,将 IRedisClient 从外面传入,这样可以保存事务的和仓储的用的是一个对象

public void SetDataContext(object db) {  try  {   //手动Redis数据库对象,在redis事务时启用   redisDB = (IRedisClient)db;   redisTypedClient = redisDB.GetTypedClient<TEntity>();   table = redisTypedClient.Lists[typeof(TEntity).Name];  }  catch (Exception)  {   throw new ArgumentException("redis.SetDataContext要求db为IRedisClient类型");  } }

二添加基于Redis的事务管理者,让大叔仓储与事务更好的结合,方便开发人员的使用

/// <summary> /// Redis事务管理机制 /// </summary> public class RedisTransactionManager {  /// <summary>  /// 事务块处理  /// </summary>  /// <param name="redisClient">当前redis库</param>  /// <param name="action">事务中的动作</param>  public static void Transaction(IRedisClient redisClient, Action action)  {   using (IRedisTransaction IRT = redisClient.CreateTransaction())   {    try    {     action();     IRT.Commit();    }    catch (Exception)    {     IRT.Rollback();    }   }  } }

三在领域代码中,我们通常可以这样使用大叔redis的事务块,看代码

var redis = new Lind.DDD.Repositories.Redis.RedisRepository<User>();             IRedisClient redisClient = Lind.DDD.RedisClient.RedisManager.GetClient();             redis.SetDataContext(redisClient);             Lind.DDD.RedisClient.RedisTransactionManager.Transaction(redisClient, () =>             {                 redis.Insert(new User { UserName = "gogod111" });                 redis.Insert(new User { UserName = "gogod211" });             });

这样,大叔框架就支持了Redis的事务,希望MongoDB早日也能对事务进行支持,到那时,大叔将会为它提供一种实现机制,呵呵!

下面是大叔对分布式多数据源事务的测试,可以实现SQLSERVER与Redis的事务共存机制,下面是代码

Lind.DDD.RedisClient.RedisTransactionManager.Transaction(redisClient, () => {  redis.Insert(new User { UserName = "gogod111" });  redis.Insert(new User { UserName = "gogod211" });  using (var trans = new TransactionScope())  {   userRepository.Insert(new UserInfo { UserName = "zzl3" });   trans.Complete();  } });

回到目录

正文到此结束