当前位置：首页 > news >正文

安居客看房网北京seo编辑

news 2025/7/19 8:53:20

安居客看房网,北京seo编辑,河北建设信息网官网,网站做外链软件做一个积极的人编码、改bug、提升自己我有一个乐园，面向编程，春暖花开！ 文章目录一：前言二：分布式锁简介三：Redisson分布式锁的介绍和简单的使用四：总结五：参考博文一：…

做一个积极的人

编码、改bug、提升自己

我有一个乐园，面向编程，春暖花开！

文章目录

- - 一：前言
  - 二：分布式锁简介
  - 三：Redisson分布式锁的介绍和简单的使用
  - 四：总结
  - 五：参考博文

一：前言

我在实际环境中遇到了这样一种问题，分布式生成id的问题！因为业务逻辑的问题，我有个生成id的方法，是根据业务标识+id 当做唯一的值！
而uuid是递增生成的，从1开始一直递增，那么在同一台机器上运行代码，加上同步方法（synchronized），这个生成id的方法就是ok！

但是因为业务扩展或者说为了安全，项目运行在两台机器上，此时单个的同步方法（synchronized或者Lock）就不能防止id的重复了！！！

要解决上面的这个问题，其他有如下解决办法！

（1）：每台机器生产Id的代码，key+id 可以在前加上机器编号区分，key + id — >机器唯一编号 + key + id
（2）：使用数据库行锁（单个数据库的是时候，如何是分布式数据库也会出现问题），在需要插入id的表加上行锁，防止数据重复导致程序异常！
（3）：使用分布式锁

二：分布式锁简介

网上有很多的讲解分布式锁的文章，但是细细分析很多的代码还是有很多的问题的，如下代码片段摘自博文：

https://my.oschina.net/91jason/blog/517996?p=1
http://blog.csdn.net/u010359884/article/details/50310387

public void lock(long timeout) {long nano = System.nanoTime();timeout *= 1000000;final Random r = new Random();try {while ((System.nanoTime() - nano) < timeout) {if (redisTemplate.getConnectionFactory().getConnection().setNX(key.getBytes(), LOCKED.getBytes())) {redisTemplate.expire(key, EXPIRE, TimeUnit.SECONDS);locked = true;logger.debug("add RedisLock[" + key + "].");break;}Thread.sleep(3, r.nextInt(500));}} catch (Exception e) {}}

上面的代码博主也说了：如果长时间获取不到，就会获取锁失败，相当于没加锁！

这里还有可能发生其他问题：

（1）并发情况，expire主动释放锁的时候，可能释放的是别人的锁（不懂请自行查询相关资料）

（2）Redis服务挂掉，锁失败，相当于没加锁！最好使用主从+哨兵提高高可用

注：使用的时候要注意上面问题！！！

还有一种摘自博文：
http://www.cnblogs.com/0201zcr/p/5942748.html
这个博问分析的：

 while (timeout >= 0) {long expires = System.currentTimeMillis() + expireMsecs + 1;String expiresStr = String.valueOf(expires); //锁到期时间if (this.setNX(lockKey, expiresStr)) {// lock acquiredlocked = true;return true;}String currentValueStr = this.get(lockKey); //redis里的时间if (currentValueStr != null && Long.parseLong(currentValueStr) < System.currentTimeMillis()) {//判断是否为空，不为空的情况下，如果被其他线程设置了值，则第二个条件判断是过不去的// lock is expiredString oldValueStr = this.getSet(lockKey, expiresStr);//获取上一个锁到期时间，并设置现在的锁到期时间，//只有一个线程才能获取上一个线上的设置时间，因为jedis.getSet是同步的if (oldValueStr != null && oldValueStr.equals(currentValueStr)) {//防止误删（覆盖，因为key是相同的）了他人的锁——这里达不到效果，这里值会被覆盖，但是因为什么相差了很少的时间，所以可以接受//[分布式的情况下]:如过这个时候，多个线程恰好都到了这里，但是只有一个线程的设置值和当前值相同，他才有权利获取锁// lock acquiredlocked = true;return true;}}timeout -= DEFAULT_ACQUIRY_RESOLUTION_MILLIS;/*延迟100 毫秒,  这里使用随机时间可能会好一点,可以防止饥饿进程的出现,即,当同时到达多个进程,只会有一个进程获得锁,其他的都用同样的频率进行尝试,后面有来了一些进行,也以同样的频率申请锁,这将可能导致前面来的锁得不到满足.使用随机的等待时间可以一定程度上保证公平性*/Thread.sleep(DEFAULT_ACQUIRY_RESOLUTION_MILLIS);}

这个相比第一个完善了误删除key的问题，但是要合理的设置超时时间 (要了解具体加锁的业务)，否则的话，也会使锁失效。