補習系列(14)-springboot redis 整合-數據讀寫

[TOC]

1、簡介

在 補習系列(A3)-springboot redis 與發佈訂閱 一文中，咱們介紹了使用 Redis 實現消息訂閱發佈的機制，而且給出了一個真實用例。 然而，絕大多數場景下 Redis 是做爲緩存被使用的(這是其主要優點)。除此以外，因爲Redis 提供了 AOF以及RDB兩種持久化機制，某些狀況下也能夠做爲臨時數據庫使用。 本次將介紹 SpringBoot 中如何使用 Redis 進行緩存讀寫。

Redis 的基本命令 在學習以前，須要先了解一些Redis 的基本命令，能夠參考這裏 http://www.redis.cn/

2、SpringBoot Redis 讀寫

A. 引入 spring-data-redis

添加依賴

<!-- redis -->
  <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-data-redis</artifactId>
   <version>${spring-boot.version}</version>
  </dependency>

spring-boot-starter-redis在1.4版本已經廢棄

配置redis鏈接 application.properties

# redis 鏈接配置
spring.redis.database=0 
spring.redis.host=127.0.0.1
spring.redis.password=
spring.redis.port=6379
spring.redis.ssl=false

# 鏈接池最大數
spring.redis.pool.max-active=10 
# 空閒鏈接最大數
spring.redis.pool.max-idle=10
# 獲取鏈接最大等待時間(s)
spring.redis.pool.max-wait=600000

B. 序列化

一樣，咱們須要指定 JSON做爲 Key/HashKey/Value的主要方式：

/**
     * 序列化定製
     * 
     * @return
     */
    @Bean
    public Jackson2JsonRedisSerializer<Object> jackson2JsonSerializer() {
        Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(
                Object.class);

        // 初始化objectmapper
        ObjectMapper mapper = new ObjectMapper();
        mapper.setSerializationInclusion(Include.NON_NULL);
        mapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(mapper);
        return jackson2JsonRedisSerializer;
    }

   /**
     * 操做模板
     * 
     * @param connectionFactory
     * @param jackson2JsonRedisSerializer
     * @return
     */
    @Bean
    public RedisTemplate<String, Object> redisTemplate(JedisConnectionFactory connectionFactory,
            Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer) {

        RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
        template.setConnectionFactory(connectionFactory);

        // 設置key/hashkey序列化
        RedisSerializer<String> stringSerializer = new StringRedisSerializer();
        template.setKeySerializer(stringSerializer);
        template.setHashKeySerializer(stringSerializer);

        // 設置值序列化
        template.setValueSerializer(jackson2JsonRedisSerializer);
        template.setHashValueSerializer(jackson2JsonRedisSerializer);
        template.afterPropertiesSet();

        // template.setValueSerializer(new
        // GenericToStringSerializer<Object>(Object.class));
        return template;
    }

Jackson2JsonRedisSerializer是Jackson轉換的橋接器； RedisTemplate是用於讀寫的主要操做類；

C. 讀寫樣例

首先定義一個Pet實體類

public class RedisPet {

    private String name;
    private String type;
... ignore get set

利用RedisTemplate封裝一層Repository，以下：

@Repository
    public static class PetRepository {

        private static final String KEY = "Pets";

        @Autowired
        private RedisTemplate<String, Object> redisTemplate;
        private HashOperations<String, String, Object> hashOperations;

        @PostConstruct
        private void init() {
            hashOperations = redisTemplate.opsForHash();
        }

        public void add(RedisPet pet) {
            hashOperations.put(KEY, pet.getName(), pet);
        }

        public RedisPet find(String name) {
            return (RedisPet) hashOperations.get(KEY, name);
        }

        public Map<String, Object> findAll() {
            return hashOperations.entries(KEY);
        }
        
