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(); // 提交事务
        }}

      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类型");}}

    /// <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();}}}}

            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" });});

           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();}});

        /// <summary>/// 事务块处理/// </summary>/// <param name="redisClient">当前redis库</param>/// <param name="redisAction">Redis事务中的动作</param>/// <param name="sqlAction">Sql事务中的动作</param>public static void Transaction(IRedisClient redisClient, Action redisAction, Action sqlAction = null){using (IRedisTransaction IRT = redisClient.CreateTransaction()){try{redisAction();if (sqlAction != null){using (var trans = new TransactionScope()){sqlAction();trans.Complete();}}IRT.Commit();}catch (Exception){IRT.Rollback();}}}

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