spring?boot如何集成redisson

這篇文章主要介紹了spring boot如何集成redisson的相關(guān)知識(shí)，內(nèi)容詳細(xì)易懂，操作簡(jiǎn)單快捷，具有一定借鑒價(jià)值，相信大家閱讀完這篇spring boot如何集成redisson文章都會(huì)有所收獲，下面我們一起來(lái)看看吧。

集成及注意事項(xiàng)

redisson支持redis環(huán)境，單機(jī)、集群、哨兵、云等。

這里就講一下集群模式需要注意的地方，redisson啟動(dòng)會(huì)檢測(cè)master/slave節(jié)點(diǎn)是否正常，一般來(lái)說(shuō)3分片3主3從是沒(méi)有什么問(wèn)題的，但是如果測(cè)試環(huán)境1分片1主1從或者3主都是啟動(dòng)不了的。

除了環(huán)境需要注意，還有注意兼容有無(wú)密碼的情況。

手動(dòng)注入redisson配置

一般情況下，生產(chǎn)環(huán)境都是有密碼的。有密碼的話，建議手動(dòng)注入redisson配置，不用spring boot來(lái)幫你集成，因?yàn)榭赡躶pring boot識(shí)別不了密碼。

@Configuration
public class RedissonConfiguration {
    @Value("${spring.redis.cluster.nodes}")
    private String node;
    @Value("${spring.redis.password:}")
    private String password;
    @Bean
    public RedissonClient redissonClient() {
        Config config = new Config();
        String[] nodes = node.split(",");
        ClusterServersConfig clusterServersConfig = config.useClusterServers();
        for (String nodeAddress : nodes) {
            clusterServersConfig.addNodeAddress(prefixAddress(nodeAddress));
        }
        if (StringUtils.isNotBlank(password)) {
            clusterServersConfig.setPassword(password);
        }
        return Redisson.create(config);
    }
    private String prefixAddress(String address) {
        if (!StringUtils.isBlank(address) && !address.startsWith("redis")) {
            return "redis://" + address;
        }
        return address;
    }
}

上面可以根據(jù)自己實(shí)際情況調(diào)優(yōu)一些配置。

當(dāng)然除了密碼需要注意，還有一點(diǎn)就是是否有ssl，目前所在company是用的亞馬遜云，會(huì)有ssl

spring boot 兼容 redis 可以在yaml配置里天際： Ssl：true，但對(duì)于redisson來(lái)說(shuō)添加前綴就可以啦：

rediss:// + ip:端口或者域名

具體yaml配置

spring:
  redis:
    cluster:
      nodes: rediss://clustercfg.xxx
    password: 'xxx'
    timeout: 30000
    Ssl: true
    lettuce:
      pool:
        max-idle: 100

利用鎖的互斥策略，一開始這樣的

@Scheduled(cron = "${xxx:0 0 */2 * * ?}")
public void createProcess() {
    RLock lock = redisson.getLock(key);
    try {
        if (lock.tryLock()) {
           // 執(zhí)行運(yùn)行程序
        } else {
            log.info("createProcess 獲取鎖失敗");
        }
    } catch (Exception e) {
        log.error("xxx", e);
    } finally {
        // 是否有鎖 && 是否當(dāng)前線程
        if (lock != null && lock.isLocked() && lock.isHeldByCurrentThread()) {
            lock.unlock();
        }
    }
}

咋一看是沒(méi)有什么問(wèn)題的，但是本次重構(gòu)的定時(shí)任務(wù)比較多,因此會(huì)涉及到很多try catch相同的代碼。

注解方式

解決重復(fù)代碼方式之一就是封裝，在就是注解切面，想到注解方式更加靈活

于是

/**
 * Redisson 同步鎖
 */
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface RedissonSyncLock {
    String pref();
    /**
     * 鎖后綴，一般前綴根據(jù)業(yè)務(wù)來(lái)定，后綴是具體的場(chǎng)景
     */
    String keyEL();
    /**
     * 等待時(shí)長(zhǎng) 【需要區(qū)分是互斥還是阻塞，互斥默認(rèn)0就可以】
     */
    int waitSec() default 0;
}

需要一個(gè)切面

@Slf4j
@Aspect
@Component
@RequiredArgsConstructor
public class RedissonSyncLockAspect {
    private final Redisson redisson;
    @Around(value = "@annotation(xxx.RedissonSyncLock)")
    public Object around(ProceedingJoinPoint joinPoint) throws Throwable {
        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
        RedissonSyncLock redissonSyncLock = signature.getMethod().getAnnotation(RedissonSyncLock.class);
        Object[] args = joinPoint.getArgs();
        String key = SpelUtil.parseSpel(signature.getMethod(), args, redissonSyncLock.keyEL());
        RLock lock = null;
        try {
            if (StringUtils.isNotBlank(key) && !StringUtils.equals(key, "null") 
                lock = redisson.getLock(redissonSyncLock.pref().concat(key));
                if (lock.tryLock(redissonSyncLock.waitSec(), TimeUnit.SECONDS)) {
                    return joinPoint.proceed();
                }
            }
            log.info("RedissonSyncLockAspect 上鎖失敗 {}", key);
        } finally {
            if (lock != null && lock.isLocked() && lock.isHeldByCurrentThread()) {
                lock.unlock();
            }
        }
    }
}

使用方法：

@RedissonSyncLock(pref = KeyConstant.xxx, keyEL = "#bean.accountNo")
private void xxx(Bean bean){
     // 程序執(zhí)行
}

的確使用起來(lái)是比較方便的。

關(guān)于“spring boot如何集成redisson”這篇文章的內(nèi)容就介紹到這里，感謝各位的閱讀！相信大家對(duì)“spring boot如何集成redisson”知識(shí)都有一定的了解，大家如果還想學(xué)習(xí)更多知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道。