        public void clear() {
            hashOperations.getOperations().delete(KEY);
        }
    }

在**PetRepository **的實現中，咱們利用Hash結構來存儲 Pet信息(Pet.name是key) 分別實現了添加(add)/查找(get)/清除(clear)等方法。

最後，實現讀寫調用：

@Service
public class RedisDataOperation {

    private static final Logger logger = LoggerFactory.getLogger(RedisDataOperation.class);

    @Autowired
    private PetRepository petRepo;


    @PostConstruct
    public void start() {

        RedisPet pet1 = new RedisPet("Polly", "Bird");
        RedisPet pet2 = new RedisPet("Tom", "Cat");

        //寫入寵物信息
        petRepo.add(pet1);
        petRepo.add(pet2);

        //打印寵物信息
        logger.info("polly {}", JsonUtil.toJson(petRepo.find("Polly")));
        logger.info("pets  {}", JsonUtil.toJson(petRepo.findAll()));

        //清空
        petRepo.clear();
    }

上面的代碼在應用啓動時，會寫入兩個Pet信息，以後完成清理，控制檯輸出以下：

RedisDataOperation : polly {"name":"Polly","type":"Bird"}
RedisDataOperation : pets {"Tom":{"name":"Tom","type":"Cat"},"Polly":{"name":"Polly","type":"Bird"}}

3、方法級緩存

除了上面的RedisTemplate，spring-data-redis還提供了方法級緩存, 就是將業務方法的執行結果緩存起來，後面再次調用直接從緩存中取得結果返回。

這種方式能夠簡化緩存邏輯的代碼，好比配置類數據的讀取，經過方法註解就能夠實現， 下面是一個樣例：

/**
 * 方法級緩存樣例
 * 
 * @author atp
 *
 */
@Service
public class RedisCacheOperation {

    private static final Logger logger = LoggerFactory.getLogger(RedisCacheOperation.class);

    public static final String PREFIX = "pets:";
    public static final String WRAP_PREFIX = "'pets:'";

    /**
     * 當結果不爲空時緩存
     * 
     * @param name
     * @return
     */
    @Cacheable(value = "petCache", key = WRAP_PREFIX + "+#name", unless = "#result==null")
    public RedisPet getPet(String name) {
        logger.info("get pet {}", name);
        return new RedisPet(name, "Bird");
    }

    /**
     * 當結果不爲空時淘汰緩存
     * 
     * @param pet
     * @return
     */
    @CacheEvict(value = "petCache", key = WRAP_PREFIX + "+#pet.name", condition = "#result!=null")
    public RedisPet updatePet(RedisPet pet) {
        logger.info("update pet {}", pet.getName());
        return new RedisPet(pet.getName(), "Bird1");
    }

    /**
     * 當結果爲true時淘汰緩存
     * 
     * @param name
     * @return
     */
    @CacheEvict(value = "petCache", key = WRAP_PREFIX + "+#name", condition = "#result==true")
    public boolean deletePet(String name) {
        logger.info("delete pet {}", name);
        return true;
    }
}

涉及到幾個註解：

註解	說明
@Cachable	方法執行結果緩存
@CachePut	方法執行結果緩存(強制)
@CacheEvict	方法執行時觸發刪除

其中 @CachePut 與 @Cachable 的區別在於，前者必定會執行方法，並嘗試刷新緩存(條件知足)， 然後者則是當緩存中不存在時纔會執行方法並更新。 註解中的屬性 key/condition 都支持經過 Spring EL 表達式來引用參數對象。

啓用註解

除了上面的代碼，咱們還須要使用 @EnableCaching 啓用註解：

@EnableCaching
@Configuration
public class RedisConfig {

    private static final Logger logger = LoggerFactory.getLogger(RedisConfig.class);

