欧美一级特黄大片做受成人-亚洲成人一区二区电影-激情熟女一区二区三区-日韩专区欧美专区国产专区

redis分布式鎖的實現(xiàn)示例

小編給大家分享一下redis分布式鎖的實現(xiàn)示例,相信大部分人都還不怎么了解,因此分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后大有收獲,下面讓我們一起去了解一下吧!

創(chuàng)新互聯(lián)專注于企業(yè)全網(wǎng)整合營銷推廣、網(wǎng)站重做改版、晉安網(wǎng)站定制設(shè)計、自適應(yīng)品牌網(wǎng)站建設(shè)、H5響應(yīng)式網(wǎng)站、商城開發(fā)、集團(tuán)公司官網(wǎng)建設(shè)、外貿(mào)營銷網(wǎng)站建設(shè)、高端網(wǎng)站制作、響應(yīng)式網(wǎng)頁設(shè)計等建站業(yè)務(wù),價格優(yōu)惠性價比高,為晉安等各大城市提供網(wǎng)站開發(fā)制作服務(wù)。

Redisson

redisson和下列一下自行封裝兩種方式的區(qū)別(場景):

  1. redisson未獲取到鎖的會進(jìn)入等待,直到獲取到鎖。

  2. 另外兩種方式如果未獲取到鎖,會放棄,不會執(zhí)行業(yè)務(wù)代碼。

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>3.13.6</version></dependency>
@Autowiredprivate Redisson redisson;@GetMapping("/redissonLock")public String redissonLock() {
    log.info("進(jìn)入了方法");
    RLock lock = redisson.getLock("redissonLock");
    try {
        lock.lock(30, TimeUnit.SECONDS);
        Thread.sleep(10000);
        System.out.println("我是你大哥");
    } catch (InterruptedException e) {
        e.printStackTrace();
    } finally {
    // 如果不釋放,不會喚起其他線程,則其他線程會超時過期自動喚醒,不會執(zhí)行業(yè)務(wù)代碼
        lock.unlock();
    }
    return "運(yùn)行結(jié)束";}

RedisTemplate封裝redis鎖(1)

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-data-redis</artifactId></dependency>
package com.util;import org.springframework.dao.DataAccessException;import org.springframework.data.redis.connection.RedisConnection;import org.springframework.data.redis.connection.RedisStringCommands;import org.springframework.data.redis.core.RedisCallback;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.data.redis.core.script.RedisScript;import org.springframework.data.redis.core.types.Expiration;import org.springframework.stereotype.Component;import java.util.Arrays;@Componentpublic class RedisLock {

    private static RedisTemplate redisTemplate;

    private static String script = "if redis.call(\"get\",KEYS[1]) == ARGV[1] then\n" +
            "\treturn redis.call(\"del\",KEYS[1])\n" +
            "else\n" +
            "   \treturn 0\t\n" +
            "end  ";

    public RedisLock(RedisTemplate redisTemplate) {
        RedisLock.redisTemplate = redisTemplate;
    }

    public static Boolean getLock(String key, String value, Long expireTime) {
        RedisStringCommands.SetOption setOption = RedisStringCommands.SetOption.ifAbsent();
        Expiration expiration = Expiration.seconds(expireTime);
        RedisCallback<Boolean> booleanRedisCallback = new RedisCallback<Boolean>() {
            @Override
            public Boolean doInRedis(RedisConnection connection) throws DataAccessException {
                return connection.set(redisTemplate.getKeySerializer().serialize(key), redisTemplate.getValueSerializer().serialize(value), expiration, setOption);
            }
        };
        return (Boolean) redisTemplate.execute(booleanRedisCallback);
    }

    public static Boolean unLock(String key, String value) {
        RedisScript<Boolean> redisScript = RedisScript.of(script, Boolean.class);
        return (Boolean) redisTemplate.execute(redisScript, Arrays.asList(key), value);
    }}
@GetMapping("/redisLock")public String redisLock() {
    log.info("進(jìn)入了方法");
    String key = "redisLock";
    String uuid = UUID.randomUUID().toString();
    try {
        if (RedisLock.getLock(key, uuid, 30L)) {
            log.info("進(jìn)入了鎖");
            Thread.sleep(10000);
        }
    } catch (InterruptedException e) {
        e.printStackTrace();
    } finally {
        RedisLock.unLock(key, uuid);
    }
    log.info("方法執(zhí)行完成");
    return "程序結(jié)束";}

RedisTemplate封裝redis鎖(2)

