专栏首页Java后端技术栈cwnaitSpringBoot系列-- 集成 Redis 缓存(实战)

SpringBoot系列-- 集成 Redis 缓存(实战)

正文

1、pom.xml引入jar包

如下:

<dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

2、修改项目启动类,增加注解@EnableCaching,开启缓存功能

如下:

package springboot;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.scheduling.annotation.EnableScheduling;

@SpringBootApplication
@EnableScheduling
@EnableCaching
public class SpringbootApplication{

   public static void main(String[] args) {
       SpringApplication.run(SpringbootApplication.class, args);
   }
}

3、application.properties中配置Redis连接信息

如下:

# Redis数据库索引(默认为0)
spring.redis.database=0
# Redis服务器地址
spring.redis.host=172.31.19.222
# Redis服务器连接端口
spring.redis.port=6379
# Redis服务器连接密码(默认为空)
spring.redis.password=
# 连接池最大连接数(使用负值表示没有限制)
spring.redis.pool.max-active=8
# 连接池最大阻塞等待时间(使用负值表示没有限制)
spring.redis.pool.max-wait=-1
# 连接池中的最大空闲连接
spring.redis.pool.max-idle=8
# 连接池中的最小空闲连接
spring.redis.pool.min-idle=0
# 连接超时时间(毫秒)
spring.redis.timeout=0

4、新建Redis缓存配置类RedisConfig

如下:

package springboot.config;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.cache.RedisCacheManager;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;


/**
* Redis缓存配置类
* @author szekinwin
*
*/
@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport{

   @Value("${spring.redis.host}")
   private String host;
   @Value("${spring.redis.port}")
   private int port;
   @Value("${spring.redis.timeout}")
   private int timeout;
   
   //自定义缓存key生成策略
//    @Bean
//    public KeyGenerator keyGenerator() {
//        return new KeyGenerator(){
//            @Override
//            public Object generate(Object target, java.lang.reflect.Method method, Object... params) {
//                StringBuffer sb = new StringBuffer();
//                sb.append(target.getClass().getName());
//                sb.append(method.getName());
//                for(Object obj:params){
//                    sb.append(obj.toString());
//                }
//                return sb.toString();
//            }
//        };
//    }
   //缓存管理器
   @Bean 
   public CacheManager cacheManager(@SuppressWarnings("rawtypes") RedisTemplate redisTemplate) {
       RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate);
       //设置缓存过期时间 
       cacheManager.setDefaultExpiration(10000);
       return cacheManager;
   }
   @Bean
   public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory){
       StringRedisTemplate template = new StringRedisTemplate(factory);
       setSerializer(template);//设置序列化工具
       template.afterPropertiesSet();
       return template;
   }
    private void setSerializer(StringRedisTemplate template){
           @SuppressWarnings({ "rawtypes", "unchecked" })
           Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
           ObjectMapper om = new ObjectMapper();
           om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
           om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
           jackson2JsonRedisSerializer.setObjectMapper(om);
           template.setValueSerializer(jackson2JsonRedisSerializer);
    }
}

5、新建UserMapper

如下:

package springboot.dao;

import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.annotations.Update;
import org.springframework.cache.annotation.CacheConfig;
import org.springframework.cache.annotation.CacheEvict;
import org.springframework.cache.annotation.CachePut;
import org.springframework.cache.annotation.Cacheable;

import springboot.domain.User;

@Mapper
@CacheConfig(cacheNames = "users")
public interface UserMapper {

   @Insert("insert into user(name,age) values(#{name},#{age})")
   int addUser(@Param("name")String name,@Param("age")String age);
   
   @Select("select * from user where id =#{id}")
   @Cacheable(key ="#p0") 
   User findById(@Param("id") String id);
   
   @CachePut(key = "#p0")
   @Update("update user set name=#{name} where id=#{id}")
   void updataById(@Param("id")String id,@Param("name")String name);
   
   //如果指定为 true,则方法调用后将立即清空所有缓存
   @CacheEvict(key ="#p0",allEntries=true)
   @Delete("delete from user where id=#{id}")
   void deleteById(@Param("id")String id);
   
}
  • @Cacheable将查询结果缓存到redis中,(key="#p0")指定传入的第一个参数作为redis的key。
  • @CachePut,指定key,将更新的结果同步到redis中
  • @CacheEvict,指定key,删除缓存数据,allEntries=true,方法调用后将立即清除缓存

6、service层与controller层

Service层代码如下:

package springboot.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import springboot.dao.UserMapper;
import springboot.domain.User;


