zoukankan      html  css  js  c++  java
  • Java分布式集群,使用synchronized和Redis保证Job的原子性

    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();
                }
            }
            
        }
  • 相关阅读:
    Android Studio 生成Jar包时遇到的gradlew下载问题
    未解决问题
    Android -- android.os.Parcelable[] cannot be cast to ...
    vulkan gpu limits in mali
    Why GPU Program is expensive in CPU
    iOS native plugin 的代码sample
    USC-- compute shader ps vs
    zprepass 之后再base pass为什么用equal不用lessequal
    memory management Vulkan
    hlslcc
  • 原文地址:https://www.cnblogs.com/raphael5200/p/9012984.html
Copyright © 2011-2022 走看看