本地测试用例,测试RedisUtils、RedisTemplat

2022-09-11  本文已影响0人  王月亮17

工作中经常需要进行某一小段代码的测试,来保证代码的正确性。测试普通的代码还好说,如果要连接Redis,测试一些RedisTemplate读取出来的数据类型是否可以进行转换等,则比较麻烦。
我一般测试代码、请求测试接口都是创建一个单独的专门用于测试的SpringBoot项目,这样会方便很多。

进入正题:

首先第一步,测试自己封装的RedisUtils或者RedisTemplate,我们需要在项目中引入Spring的Redis相关依赖:

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

然后配置对Redis进行配置,配置一个RedisConfig配置类:

@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {
    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(factory);
        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);
        StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
        template.setKeySerializer(stringRedisSerializer);
        template.setHashKeySerializer(stringRedisSerializer);
        template.setValueSerializer(jackson2JsonRedisSerializer);
        template.setHashValueSerializer(jackson2JsonRedisSerializer);
        template.afterPropertiesSet();
        return template;
    }
}

写一个RedisUtils工具类:

@Component
public class RedisUtils {

    @Resource
    public RedisTemplate<String, Object> redisTemplate;

    @Resource
    public StringRedisTemplate stringRedisTemplate;

    /**
     * 添加一个key,无过期时间
     *
     * @param key
     * @param value
     */
    public void set(String key, Object value) {
        redisTemplate.opsForValue().set(key, value);
    }

    /**
     * 添加value为字符串的数据
     *
     * @param key
     * @param value
     */
    public void setString(String key, String value) {
        stringRedisTemplate.opsForValue().set(key, value);
    }

    /**
     * 添加value为字符串的数据
     *
     * @param key
     * @param value
     */
    public void setString(String key, String value, long time, TimeUnit timeUnit) {
        stringRedisTemplate.opsForValue().set(key, value, time, timeUnit);
    }

    /**
     * 获取value为字符串的数据
     *
     * @param key
     * @return
     */
    public String getString(String key) {
        return stringRedisTemplate.opsForValue().get(key);
    }

    /**
     * 添加一个key,并设置过期时间
     *
     * @param key
     * @param value
     * @param time
     * @param timeUnit
     */
    public void set(String key, Object value, long time, TimeUnit timeUnit) {
        redisTemplate.opsForValue().set(key, value, time, timeUnit);
    }

    /**
     * get redis value
     *
     * @param key
     * @return
     */
    public Object get(String key) {
        return redisTemplate.opsForValue().get(key);
    }

    /**
     * 设置key的过期时间
     *
     * @param key
     * @param time
     * @param timeUnit
     */
    public Boolean expire(String key, long time, TimeUnit timeUnit) {
        return redisTemplate.expire(key, time, timeUnit);
    }

    /**
     * 删除key
     *
     * @param key
     */
    public Boolean delete(String key) {
        return redisTemplate.delete(key);
    }

    /**
     * 判断key是否存在
     *
     * @param key
     * @return
     */
    public Boolean hasKey(String key) {
        return redisTemplate.hasKey(key);
    }

    /**
     * 设置hash
     */
    public void setHash(String key, Map<String, Object> map) {
        redisTemplate.opsForHash().putAll(key, map);
    }

    /**
     * 设置hash
     */
    public void setHash(String key, String hashKey, Object value) {
        redisTemplate.opsForHash().put(key, hashKey, value);
    }

    /**
     * 判断hash中是否存在某个key
     */
    public Boolean hasHash(String key, String hashKey) {
        return redisTemplate.opsForHash().hasKey(key, hashKey);
    }

    /**
     * 获取hash
     */
    public Map<Object, Object> getHash(String key) {
        return redisTemplate.opsForHash().entries(key);
    }

    /**
     * 获取hash某个key的值
     */
    public Object getHash(String key, String hashKey) {
        return redisTemplate.opsForHash().get(key, hashKey);
    }

    /**
     * 删除hash中的某个key
     */
    public Object deleteHash(String key, String hashKey) {
        return redisTemplate.opsForHash().delete(key, hashKey);
    }

    /**
     * increment
     *
     * @param key
     * @return
     */
    public Long increment(String key) {
        return redisTemplate.opsForValue().increment(key);
    }

    /**
     * increment
     *
     * @param key
     * @param delta
     * @return
     */
    public Long increment(String key, long delta) {
        return redisTemplate.opsForValue().increment(key, delta);
    }

    /**
     * decrement
     *
     * @param key
     * @return
     */
    public Long decrement(String key) {
        return redisTemplate.opsForValue().decrement(key);
    }

    /**
     * decrement
     *
     * @param key
     * @param delta
     * @return
     */
    public Long decrement(String key, long delta) {
        return redisTemplate.opsForValue().decrement(key, delta);
    }

    /**
     * list right push
     * @param key
     * @param value
     */
    public void listPush(String key, String value) {
        stringRedisTemplate.opsForList().rightPush(key, value);
    }

    /**
     * list left pop string
     * @param key
     * @return
     */
    public String listPop(String key) {
        return stringRedisTemplate.opsForList().leftPop(key);
    }

    public List<String> range(String key) {
        return stringRedisTemplate.opsForList().range(key, 0, -1);
    }

    public Set<String> keys(String keyPrefix) {
        return redisTemplate.keys(keyPrefix + "*");
    }
}

然后在test路径下创建测试类,就可以直接测试了:

@SpringBootTest
class TestApplicationTests {

    @Resource
    private RedisUtils redisUtils;

    @Resource
    private RedisTemplate<String, Object> redisTemplate;
    
    @Test
    void redisTest() {
        redisUtils.set("test_key", "test_value");
        redisUtils.get("test_key");
        redisTemplate.opsForValue().set("test_key", "test_value");
        redisTemplate.opsForValue().get("test_key");
    }
}

application.yml中并没有配置Redis连接信息,默认连接信息是下面这个样子的:

spring:
  redis:
    database: 0
    host: 127.0.0.1
    port: 6379
    password: 

这样我们就可以随心所欲地测试Redis了,舒服。

上一篇 下一篇

猜你喜欢

热点阅读