一区二区三区在线-一区二区三区亚洲视频-一区二区三区亚洲-一区二区三区午夜-一区二区三区四区在线视频-一区二区三区四区在线免费观看

服務器之家:專注于服務器技術及軟件下載分享
分類導航

PHP教程|ASP.NET教程|JAVA教程|ASP教程|編程技術|正則表達式|C/C++|IOS|C#|Swift|Android|JavaScript|易語言|

服務器之家 - 編程語言 - JAVA教程 - SpringBoot使用Redis緩存的實現方法

SpringBoot使用Redis緩存的實現方法

2021-03-31 13:20gdpuzxs JAVA教程

這篇文章主要介紹了SpringBoot使用Redis緩存的實現方法,需要的朋友可以參考下

(1)pom.xml引入jar包,如下:

?
1
2
3
4
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
  </dependency>

  (2)修改項目啟動類,增加注解@EnableCaching,開啟緩存功能,如下:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
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連接信息,如下:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
# 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,如下:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
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,如下:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
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層跟上一篇整合一樣,啟動redis服務器,redis服務器的安裝與啟動可以參考之前的博客,地址如下:

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

  (7)配置log4j日志信息,如下:

?
1
2
3
4
5
6
## 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")進行緩存數據的更新,否則將查詢到臟數據。

總結

以上所述是小編給大家介紹的SpringBoot使用Redis緩存的實現方法,希望對大家有所幫助,如果大家有任何疑問歡迎給我留言,小編會及時回復大家的!

原文鏈接:https://www.cnblogs.com/gdpuzxs/p/7222309.html

延伸 · 閱讀

精彩推薦
主站蜘蛛池模板: 午夜宅男宅女看在线观看 | 日本不卡视频免费的 | 久久精品国产久精国产果冻传媒 | 无颜之月全集免费观看 | 黄瓜污视频| 国产女乱淫真高清免费视频 | gay男强壮军人chinese | 精品女同同性视频很黄很色 | 国产99精品免费视频看6 | 男同桌脱我奶罩吸我奶作文 | 亚洲国产精品二区久久 | 按摩院已婚妇女中文字幕 | 精品视频网站 | 国产高清在线视频一区二区三区 | 无限资源在线观看完整版免费下载 | 武侠古典久久亚洲精品 | 亚洲男女在线 | 天堂俺去俺来也www久久婷婷 | 男女做受快插大片 | 国产综合视频 | 日本三级免费网站 | 性吟网| 四虎最新永久在线精品免费 | youjizzxxx在线观看 | 色帝国亚洲欧美在线蜜汁tv | 韩国三级在线观看 完整版 韩国三级视频网站 | 福利视频一区二区牛牛 | 青青青手机在线视频 | 91亚洲成人 | aa视频免费| 513热点网 | 青草视频在线观看视频 | 国产精品视频一区二区三区 | 国产suv精品 | 精品久久日日躁夜夜躁AV | 久久re视频精品538在线 | 美女被扒开屁股进去网 | 国产午夜精品一区二区 | 日韩中文字幕一区 | 日韩免费在线观看 | 日韩高清成人毛片不卡 |