别在只用RedisTemplate来访问Redis了。

以你之姓@ 2024-03-23 12:30 20阅读 0赞

### 开始准备 ###

开始之前我们需要有Redis安装，我们采用本机Docker运行Redis, 主要命令如下

docker pull redis
    docker run --name my_redis -d -p 6379:6379 redis
    docker exec -it my_redis bash
    redis-cli
    复制代码

前面两个命令是启动redis docker, 后两个是连接到docker, 在使用redis-cli 去查看redis里面的内容，主要查看我们存在redis里面的数据。

### RedisTemplate ###

我们先从RedisTemplate开始，这个是最好理解的一种方式，我之前在工作中也使用过这种方式，先看代码示例 我们先定义一个POJO类

@Data
    @Builder
    @NoArgsConstructor
    @AllArgsConstructor
    public class Book implements Serializable {
        private Long id;
        private String name;
    
        private String author;
    }
    复制代码

一个很简单的BOOK类，三个字段： id,name和author. 再来一个RedisTemplate的Bean

@Bean
        public RedisTemplate<String, Book> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
            RedisTemplate<String, Book> template = new RedisTemplate<>();
            template.setConnectionFactory(redisConnectionFactory);
            return template;
        }
    复制代码

再定义一个使用这个RedisTemplate的Service类

public Optional<Book> findOneBook(String name) {
            HashOperations<String, String, Book> hashOperations = redisTemplate.opsForHash();
            if (redisTemplate.hasKey(CACHE) && hashOperations.hasKey(CACHE, name)) {
                log.info("Get book {} from Redis.", name);
                return Optional.of(hashOperations.get(CACHE, name));
            }
    
            Optional<Book> book = bookRepository.getBook(name);
            log.info("Book Found: {}", book);
            if (book.isPresent()) {
                log.info("Put book {} to Redis.", name);
                hashOperations.put(CACHE, name, book.get());
                redisTemplate.expire(CACHE, 10, TimeUnit.MINUTES);
            }
            return book;
        }
    复制代码

我们使用Hash来存储这个Book信息，在上面的方法中查找书名存不存在Redis中，如果存在就直接返回，如果不存在就去持久化存储中找，找到就再通过Template写入到Redis中， 这是缓存的通用做法。 使用起来感觉很方便。 我们这里为了简单没有使用持久化存储，就硬编码了几条数据, 代码如下

@Repository
    public class BookRepository {
        Map<String, Book> bookMap = new HashMap<>();
        public BookRepository(){
            bookMap.put("apache kafka", Book.builder()
                    .name("apache kafka").id(1L).author("zhangsan")
                    .build());
            bookMap.put("python", Book.builder()
                    .name("python").id(2L).author("lisi")
                    .build());
        }
    
        public Optional<Book> getBook(String name){
            if(bookMap.containsKey(name)){
                return Optional.of(bookMap.get(name));
            }
            else{
                return Optional.empty();
            }
        }
    }
    复制代码</