快捷導(dǎo)航

Redis在項(xiàng)目中的使用(JedisPool方式)

更新時(shí)間：2021年12月24日 11:22:17 作者：HongMaJu

項(xiàng)目操作redis是使用的RedisTemplate方式，另外還可以完全使用JedisPool和Jedis來(lái)操作redis,本文給大家介紹Redis在項(xiàng)目中的使用，JedisPool方式，感興趣的朋友跟隨小編一起看看吧

springboot中redis相關(guān)配置

1、pom.xml中引入依賴(lài)

<dependency>
  <groupId>redis.clients</groupId>
  <artifactId>jedis</artifactId>
  <version>2.9.0</version>
</dependency>

2、springboot的習(xí)慣優(yōu)于配置。也在項(xiàng)目中使用了application.yml文件配置mysql的基本配置項(xiàng)。這里也在application.yml里面配置redis的配置項(xiàng)。

spring:
  datasource:
        # 驅(qū)動(dòng)配置信息
        url: jdbc:mysql://localhost:3306/spring_boot?useUnicode=true&characterEncoding=utf8
        username: root
        password: root
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.jdbc.Driver

        # 連接池的配置信息
        filters: stat
        maxActive: 20
        initialSize: 1
        maxWait: 60000
        minIdle: 1
        timeBetweenEvictionRunsMillis: 60000
        minEvictableIdleTimeMillis: 300000
        validationQuery: select 'x'
        testWhileIdle: true
        testOnBorrow: false
        testOnReturn: false
        poolPreparedStatements: true
        maxOpenPreparedStatements: 20
  redis:
        host: 127.0.0.1
        port: 6379
        password: pass1234
        pool:
          max-active: 100
          max-idle: 10
          max-wait: 100000
        timeout: 0

springboot中redis相關(guān)類(lèi)

項(xiàng)目操作redis是使用的RedisTemplate方式，另外還可以完全使用JedisPool和Jedis來(lái)操作redis。整合的內(nèi)容也是從網(wǎng)上收集整合而來(lái)，網(wǎng)上整合的方式和方法非常的多，有使用注解形式的，有使用Jackson2JsonRedisSerializer來(lái)序列化和反序列化key value的值等等，很多很多。這里使用的是我認(rèn)為比較容易理解和掌握的，基于JedisPool配置，使用RedisTemplate來(lái)操作redis的方式。

redis單獨(dú)放在一個(gè)包redis里，在包里先創(chuàng)建RedisConfig.java文件。

RedisConfig.java

@Configuration
@EnableAutoConfiguration
public class RedisConfig {

    @Bean
    @ConfigurationProperties(prefix = "spring.redis.pool")
    public JedisPoolConfig getRedisConfig(){
        JedisPoolConfig config = new JedisPoolConfig();
        return config;
    }

    @Bean
    @ConfigurationProperties(prefix = "spring.redis")
    public JedisConnectionFactory getConnectionFactory() {
        JedisConnectionFactory factory = new JedisConnectionFactory();
        factory.setUsePool(true);
        JedisPoolConfig config = getRedisConfig();
        factory.setPoolConfig(config);
        return factory;
    }

    @Bean
    public RedisTemplate<?, ?> getRedisTemplate() {
        JedisConnectionFactory factory = getConnectionFactory();
        RedisTemplate<?, ?> template = new StringRedisTemplate(factory);
        return template;
    }

}

在包里創(chuàng)建RedisService接口的實(shí)現(xiàn)類(lèi)RedisServiceImpl，這個(gè)類(lèi)實(shí)現(xiàn)了接口的所有方法。

RedisServiceImpl.java

@Service("redisService")
public class RedisServiceImpl implements RedisService {

    @Resource
    private RedisTemplate<String, ?> redisTemplate;

    @Override
    public boolean set(final String key, final String value) {
        boolean result = redisTemplate.execute(new RedisCallback<Boolean>() {
            @Override
            public Boolean doInRedis(RedisConnection connection) throws DataAccessException {
                RedisSerializer<String> serializer = redisTemplate.getStringSerializer();
                connection.set(serializer.serialize(key), serializer.serialize(value));
                return true;
            }
        });
        return result;
    }

