文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

redis中使用java脚本实现分布式锁

2022-06-04 17:23

关注

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);// 将对象转换成map

String 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";

 

    

    @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;

    }

 

}

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-数据库
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