工作中经常需要进行某一小段代码的测试,来保证代码的正确性。测试普通的代码还好说,如果要连接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 {
@Beanpublic 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 {
@Resourcepublic RedisTemplate<String, Object> redisTemplate;@Resourcepublic 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 {
@Resourceprivate RedisUtils redisUtils;@Resourceprivate RedisTemplate<String, Object> redisTemplate;@Testvoid 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: 0host: 127.0.0.1port: 6379password:
这样我们就可以随心所欲地测试Redis了,舒服。
喜欢本文的朋友不要忘记点一个免费的赞哦,你的赞将是我最大的动力。