springboot集成redisson

1.添加依赖

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
            <version>2.4.1</version>
        </dependency>
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>3.3.0</version>
        </dependency>
        <dependency>
            <groupId>org.redisson</groupId>
            <artifactId>redisson-spring-boot-starter</artifactId>
            <version>3.13.6</version>
        </dependency>

2.redisson配置文件(redisson.yaml)

# 单节点配置
singleServerConfig:
  # 连接空闲超时,单位:毫秒
  idleConnectionTimeout: 10000
  # 连接超时,单位:毫秒
  connectTimeout: 10000
  # 命令等待超时,单位:毫秒
  timeout: 3000
  # 命令失败重试次数,如果尝试达到 retryAttempts(命令失败重试次数) 仍然不能将命令发送至某个指定的节点时,将抛出错误。
  # 如果尝试在此限制之内发送成功,则开始启用 timeout(命令等待超时) 计时。
  retryAttempts: 3
  # 命令重试发送时间间隔,单位:毫秒
  retryInterval: 1500
  # 密码
  password: null
  # 单个连接最大订阅数量
  subscriptionsPerConnection: 5
  # 客户端名称
  clientName: null
  #  # 节点地址
  address: redis://ip:6489     //这里是redis的ip地址和端口
  # 发布和订阅连接的最小空闲连接数
  subscriptionConnectionMinimumIdleSize: 1
  # 发布和订阅连接池大小
  subscriptionConnectionPoolSize: 50
  # 最小空闲连接数
  connectionMinimumIdleSize: 32
  # 连接池大小
  connectionPoolSize: 64
  # 数据库编号
  database: 0
  # DNS监测时间间隔,单位:毫秒
  dnsMonitoringInterval: 5000
# 线程池数量,默认值: 当前处理核数量 * 2
#threads: 0
# Netty线程池数量,默认值: 当前处理核数量 * 2
#nettyThreads: 0
# 编码
codec: !<org.redisson.codec.JsonJacksonCodec> {}
# 传输模式
transportMode : "NIO"

3.配置文件(application.properties)

//是否启用缓存
com.celery.cache.enable=true
//缓存相关配置
com.celery.cache.config-file=/src/main/resources/redisson.yaml
//缓存超时时间
com.celery.cache.ttl-seconds=3600

4.redis配置类

    @Configuration
    @ComponentScan
    @EnableCaching
    public static class RedisConfig {
    
		@Value("${com.celery.cache.config-file}")
		private String configFile;
		@Value("${com.celery.cache.ttl-seconds:1800}")		
		private long ttlSeconds;

        @Bean
        RedissonClient redisson() Resource configFile) throws IOException {
            Config config = Config.fromYAML(configFile);
            return Redisson.create(config);
        }

        @Bean
        CacheManager cacheManager(RedissonClient redissonClient) throws IOException {
            return new RedissonSpringCacheManager(redissonClient, "classpath:/cache-config.json");
        }

		public static class MyRedisCacheManager extends RedissonSpringCacheManager{
			private final long ttl;
			public MyRedisCacheManager(RedissonClient  redisson, long ttl){\
				super(redisson);
				this.ttl = ttl;
			}
			@Override
			protected CacheConfig createDefaultConfig(){
			return new CacheConfig(ttl*1000, ttl*1000);
		}
		}
    }

5.使用缓存

实际使用一般使用@Caching注解、@Cacheable注解,可以放在mapper方法上,service层方法上。
(1)mapper方法使用缓存

@Cacheable(cacheNames = "user", key = "#id")
@Select("select * from user where id=#{id}")
User findById(int id);

(2)service
service层的key可以为具体的字段如id、name,也可以用对象作为key,如User对象,指定时key="#user"即可

@Cacheable(cacheNames = "findUser", key = "#id")
public User findById(int id){
	return userMapper.findById(id);
}

上一篇:PBFT是什么


下一篇:不同操作系统的TTL值