springboot整合redisson分佈式鎖

1、經過maven引入redisson的jar包java

<dependency>
            <groupId>org.redisson</groupId>
            <artifactId>redisson</artifactId>
            <version>3.6.5</version>
        </dependency>

 

2、在yaml文件中引入redis的相關配置(redis單節點能夠讀取原有redis配置拼裝,若是是主從需另外獨立配置,相關屬性能夠參考org.redisson.config.Config.masterSlaveServersConfig)redis

spring:
  redis:
    host: 127.0.0.1 
    port: 6379
    password: 111111

3、添加springboot配置spring

package com.aoxun.config;

import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * redisson配置
 * 目前使用的是騰訊雲的單節點redis,因此暫時配置單服務
 * 
 *
 */
@Configuration
public class RedissonConfig {

    @Value("${spring.redis.host}")
    private String host;
    
    @Value("${spring.redis.port}")
    private String port;
    
    @Value("${spring.redis.password}")
    private String password;
    
    
    @Bean
    public RedissonClient getRedisson(){
        
        Config config = new Config();
        config.useSingleServer().setAddress("redis://" + host + ":" + port).setPassword(password);
        //添加主從配置
//        config.useMasterSlaveServers().setMasterAddress("").setPassword("").addSlaveAddress(new String[]{"",""});
        
        return Redisson.create(config);
    }
    
}

4、在須要使用的地方注入RedissonClient便可api

package com.aoxun.modular.menjin.service.impl;

import java.util.concurrent.TimeUnit;

import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;


@Service
public class TestRedissonLock{
    
    @Autowired
    private RedissonClient redissonClient;

    public void cameraCallback() {
        
        RLock rlock = redissonClient.getLock("redisson:lock:personId" + 123);

     //設置鎖超時時間,防止異常形成死鎖 rlock.lock(
20, TimeUnit.SECONDS); try{ //執行業務邏輯 Thread.sleep(10000); System.out.println(123); } catch(Exception e){ }finally{ rlock.unlock(); } } }

 

到此利用redisson實現分佈式鎖簡單樣例已經結束springboot

相關文章
相關標籤/搜索