package com.util;import lombok.extern.slf4j.Slf4j;import org.springframework.dao.DataAccessException;import org.springframework.data.redis.connection.RedisConnection;import org.springframework.data.redis.connection.RedisStringCommands;import org.springframework.data.redis.core.RedisCallback;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.data.redis.core.script.RedisScript;import org.springframework.data.redis.core.types.Expiration;import java.util.Arrays;import java.util.UUID;@Slf4jpublic class HighRedisLock implements AutoCloseable{

    private RedisTemplate redisTemplate;

    private String key;

    private String value;

    private Long expireTime;

    private static String script = "if redis.call(\"get\",KEYS[1]) == ARGV[1] then\n" +
            "\treturn redis.call(\"del\",KEYS[1])\n" +
            "else\n" +
            "   \treturn 0\t\n" +
            "end  ";

    public HighRedisLock(RedisTemplate redisTemplate, String key, Long expireTime) {
        this.redisTemplate = redisTemplate;
        this.key = key;
        this.value = UUID.randomUUID().toString();
        this.expireTime = expireTime;
    }

    public Boolean getLock() {
        RedisStringCommands.SetOption setOption = RedisStringCommands.SetOption.ifAbsent();
        Expiration expiration = Expiration.seconds(expireTime);
        RedisCallback<Boolean> booleanRedisCallback = new RedisCallback<Boolean>() {
            @Override
            public Boolean doInRedis(RedisConnection connection) throws DataAccessException {
                return connection.set(redisTemplate.getKeySerializer().serialize(key), redisTemplate.getValueSerializer().serialize(value), expiration, setOption);
            }
        };
        return (Boolean) redisTemplate.execute(booleanRedisCallback);
    }

    public Boolean unLock() {
        RedisScript<Boolean> redisScript = RedisScript.of(script, Boolean.class);
        return (Boolean) redisTemplate.execute(redisScript, Arrays.asList(key), value);
    }

    @Override
    public void close() throws Exception {
        unLock();
    }}
@Autowiredprivate RedisTemplate redisTemplate;@GetMapping("/highRedisLock")public String highRedisLock() {
    log.info("進(jìn)入了方法");
    try (HighRedisLock redisLock = new HighRedisLock(redisTemplate, "highRedisLock", 30L)) {
        if (redisLock.getLock()) {
            log.info("進(jìn)入了鎖");
            Thread.sleep(10000);
        }
    } catch (InterruptedException e) {
        e.printStackTrace();
    } catch (Exception e) {
        e.printStackTrace();
    }
    log.info("方法執(zhí)行完成");
    return "程序結(jié)束";}

以上是“redis分布式鎖的實現(xiàn)示例”這篇文章的所有內(nèi)容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內(nèi)容對大家有所幫助,如果還想學(xué)習(xí)更多知識,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道!

網(wǎng)頁名稱:redis分布式鎖的實現(xiàn)示例
標(biāo)題網(wǎng)址:http://aaarwkj.com/article26/jjigcg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供虛擬主機(jī)、搜索引擎優(yōu)化響應(yīng)式網(wǎng)站、微信小程序、靜態(tài)網(wǎng)站、自適應(yīng)網(wǎng)站

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)

成都定制網(wǎng)站建設(shè)
亚洲熟女av综合网丁香| 国产午夜草莓视频在线观看| 日韩精品一区二区一牛| 中文字幕日本精品人妻在线| 91麻豆粉色视频在线| 精品人妻一区二区三区蜜桃视频 | 九九热久久这里全是精品| 精品视频一区二区三区在线观看 | 偷窥偷拍视频一区二区| 成人一区二区三区播放| 欧美精品欧美精品一区二区| 97日韩在线免费视频网站| 日韩在线一区中文字幕| 少妇被啪出水在线视频| 日韩中文字幕亚洲精品一| 熟女乱熟乱熟妇综合网二区| 日本精品一区二区三区免费| 无码精品人妻一区二区三区中| 日韩精品欧美中文字幕| 欧美一区二区三区中文字幕| 青青草成人公开在线视频| 国产综合中文字幕不卡| 亚洲精品一品区二品区三区 | 欧美大片黄片在线观看| 91欧美日韩中在线视频| 毛片一区二区三区免费看| 国产av人妻精品一区二| 日韩中文字幕视频久久| 日韩精品毛片一区到三区| 四虎国产最新在线免费| 岛国毛片在线免费播放| 粉嫩国产av一区二区三区| 91亚洲国产成人精品性色| 成年女人大片免费观看版| 亚洲精品网站国产高清| 伊在人亚洲香蕉精品区| 亚洲日本熟妇在线视频| 在线免费观看91亚洲| 亚洲欧美国产成人在线| 欧美日韩亚洲精品三级| 国产午夜福利一区在线|