ItGo.me - 专注IT技术分享

首页 > Redis > Redis脚本实现分布式锁

Redis脚本实现分布式锁

时间:2016-08-28来源:网友分享 点击:

       redis被大量用在分布式的环境中,自然而然分布式环境下的锁如何解决,立马成为一个问题。例如我们当前的手游项目,服务器端是按业务模块划分服务器的,有应用服,战斗服等,但是这两个vm都有可能同时改变玩家的属性,这如果在同一个vm下面,就很容易加锁,但如果在分布式环境下就没那么容易了,当然利用redis现有的功能也有解决办法,比如redis的脚本。

       redis在2.6以后的版本中增加了Lua脚本的功能,可以通过eval命令,直接在RedisServer环境中执行Lua脚本,并且可以在Lua脚本中调用Redis命令。
使用脚本的好处:
1.减少网络开销:可以把一些要批量处理的功能,发在一个脚本里面执行,减少客户端和redis的交互次数
2.原子操作:这主要就是我们在这边主要利用的功能,在分布式环境下保证数据的原子性。
3.复用:客户端发送的脚本会永久的存储在redis中,这就意味着其他客户端可以复用这一脚本而不需要使用代码完成同样的逻辑。
下面先看一段lua脚本:

local food=redis.call('hget',KEYS[1],'food');food=food+ARGV[1];redis.call('hset',KEYS[1],'food',food);local diamond=redis.call('hget',KEYS[1],'diamond');diamond=diamond+ARGV[2];redis.call('hset',KEYS[1],'diamond',diamond);
注:redis.call是我们在脚本中调用redis命令,KEYS和ARGV2个数组,分别是键和参数,下标都是从1开始的,不是0。
这段脚本的功能是取出 KEYS指定的玩家food(粮草)和diamond(玉石),然后就行修改,最后保存在redis中,脚本的执行,保证了整个操作的原子性。
下面我们用java代码来看看具体的实现过程
Jedis jedis = new Jedis("192.168.128.128", 6379);// 1.初始玩家数据到redis中GamePlayer player = new GamePlayer();player.setId(1001);player.setName("ksfzhaohui");player.setFood(100);player.setDiamond(100);Map<String, String> beanMap = BeanUtil.warp(player);// 将对象转换成mapString beanKey = getRedisBeanKey(player.getClass(), player.getId());System.out.println("key:" + beanKey);jedis.hmset(beanKey, beanMap);// 将玩家数据保存到redis中
首先模拟了一个玩家将玩家信息保存在redis中,这边的Id随便写了一个,正常的情况下都是通过redis的命令incr生成一个id
结果:
 
String script = "local food=redis.call('hget',KEYS[1],'food');"+ "food=food+ARGV[1];"+ "redis.call('hset',KEYS[1],'food',food);"+ "local diamond=redis.call('hget',KEYS[1],'diamond');"+ "diamond=diamond+ARGV[2];"+ "redis.call('hset',KEYS[1],'diamond',diamond);";List<String> keys = new ArrayList<String>();keys.add(beanKey);List<String> args = new ArrayList<String>();args.add("100");args.add("100");// 3.执行脚本jedis.eval(script, keys, args);

指定键和参考,执行脚本,结果:
BeanUtil代码:

public class BeanUtil {private static Logger logger = Logger.getLogger(BeanUtil.class);private static final String CLASS = "class";/*** 将指定的对象数据封装成map** @param bean*            对象数据* @return*/@SuppressWarnings("all")public static Map<String, String> warp(Object bean) {Map<String, String> propertyMap = new HashMap<String, String>();try {PropertyDescriptor[] ps = Introspector.getBeanInfo(bean.getClass()).getPropertyDescriptors();for (PropertyDescriptor propertyDescriptor : ps) {String propertyName = propertyDescriptor.getName();if (propertyName != null && !propertyName.equals(CLASS)) {Method getter = propertyDescriptor.getReadMethod();if (getter != null) {propertyMap.put(propertyName,String.valueOf(getter.invoke(bean, null)));}}}} catch (Exception e) {logger.error(e);}return propertyMap;}}
当然网上还有一些其他的方法,如: 用SETNX实现分布式锁
可以参考:


Redis脚本实现分布式锁

Redis脚本实现分布式锁  讨论


redis php 实例二

前面一篇博客主要是string类型,list类型和set类型,下面hash类型和zset类型 1,hset 描述:将哈希表key中的域field的值设为value。如果key不存在,一个新的哈希表被创建并进行HSET操作。如果域field已...

Redis 实践笔记

最近在项目中实践了一下Redis,过程中遇到并解决了若干问题,记录之. Why Redis 我们这个项目是对原有缓存系统的改进,应用场景是论坛发帖,回帖,置顶,以及操作日志等等;原有系统会有替换算法把内...

【redis,1】java操作redis: 将string、list、map、自定义的对象保存到redis中

一、操作string 、list 、map 对象 1、引入jar: jedis-2.1.0.jar2、代码 /** * @param args */ public static void main(String[]args){ //连接 redis 服务 Jedisjedis= new Jedis( 192.168.88.15 ,6379); //密码验证-如果你没有设置 re...

redis被大量用在分布式的环境中,自然而然分布式环境下的锁如何解决,立马成为一个问题。例如我们当前的手游项目,服务器端是按业务模块划分服务器的,有应用服,战斗服等,但是这两个
------分隔线----------------------------