@Service
public class UserService {

   @Autowired
   private UserMapper userMapper;
   
   
   public User findById(String id){
       return userMapper.findById(id);
   }
   
   public int addUser(String name,String age){
       return userMapper.addUser(name,age);
   }
   
   public void updataById(String id,String name){
        userMapper.updataById(id,name);
   }
   
   public void deleteById(String id){
       userMapper.deleteById(id);
   }
}

Controller层,代码如下:

package springboot.web;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import springboot.domain.User;
import springboot.service.UserService;

@RestController
public class HelloController {
   
   @Autowired
   private UserService userService;
   
   @RequestMapping("/adduser")
   public int addUser(@RequestParam("name")String name,@RequestParam("age")String age){
       return userService.addUser(name, age);
   }
   @RequestMapping("/findUser")
   public User findUser(@RequestParam("id") String id){
       return userService.findById(id);
   }
   @RequestMapping("/updataById")
   public String updataById(@RequestParam("id") String id,@RequestParam("name") String name){
       try {
           userService.updataById(id, name);
       } catch (Exception e) {
           return "error";
       }
       return "success";
   }
   
   @RequestMapping("/deleteById")
   public String deleteById(@RequestParam("id") String id){
       try {
           userService.deleteById(id);
       } catch (Exception e) {
           return "error";
       }
       return "success";
   }
}

启动redis服务器,redis服务器的安装与启动可以参考博客,地址如下:

http://www.cnblogs.com/gdpuzxs/p/6623171.html

7、配置log4j日志信息

如下:

## LOG4J配置
log4j.rootCategory=DEBUG,stdout
## 控制台输出
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss,SSS} %5p %c{1}:%L - %m%n

8、验证redis缓存

首先我们向user表总插入一条数据,数据库显示如下:

现在,我们查询一下user表中id=24的数据,观擦控制台输出的信息,如下:

通过控制台输出信息我们可以知道,这次执行了数据库查询,并开启了Redis缓存查询结果。接下来我们再次查询user表中id=24的数据,观察控制台,如下:

通过控制台输出信息我们可以知道,这次并没有执行数据库查询,而是从Redis缓存中查询,并返回查询结果。我们查看redis中的信息,如下:

方法finduser方法使用了注解@Cacheable(key="#p0"),即将id作为redis中的key值。当我们更新数据的时候,应该使用@CachePut(key="#p0")进行缓存数据的更新,否则将查询到脏数据。

cnblogs.com/gdpuzxs/p/7222221.html

本文分享自微信公众号 - Java后端技术栈(t-j20120622),作者:田老师

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2020-01-08

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Spring Boot系列-- 分布式事务解决方案

    LCN事务控制原理是由事务模块TxClient下的代理连接池与TxManager的协调配合完成的事务协调控制。

    用户4143945
  • Spring创建bean的三种方式

    Spring主要从两个角度来实现自动化装配:①组件扫描;②自动装配。组件扫描指的是Spring会自动扫描指定包及其子包下的所有bean,并将其放入s...

    用户4143945
  • spring boot使用自带缓存

    用户4143945
  • 1 Springboot中使用redis,自动缓存、更新、删除

    第一篇记录一下在springboot中,redis的基础用法,自动缓存新增的数据,自动修改及删除。

    天涯泪小武
  • SpringCloud gateway跨域配置

    天涯泪小武
  • SpringBoot2.0 基础案例(08):集成Redis数据库,实现缓存管理

    Spring Boot中除了对常用的关系型数据库提供了优秀的自动化支持之外,对于很多NoSQL数据库一样提供了自动化配置的支持,包括:Redis, MongoD...

    知了一笑
  • @EnableDiscoveryClient和@EnableEurekaClient的区别?

    @EnableDiscoveryClient和@EnableEurekaClient的区别?在前面的服务提供者的例子中我们是用@EnableEurekaClie...

    马克java社区
  • java之异步线程Executor

    说起异步,下意识就想到同步,这两个概念每个人都有着不同的理解,在这我们只是提下这关键词,具体的理解,可自行斟酌。

    用户3625239
  • 日志切面的配置使用

    在User类上加上@Component(value=“user”)//注入beanfactory中

    微醺
  • Spring 实现 SchedulingConfigurer 接口完成动态定时任务(配合数据库动态执行)

    Spring 实现 SchedulingConfigurer 接口完成动态定时任务(配合数据库动态执行)

    一个会写诗的程序员

扫码关注云+社区

领取腾讯云代金券