Redis-分布式-事务
在大型游戏中经常使用分布式，分布式中因为游戏逻辑会经常游戏事务，借助redis某些特性我们可以实现分布式锁和分布式事务。很多redis集群不支持redis的事务特性。
这个框架用来解决分布式服务器下redis集群事务失效的情况下多线程分布式锁和分布式锁，支持独占锁，共享锁，读写锁，并且支持事务提交失败情况下的回滚操作，让开发者可以有更多时间侧重游戏逻辑.
互斥锁使用例子
可参考test下的entity.
- 生成事务原因,GameTransactionCauseImpl里面构造.
- 生成锁实体,GameTransactionEntityFactoryImpl里面构造TimeMutexEntity.
- 提交锁实体跟事务,transactionService.commitTransaction里面提交.
- 后去事务提交结果,根据返回值做出判断.
读取锁使用例子
可参考test下的read 可以设置默认是否成功读取到
- 生成读取事务原因GameTransactionCause里面已经构造好了.
- 生成读取锁实体GameTransactionEntityFactory里面已经构造好了.
- 提交读取锁实体跟事务transactionService.commitTransaction里面提交.
- 后去事务提交结果 根据返回值做出判断.
标记锁使用例子
可参考test下的lockattchment可以设置默认是否成功读取到
写锁例子如下
- 生成事务原因,GameTransactionCauseImpl里面构造.
- 生成锁实体,GameTransactionEntityFactoryImpl里面构造.
- 生成锁标记内容 GameTransactionEntity对象获取GameTransactionLockInterface锁使用setContent
- 提交锁实体跟事务,transactionService.commitTransaction里面提交.
- 后去事务提交结果,根据返回值做出判断.
读锁例子如下
- 生成读取事务原因GameTransactionCause里面构造.
- 生成读取锁实体GameTransactionEntityFactory里面构.
- 生成锁标记内容 GameTransactionEntity对象获取GameTransactionLockInterface锁使用setContent
- 提交读取锁实体跟事务transactionService.commitTransaction里面提交.
- 后去事务提交结果 根据返回值做出判断.
强制写锁使用例子如下
可参考test下的force
当锁存在的情况，延迟锁占用时间。
例子如下
1. 生成事务原因,GameTransactionCauseImpl里面构造.
2. 生成锁实体,GameTransactionEntityFactoryImpl里面构造ForceEntity.
3. 提交锁实体跟事务,transactionService.commitTransaction里面提交.
4. 后去事务提交结果,根据返回值做出判断.
带时间写锁使用例子如下
参考test下的testlock.
当锁存在的情况，延迟锁占用时间。
例子如下
- 生成事务原因,GameTransactionCauseImpl里面构造.
- 生成锁实体,GameTransactionEntityFactoryImpl里面构造TestTimeMutexEntity.
- 提交锁实体跟事务,transactionService.commitTransaction里面提交.
- 后去事务提交结果,根据返回值做出判断.
带时间等待写锁使用例子如下
参考test下的wait.当锁失败的情况下，会尝试每秒检查锁，直到设置的等待时间结束.例子如下
- 生成事务原因,GameTransactionCauseImpl里面构造.
- 生成锁实体,GameTransactionEntityFactoryImpl里面构造WaitMutexEntity.
- 提交锁实体跟事务,transactionService.commitTransaction里面提交.
- 后去事务提交结果,根据返回值做出判断.
带事务回滚写锁使用例子如下
参考test下的rollback.当事务提交失败的情况下，根据提交进度进行rollback.例子如下
- 生成事务原因,GameTransactionCauseImpl里面构造.
- 生成锁实体,GameTransactionEntityFactoryImpl里面构造RollbackMutexEntity.
- 提交锁实体跟事务,transactionService.commitTransaction里面提交.
- 后去事务提交结果,根据返回值做出判断.
代码最后通过maven部
-
1. 安装pyredis 首先安装pip <SHELL># apt-get install python-pip ...... <SHELL># pip install --proxy=http://172.1.2.6:8080 redis Downloading redis-2.9.1.tar.gz (62kB): 62kB downloaded Running setup.py (pa
-
首先安装pip 1 2 3 4 5 6 7 8 # apt-get install python-pip ...... # pip install --proxy=http://172.1.2.6:8080 redis Downloading redis-2.9.1.tar.gz(62kB):62kBdownloaded Running setup.py(path:/tmp/pip_build_r
-
首先安装pip 1 2 3 4 5 6 7 8 # apt-get install python-pip ...... # pip install --proxy=http://172.1.2.6:8080 redis Downloading redis-2.9.1.tar.gz(62kB):62kBdownloaded Running setup.py(path:/tmp/pip_build_r
-
redis的transaction事务的了解 redis命令手册 WATCH WATCH key [key ...] 返回值： 总是返回 OK 。 监视一个(或多个) key ，如果在事务执行之前这个(或这些) key 被其他命令所改动， 那么事务将被打断。 示例代码： redis> WATCH lock lock_times OK UNWATCH 返回值： 总是 OK 。 取消 WATCH
-
背景 在很多互联网产品应用中，有些场景需要加锁处理，比如：秒杀，全局递增ID，楼层生成等等。大部分的解决方案是基于DB实现的，Redis为单进程单线程模式，采用队列模式将并发访问变成串行访问，且多客户端对redis的连接并不存在竞争关系。其次Redis提供一些命令SETNX，GETSET，可以方便实现分布式锁机制。 一、使用分布式锁要满足的几个条件： 系统是一个分布式系统（关键是分布式，单机的可以
-
问题内容： 我们有75台（并且正在不断增长）服务器需要通过Redis共享数据。理想情况下，所有75台服务器都希望通过操作写入Redis中的两个字段。我们预计最终在这两个领域上可能有数百万次的每日写入操作和数 十亿次 的每日读取。此数据 必须 是持久性的。 我们担心，Redis锁定可能会导致多次重试写入操作，而同时尝试增加同一字段的次数。 问题： 在一个非常重的负载下，在一个字段上同时执行多个操作是
-
使用Redis实现分布式锁 redis命令：set users 10 nx ex 12 原子性命令 //使用uuid，解决锁释放的问题 @GetMapping public void testLock() throws InterruptedException { String uuid = UUID.randomUUID().toString(); Boolean b_loc
-
本文向大家介绍Redis 怎么实现分布式锁？相关面试题，主要包含被问及Redis 怎么实现分布式锁？时的应答技巧和注意事项，需要的朋友参考一下 Redis 分布式锁其实就是在系统里面占一个“坑”，其他程序也要占“坑”的时候，占用成功了就可以继续执行，失败了就只能放弃或稍后重试。 占坑一般使用 setnx(set if not exists)指令，只允许被一个程序占有，使用完调用 del 释放锁。
-
一个挺着啤酒肚，身穿格子衫，发际线严重后移的中年男子，手拿着保温杯，胳膊夹着MacBook向你走来，看样子是架构师级别。 面试开始， 直入正题。 面试官： 你有没有参与过秒杀系统的设计？ 我： 没有，我平时都是开发后台管理系统、OA办公系统、内部管理系统，从来没有开发过秒杀系统。 面试官： 嗯...，小伙子很实诚。今天就先到这里吧，后面有消息会主动联系你。 后面还可能有消息吗？你们啥时候主动联系过
-
这个错误在我将spring-data-redis从1.4.2升级到1.5.2之后出现。 我的代码是实现一个悲观锁,