<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    posts - 110, comments - 101, trackbacks - 0, articles - 7
      BlogJava :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理

    redis 設置分布式鎖

    Posted on 2014-01-15 19:00 云云 閱讀(13412) 評論(1)  編輯  收藏
    public static boolean acquireLock(String lock) {
        // 1. 通過SETNX試圖獲取一個lock
        boolean success = false;
        Jedis jedis = pool.getResource();      
        long value = System.currentTimeMillis() + expired + 1;    
        System.out.println(value);    
        long acquired = jedis.setnx(lock, String.valueOf(value));
        //SETNX成功,則成功獲取一個鎖
        if (acquired == 1)      
            success = true;
        //SETNX失敗,說明鎖仍然被其他對象保持,檢查其是否已經超時
        else {
            long oldValue = Long.valueOf(jedis.get(lock));
     
            //超時
            if (oldValue < System.currentTimeMillis()) {
                String getValue = jedis.getSet(lock, String.valueOf(value));              
                // 獲取鎖成功
                if (Long.valueOf(getValue) == oldValue)
                    success = true;
                // 已被其他進程捷足先登了
                else
                    success = false;
            }
            //未超時,則直接返回失敗
            else            
                success = false;
        }        
        pool.returnResource(jedis);
        return success;      
    }
     
    //釋放鎖
    public static void releaseLock(String lock) {
        Jedis jedis = pool.getResource();      
        long current = System.currentTimeMillis();      
        // 避免刪除非自己獲取得到的鎖
        if (current < Long.valueOf(jedis.get(lock)))
            jedis.del(lock);      
        pool.returnResource(jedis);
    }



    //--------------------------

    public Long acquireLock(final String lockName,final long expire){
        return redisTemplate.execute(new RedisCallback<Long>() {
         public Long doInRedis(RedisConnection connection) {
            byte[] lockBytes = redisTemplate.getStringSerializer().serialize(lockName);
    boolean locked = connection.setNX(lockBytes, lockBytes);
    connection.expire(lockBytes, expire);
    if(locked){
    return 1L;
    }
                return 0L;
    }
    });
    }


    //原子操作 -----------------------

    public String getAndSet(final String key,final String value){
    return redisTemplate.execute(new RedisCallback<String>() {
    @Override
    public String doInRedis(RedisConnection connection)
    throws DataAccessException {
    byte[] result = connection.getSet(redisTemplate.getStringSerializer().serialize(key),
    redisTemplate.getStringSerializer().serialize(value));
    if(result!=null){
                                        return new String(result);
     }
    return null;
                    }
             });
    }





    評論

    # re: redis 設置分布式鎖   回復  更多評論   

    2016-04-20 15:04 by 小新人
    請問expired如何設置

    只有注冊用戶登錄后才能發表評論。


    網站導航:
    博客園   IT新聞   Chat2DB   C++博客   博問  
     
    主站蜘蛛池模板: 四虎成人精品在永久免费| 久久精品国产亚洲av高清漫画 | 美女视频黄的全免费视频| 特级毛片全部免费播放| 亚洲国产美女在线观看 | 亚洲欧美精品午睡沙发| 亚洲精品无码不卡| AV在线亚洲男人的天堂| 国产成人免费全部网站| 免费看国产精品3a黄的视频| 国产精品免费高清在线观看| 曰批免费视频播放免费| 亚洲精品又粗又大又爽A片| 亚洲最大在线视频| 亚洲国产人成在线观看69网站| 亚洲人成网站18禁止一区| 日本一道高清不卡免费| 性色av无码免费一区二区三区| 久久狠狠躁免费观看2020| 中国内地毛片免费高清| 国产精品美女久久久免费| 日本一区二区在线免费观看 | 成人A级毛片免费观看AV网站| 18女人毛片水真多免费| 香港a毛片免费观看| 曰批全过程免费视频在线观看无码| jizz免费在线影视观看网站| 美女视频黄.免费网址| 337P日本欧洲亚洲大胆精品 | 国产三级免费电影| 午夜一区二区免费视频| 好男人视频在线观看免费看片| 国产一卡2卡3卡4卡2021免费观看| 亚洲网站免费观看| 日韩中文字幕精品免费一区| 13一14周岁毛片免费| 91九色精品国产免费| 中国在线观看免费高清完整版| 免费H网站在线观看的| 最近高清国语中文在线观看免费| 中字幕视频在线永久在线观看免费 |