SpringBoot Redisキャッシュを使用した実現方法

7539 ワード

スプリングブック redis キャッシュ

（1）pom.xml jarパッケージを導入すると、以下のようになります。

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

（2）プロジェクトの起動類を修正し、注釈@EnbleCachingを追加し、キャッシュ機能を起動し、下記の通りである：


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）appication.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);
}

@Cachebaleは、照会結果をredisにキャッシュし、（key=「菗p 0」）は、着信した最初のパラメータをredisのkeyとして指定する。
@CachePut、keyを指定して、更新の結果をredisに同期させます。
@Cacheevict、keyを指定して、キャッシュデータを削除します。all Enties=true、メソッドが起動したらすぐにキャッシュをクリアします。
（6）service層とcontroler層が一つの統合に従うように、redisサーバを起動し、redisサーバのインストールと起動は前のブログを参照してください。住所は以下の通りです。
http://www.cnblogs.com/gdpuzxs/p/6623171.html
（7）プロファイル4 jログ情報は、以下の通りです。


## 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法は注釈@Cachebale（key=「菗p 0」）を使用しており、これからはidがredisのkey値として使われます。データを更新するときは、@CachePut（key=「菗p 0」）を使ってキャッシュデータの更新を行います。でないと、汚いデータを検索します。
締め括りをつける
以上は小编で绍介したSpringBootがRedisキャッシュを使って実现した方法です。皆さんに助けてほしいです。もし何か疑问があれば、メッセージをください。小编はすぐに返事します。

koa+jwtはtoken検証とリフレッシュ機能を実現します。

SpringBootにおけるカスタムパラメータバインディング手順の詳細