Java分布式集群,使用synchronized和Redis保证Job的原子性
2018-05-09 10:55
831 查看
1.使用synchronized保证并发时,同时只会有一个请求执行该代码段;
2.在执行前先设置并获取Reids标记,先设置然后获取确保是否已经执行;SetOption.SET_IF_ABSENT 可以保证Reids如果存在Key的话就不再Set;
public synchronized static boolean isWorking(final String keyLock, final String uuidValue,long seconds){ if(null == keyLock || uuidValue == null) { return false; } RedisConnection redisConnection = null; try { JedisConnectionFactory jedisConnectionFactory = ac.getBean("jedisConnectionFactory", JedisConnectionFactory.class); StringRedisTemplate redisTemplate = new StringRedisTemplate(jedisConnectionFactory); String value = System.currentTimeMillis() + "::" + uuidValue; logger.info("{} 尝试获取锁: {}, value:{}", ip, keyLock, value); //必须设置和过期同时执行 redisConnection = redisTemplate.getConnectionFactory().getConnection(); redisConnection.set(keyLock.getBytes(), value.getBytes(), Expiration.seconds(seconds), SetOption.SET_IF_ABSENT); if(value.equals(redisTemplate.opsForValue().get(keyLock))){ logger.info("{} 成功获取锁: {}, value:{}", ip, keyLock, value); return true; } logger.info("{} 无法获取锁: {}, value:{}", ip, keyLock, value); return false; }catch(Exception e) { logger.error(e.getMessage(), e); return false; }finally { if(null != redisConnection) { redisConnection.close(); } } }
相关文章推荐
- Redis笔记整理(二):Java API使用与Redis分布式集群环境搭建
- Net分布式系统之五:C#使用Redis集群缓存
- redis中使用java脚本实现分布式锁
- java使用redis实现分布式锁
- redis集群使用Java工具类(Java jedis集群工具类)
- Java之——redis并发读写锁,使用Redisson实现分布式锁
- Linux 下 Redis 分布式集群安装使用
- redis中使用java脚本实现分布式锁
- 分布式缓存集群方案特性使用场景(Memcache/Redis(Twemproxy/Codis/Redis-cluster))优缺点对比及选型
- Java使用jedis操作Redis单机和集群
- 分布式架构学习之:032--使用Redis3.0集群实现Tomcat集群的Session共享
- Hi!欢迎使用一个Dynamo风格的分布式Redis集群分发管理系统WheatRedis - V2EX
- maven项目中使用redis集群报错: java.lang.NumberFormatException: For input string: "7006@17006"
- redis集群搭建以及在Java中的使用
- Redis集群 Java客户端Jedis的使用
- Java企业级电商项目Tomcat Redis集群分布式架构实战视频教程
- redis中使用java脚本实现分布式锁
- 使用Java对Redis集群的事务处理
- 这是一个秒杀系统,即大量用户抢有限的商品,先到先得 用户并发访问流量非常大,需要分布式的机器集群处理请求 系统实现使用Java
- Java使用Redis实现分布式锁