SringBoot整合Redis

Spring整合redis

Spring Data 好处很方便操作对象类型。 把Redis不同值得类型放到一个opsForXXX方法中。

opsForValue : String值

  opsForList : 列表List

  opsForHash: 哈希表Hash

  opsForZSet: 有序集合Sorted Set

  opsForSet : 集合

导入依赖

<!--redis启动器 其他不做描述--> 
              <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-redis</artifactId>
                <version>2.6.4</version>
            </dependency>
           
             <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
                <version>2.6.4</version>
            </dependency>

            <dependency>
                <groupId>org.junit.jupiter</groupId>
                <artifactId>junit-jupiter</artifactId>
                <version>5.8.2</version>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
                <version>2.6.4</version>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>2.2.2</version>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <version>1.18.22</version>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>8.0.28</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-thymeleaf</artifactId>
                <version>2.6.4</version>
            </dependency>

跟之前的架构一样,
这里只展示关键代码~

定义一个redis配置类

package com.gavin.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

@Configuration
public class RedisConfigDemo {


    /**
     * @param factory
     * @return RedisTemplate
     * <p>
     * RedisTemplate --简化 Redis 数据访问代码的助手类
     * </p>
     * RedisTemplate<K,V> 类型参数：
     * K- 模板工作的 Redis 键类型（通常是字符串）
     * V- 模板适用的 Redis 值类型
     * 在给定对象和底层二进制数据之间执行自动序列化/反序列化 Redis 存储。
     * 默认情况下，它对其对象使用JdkSerializationRedisSerializer 序列化。
     * 对于字符串密集型操作，请考虑用 StringRedisTemplate.
     */
    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        /**
         * 设置连接工厂~Redis连接的线程安全工厂。
         */
        template.setConnectionFactory(factory);
        
        /**设置key~字符串序列化方式
         * StringRedisSerializer
         * 简单的 String到 byte[] （和返回）序列化程序。
         * 转换 Strings 使用指定的字符集（默认为 UTF-8）转换为字节，反之亦然。
         * 当与 Redis 的交互主要通过字符串发生时很有用。
         * 不执行任何 null 转换，因为空字符串是有效的键/值
         */
        template.setKeySerializer(new StringRedisSerializer());

        /**Jackson2JsonRedisSerializer
         * 读取和写入 JSON 格式 对象
         * 转换器可用于绑定到类型化的 bean，或非类型化的 HashMap实例。
         * 注意： Null 对象被序列化为空数组，反之亦然。
         */
        template.setValueSerializer(new Jackson2JsonRedisSerializer<Object>(Object.class));
        return  template;
    }
}

服务实现

package com.gavin.service.impl;

import com.gavin.mapper.GoodsMapper;
import com.gavin.pojo.Goods;
import com.gavin.service.redisService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.stereotype.Service;

@Service
public class redisServiceImpl implements redisService {

    @Autowired
    private GoodsMapper goodsMappper;
    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    @Override
    public Goods selectById(Integer id) {
//        先从redis中获取数据
        String key = "Goods:" + id;
        if (redisTemplate.hasKey(key)) {
            System.out.println("执行缓存查找");
            redisTemplate.setValueSerializer(new Jackson2JsonRedisSerializer<Goods>(Goods.class));
            Goods goods = (Goods) redisTemplate.opsForValue().get(key);
            return goods;
        }
        System.out.println("执行了mysql");
        Goods goods = goodsMappper.selectByPrimaryKey(id);

        //将数据放入redis
        // redisTemplate.opsForValue()返回对值的操作
        redisTemplate.opsForValue().set(key,goods);
        return goods;
    }
}

controller层

import com.gavin.pojo.Goods;
import com.gavin.service.redisService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;

/**
 * @author Gavin
 */
@Controller
public class RedisController {
    @Autowired
    private redisService redisService;

@RequestMapping("/goods")
    public String selectById(Integer id, Model model) {

    Goods goods = redisService.selectById(id);
    model.addAttribute("goods",goods);
    return "index";
}
}

application.yml

spring:
    #配置数据源
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/gavin
    username: gavin
    password: 955945
   #单机版redis设置
  redis:
    host: 192.168.135.145
    port: 6379    
 #   redis集群配置
  redis:
    cluster:
      nodes: 192.168.135.145:6789,192.168.135.145:6790,192.168.135.145:6791,192.168.135.145:6792,192.168.135.145:6793,192.168.135.145:6794

mybatis:
  #mapper位置
  mapper-locations: classpath:/com.gavin.mapper/*.xml
  #实体类别名
  type-aliases-package: com.gavin.pojo

返回list集合

//list集合
    @Override
    public List<Goods> selectAllGoods() {
        String key="goodsInfo";
        if (redisTemplate.hasKey(key)){
            System.out.println("redis缓存中已找到");
            redisTemplate.setValueSerializer(new Jackson2JsonRedisSerializer<List>(List.class));
            List<Goods> goodsInfo = (List<Goods>)redisTemplate.opsForValue().get("goodsInfo");
            return  goodsInfo;
        }
        System.out.println("执行了 mysql");
        List<Goods> goodsInfo = goodsMappper.selectAll();
        redisTemplate.opsForValue().set(key,goodsInfo);

        return goodsInfo;
    }