Redis 整合中 Redisson 的使用

这篇具有很好参考价值的文章主要介绍了Redis 整合中 Redisson 的使用。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

大家好 , 我是苏麟 , 今天带来 Redisson 使用 .

官方文档 : GitHub - redisson/redisson: Redisson - Easy Redis Java client with features of In-Memory Data Grid. Sync/Async/RxJava/Reactive API. Over 50 Redis based Java objects and services: Set, Multimap, SortedSet, Map, List, Queue, Deque, Semaphore, Lock, AtomicLong, Map Reduce, Bloom filter, Spring Cache, Tomcat, Scheduler, JCache API, Hibernate, RPC, local cache ...

Redis 整合中 Redisson 的使用,java项目中高效开发,redis,java,前端

引入依赖

        <!--https://github.com/redisson/redisson#quick-start-->
        <dependency>
            <groupId>org.redisson</groupId>
            <artifactId>redisson</artifactId>
            <version>3.23.2</version>
        </dependency>

yml配置(例如)

  #redis 配置
  redis:
    port: 6379
    database: 1
    host: localhost

Redisson配置

@Data
@Configuration
@ConfigurationProperties(prefix = "spring.redis")
public class RedissonConfig {

    private String host;

    private String port;

    @Bean
    public RedissonClient redissonClient(){
        // 1.创建配置
        Config config = new Config();

        String redissonAddress = String.format("redis:/%s:%s",host,port);

        //useClusterServers()集群
        //setDatabase() 设置那个redis库
        config.useSingleServer().setAddress(redissonAddress).setDatabase(2);


        //2.创建实例
        RedissonClient redissonClient = Redisson.create(config);
        return  redissonClient;
    }
}

上面不行则用下面的

package com.sl.config;

import lombok.Data;
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.redisson.config.SingleServerConfig;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Data
@Configuration
@ConfigurationProperties(prefix = "spring.redis")
public class RedissonConfig {

    private String host;

    private String port;

    private Integer database;

    @Bean
    public RedissonClient redissonClient() {
        // 1.创建配置
        Config config = new Config();
        SingleServerConfig singleServerConfig = config.useSingleServer()
                .setAddress("redis://" + host + ":" + port)
                .setDatabase(database);

        //2.创建实例
        return Redisson.create(config);
    }
}

这里@ConfigurationProperties(prefix = "spring.redis")用法请看 : 读取/加载 properties/yml 配置文件_踏遍三十六岸的博客-CSDN博客

像操作本地集合一样操作Redisson


@SpringBootTest
class UserCenterApplicationTests {

    @Resource
    private RedissonClient redissonClient;

    @Test
    void test() {
        //list操作 数据存在 JVM 内存中
        List<String> list = new ArrayList<>();
        list.add("sl");
        System.out.println(list.get(0));
        list.remove(0);

        //数据存在 Redis 内存中
        //getList()取列表名字 因为 redis 中是 key-value 存在
        RList<String> rList = redissonClient.getList("redisson-list");
        rList.add("sl-redisson");
        System.out.println(rList.get(0));
        rList.remove(0);    

    }

   
    @Test
    void hashTest(){

        //哈希操作
        RMap<String, String> rMap = redissonClient.getMap("LiJiaWei");
        //设置 map 中的 key - value
        rMap.put("sl","1");
        rMap.put("jw","2");

        System.out.println(redissonClient.getMap("LiJiaWei").get("sl"));
        System.out.println(redissonClient.getMap("LiJiaWei").get("jw"));

        redissonClient.getMap("LiJiaWei").remove("sl");
        redissonClient.getMap("LiJiaWei").remove("jw");
    }

    //......
    //其他操作都一样
}

Redssion 分布式锁

定时任务可以看(或者其他的) : Spring Schedular 定时任务_踏遍三十六岸的博客-CSDN博客

@Component
public class PreScheduled {


    @Resource
    private RedissonClient redissonClient;


    /**
     * 每天执行
     */
    @Scheduled(cron = "0 59 23 * * *")
    public void doCah() {
        //获取锁 , 可重入  指定锁的名称
        RLock lock = redissonClient.getLock("sl:redisson:cache:lock");


        try {
            /**
             * 只有一个线程获取到锁
             * 等待时间 , 执行时间 , 毫秒
             */
            if (lock.tryLock(0, 30000L, TimeUnit.MILLISECONDS)) {
              
                      //...
         
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            /**
             * 只能释放自己加的锁
             */
            if (lock.isHeldByCurrentThread()) {
                lock.unlock();
            }
        }
    }
}

感兴趣的小伙伴可以自行了解下面知识!