Springboot整合redis

文章目录

redis简介

Redis是一个开源的内存数据结构存储数据库，用作数据库，缓存等。提供了字符串，散列，列表，集合等数据结构。常用的场景有分布式session共享，缓存数据，临时存储如购物车等。

redis常用的命令

set get

set key value

setnx

setnx key value :
将 key 的值设为 value ，当且仅当 key 不存在。
若给定的 key 已经存在，则 SETNX 不做任何动作。

127.0.0.1:6379>set k1 v1
OK
127.0.0.1:6379>127.0.0.1:6379> setnx k1 v2
(integer)0127.0.0.1:6379>set k2 v2
OK
127.0.0.1:6379>

这里就不在多介绍，详细参考官网命令。

springboot中使用redis

引入依赖

<!--添加redis依赖--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-redis</artifactId><version>1.4.7.RELEASE</version></dependency><!--分布式session--><dependency><groupId>org.springframework.session</groupId><artifactId>spring-session-data-redis</artifactId><version>2.3.1.RELEASE</version></dependency>

配置redis

#配置redisredis:host: redis服务器地址
    database:0#配置数据库0port:6379#端口#password:#配置连接池jedis:pool:max-active:8max-idle:8min-idle:0max-wait:-1#ms

redis服务类接口

/**
 * 定义访问redis的接口类
 *
 */publicinterfaceRedisService{/**
     * 保存key value
     * @param key
     * @param value
     */voidsaveKeyValue(String key,Object value);/**
     * 保存key value
     * @param key
     * @param value
     */voidsaveKeyValue(String key,Object value,int expiration);/**
     * 根据key获取value
     * @param key
     * @return
     */StringgetValueByKey(String key);/**
     * 根据key删除缓存
     * @param key
     */voiddelete(String key);/**
     * 清空所有缓存
     */voidflushdb();}

redis服务实现类

/**
 * redis 实现类
 */@ServicepublicclassRedisServiceImplimplementsRedisService{@AutowiredRedisTemplate redisTemplate;/**
     * 保存key value
     * @param key
     * @param value
     */@OverridepublicvoidsaveKeyValue(String key,Object value){
        redisTemplate.opsForValue().set(key, value);}/**
     * 设置过期时间
     * @param key
     * @param value
     * @param expiration 过期时间
     */@OverridepublicvoidsaveKeyValue(String key,Object value,int expiration){
        redisTemplate.opsForValue().set(key, value);
        redisTemplate.expire(key, expiration,TimeUnit.MINUTES);}/**
     * 根据key获取value
     * @param key
     * @return
     */@OverridepublicStringgetValueByKey(String key){try{String value = redisTemplate.opsForValue().get(key).toString();return value;}catch(Exception e){return"";}}/**
     * 删除缓存
     * @param key
     */@Overridepublicvoiddelete(String key){
        redisTemplate.delete(key);}/**
     * 清空所有的缓存
     */@Overridepublicvoidflushdb(){
        redisTemplate.getConnectionFactory().getConnection().flushDb();}}

controller测试

@RestControllerpublicclassRedisController{//引入缓存操作@AutowiredRedisService redisService;@GetMapping("/redistest")publicStringhello(){return"hello,spring integration with redis";}@GetMapping("/redis/{key}/{val}")publicStringsavekeyValue(@PathVariable("key")String key,@PathVariable("val")Object val){
        redisService.saveKeyValue(key,val);return key+"="+redisService.getValueByKey(key);}@GetMapping("/redis/{key}")publicStringgetValueByKey(@PathVariable("key")String key){return redisService.getValueByKey(key);}@GetMapping("/redis/delete/{key}")publicStringdelete(@PathVariable("key")String key){
       redisService.delete(key);return redisService.getValueByKey(key);}}

分布式session共享

配置session的存储类型

#指定session的存储方式spring:session:store-type: redis

配置session

@Configuration//@EnableRedisHttpSession//配置失效时间@EnableRedisHttpSession(maxInactiveIntervalInSeconds =60)//1分钟失效publicclassSessionConfig{}

session控制类

/**
 * session控制类
 */@RestControllerpublicclassSessionController{//设置session@GetMapping("/setSession/{username}")publicStringsetSession(HttpSession httpSession,@PathVariable("username")String username){
        httpSession.setAttribute("username",username);return"OK";}//获取session@GetMapping("/getSession")publicObjectgetSession(HttpSession httpSession){Object username = httpSession.getAttribute("username");return username;}}

IDEA中，我们可以改下端口重启两个服务，分布访问。

测试

超过1分钟之后，可以看到session失效。