    /**
     * 緩存管理，支持方法級註解
     * 
     * @param template
     * @return
     */
    @Bean
    public RedisCacheManager cacheManager(RedisTemplate<String, Object> template) {
        RedisCacheManager redisCacheManager = new RedisCacheManager(template);
        // 默認過時時間
        redisCacheManager.setDefaultExpiration(30 * 60 * 1000);
        return redisCacheManager;
    }

當@Cacheable 的key屬性爲空時，框架會自動生成，格式相似：

param1,param2,param3...

若是但願修改默認的行爲，可使用自定義的 KeyGenerator：

/**
     * 定製方法緩存的key生成策略
     *
     * @return
     */
    @Bean
    public KeyGenerator keyGenerator() {
        return new KeyGenerator() {
            @Override
            public Object generate(Object target, Method method, Object... args) {
                StringBuilder sb = new StringBuilder();
                sb.append(target.getClass().getName());
                sb.append(method.getName());

                for (Object arg : args) {
                    sb.append(arg.toString());
                }
                return sb.toString();
            }
        };
    }

單元測試

使用一小段單元測試代碼來測試方法級緩存功能

@RunWith(SpringRunner.class)
@SpringBootTest(classes =BootSampleRedis.class)
public class RedisCacheOperationTest {

    private static final Logger logger = LoggerFactory.getLogger(RedisCacheOperationTest.class);

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    @Autowired
    private RedisCacheOperation operation;

    private RedisPet pet1 = new RedisPet("Polly", "Bird");

    @Test
    public void testGet() {
        operation.getPet(pet1.getName());

        Object object = redisTemplate.opsForValue().get(RedisCacheOperation.PREFIX + pet1.getName());
        logger.info(String.valueOf(object));

        assertNotNull(object);
    }

    @Test
    public void testUpdate() {
        operation.updatePet(pet1);

        Object object = redisTemplate.opsForValue().get(RedisCacheOperation.PREFIX + pet1.getName());
        logger.info(String.valueOf(object));

        assertNull(object);
    }

    @Test
    public void testDelete() {
        operation.getPet(pet1.getName());

        // delete cache
        operation.deletePet(pet1.getName());

        Object object = redisTemplate.opsForValue().get(RedisCacheOperation.PREFIX + pet1.getName());
        logger.info(String.valueOf(object));

        assertNull(object);
    }

}

4、鏈接池

若是但願經過代碼來配置 Jedis 的鏈接池(熟悉的方式)，能夠聲明 JedisConnectionFactory 實現：

/**
     * 鏈接池配置
     *
     * @return
     */
    @Bean
    public JedisConnectionFactory jedisConnectionFactory() {
        JedisPoolConfig config = new JedisPoolConfig();

        // 最大鏈接
        config.setMaxTotal(10);
        // 最大空閒，與最大鏈接保持一致，可減小頻繁鍵鏈的開銷
        config.setMaxIdle(10);
        // 鏈接最大空閒時間
        config.setMinEvictableIdleTimeMillis(10 * 60 * 1000);
        // 獲取鏈接等待的最大時長
        config.setMaxWaitMillis(30000);

        // 進行空閒鏈接檢測的時間間隔
        config.setTimeBetweenEvictionRunsMillis(30 * 1000);
        // 取消沒必要要的test，有利於性能提高
        config.setTestOnBorrow(false);![](https://img2018.cnblogs.com/blog/242916/201812/242916-20181206231048870-1133770725.png)

        config.setTestOnReturn(false);

        JedisConnectionFactory factory = new JedisConnectionFactory(config);
        factory.setHostName("127.0.0.1");
        factory.setPort(6379);

        logger.info("redis config init first");
        return factory;
    }

更多配置可參考這裏

示例代碼可從 碼雲gitee 下載。 https://gitee.com/littleatp/springboot-samples/

小結

Redis 在大多數項目中的核心用途是緩存，spring-data-redis 爲 SpringBoot 中集成 Redis 讀寫的封裝。 除了 RedisTemplate以外，還實現了方法級的緩存註解，必定程度上簡化了業務的使用。 Redis 在分佈式系統中的應用場景有不少，後續有機會將進行更多的探討。

歡迎繼續關注"美碼師的補習系列-springboot篇" ，期待更多精彩內容^-^