    @Override
    public String get(final String key) {
        String result = redisTemplate.execute(new RedisCallback<String>() {
            @Override
            public String doInRedis(RedisConnection connection) throws DataAccessException {
                RedisSerializer<String> serializer = redisTemplate.getStringSerializer();
                byte[] value = connection.get(serializer.serialize(key));
                return serializer.deserialize(value);
            }
        });
        return result;
    }

    @Override
    public boolean expire(final String key, long expire) {
        return redisTemplate.expire(key, expire, TimeUnit.SECONDS);
    }

    @Override
    public boolean remove(final String key) {
        boolean result = redisTemplate.execute(new RedisCallback<Boolean>() {
            @Override
            public Boolean doInRedis(RedisConnection connection) throws DataAccessException {
                RedisSerializer<String> serializer = redisTemplate.getStringSerializer();
                connection.del(key.getBytes());
                return true;
            }
        });
        return result;
    }
}

在這里execute()方法具體的底層沒(méi)有去研究，只知道這樣能實(shí)現(xiàn)對(duì)于redis數(shù)據(jù)的操作。
redis保存的數(shù)據(jù)會(huì)在內(nèi)存和硬盤(pán)上存儲(chǔ)，所以需要做序列化；這個(gè)里面使用的StringRedisSerializer來(lái)做序列化，不過(guò)這個(gè)方式的泛型指定的是String，只能傳String進(jìn)來(lái)。所以項(xiàng)目中采用json字符串做redis的交互。

到此，redis在springboot中的整合已經(jīng)完畢，下面就來(lái)測(cè)試使用一下。

5. springboot項(xiàng)目中使用redis

在這里就直接使用springboot項(xiàng)目中自帶的單元測(cè)試類(lèi)SpringbootApplicationTests進(jìn)行測(cè)試。

@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringbootApplicationTests {

    private JSONObject json = new JSONObject();

    @Autowired
    private RedisService redisService;

    @Test
    public void contextLoads() throws Exception {
    }


    /**
     * 插入字符串
     */
    @Test
    public void setString() {
        redisService.set("redis_string_test", "springboot redis test");
    }

    /**
     * 獲取字符串
     */
    @Test
    public void getString() {
        String result = redisService.get("redis_string_test");
        System.out.println(result);
    }

    /**
     * 插入對(duì)象
     */
    @Test
    public void setObject() {
        Person person = new Person("person", "male");
        redisService.set("redis_obj_test", json.toJSONString(person));
    }

    /**
     * 獲取對(duì)象
     */
    @Test
    public void getObject() {
        String result = redisService.get("redis_obj_test");
        Person person = json.parseObject(result, Person.class);
        System.out.println(json.toJSONString(person));
    }

    /**
     * 插入對(duì)象List
     */
    @Test
    public void setList() {
        Person person1 = new Person("person1", "male");
        Person person2 = new Person("person2", "female");
        Person person3 = new Person("person3", "male");
        List<Person> list = new ArrayList<>();
        list.add(person1);
        list.add(person2);
        list.add(person3);
        redisService.set("redis_list_test", json.toJSONString(list));
    }

    /**
     * 獲取list
     */
    @Test
    public void getList() {
        String result = redisService.get("redis_list_test");
        List<String> list = json.parseArray(result, String.class);
        System.out.println(list);
    }

    @Test
    public void remove() {
        redisService.remove("redis_test");
    }

}

class Person {
    private String name;
    private String sex;

    public Person() {

    }

    public Person(String name, String sex) {
        this.name = name;
        this.sex = sex;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getSex() {
        return sex;
    }

    public void setSex(String sex) {
        this.sex = sex;
    }
}

在這里先是用@Autowired注解把redisService注入進(jìn)來(lái)，然后由于是使用json字符串進(jìn)行交互，所以引入fastjson的JSONObject類(lèi)。然后為了方便，直接在這個(gè)測(cè)試類(lèi)里面加了一個(gè)Person的內(nèi)部類(lèi)。

一共測(cè)試了：對(duì)于string類(lèi)型的存取，對(duì)于object類(lèi)型的存取，對(duì)于list類(lèi)型的存取，其實(shí)本質(zhì)都是轉(zhuǎn)成了json字符串。還有就是根據(jù)key來(lái)執(zhí)行remove操作。

獲取字符串：