使用Spring-data进行Redis操作

使用Spring-data进行Redis操作 http://zhaozhiming.github.io/blog/2015/04/12/spring-data-redis/
Redis整合Spring结合使用缓存实例 http://blog.csdn.net/evankaka/article/details/50396325
征服 Redis + Jedis + Spring （一）—— 配置&常规操作（GET SET DEL） http://snowolf.iteye.com/blog/1666908

Redis相信大家都听说过，它是一个开源的key-value缓存数据库，有很多Java的客户端支持，比较有名的有Jedis，JRedis等（见这里）。当然我们可以使用客户端的原生代码实现redis的操作，但实际上在spring中就已经集成了这些客户端的使用，下面我们就以Jedis为例来介绍一下Spring中关于Redis的配置。
下载相关依赖包
首先要下载spring和redis相关的依赖包，最新的jedis版本是2.6.2，还需要下载jackson的包，这个后面会介绍为什么需要，以gradle脚本示例如下。
build.gradle

Java代码

compile("redis.clients:jedis:" + jedisVersion)

compile "org.springframework.data:spring-data-redis:" + springDataRedisVersion

//json

compile "com.fasterxml.jackson.core:jackson-databind:" + jacksonDatabindVersion

compile "org.codehaus.jackson:jackson-mapper-asl:" + jacksonVersion

compile "org.codehaus.jackson:jackson-core-asl:" + jacksonVersion

spring配置jedis
在spring的xml配置文件中，做如下配置。

Xml代码

</bean>

</bean>

</property>

</bean>

序列化
在spring中进行redis存储，如果没有对key和value进行序列化，保存到redis中会出现乱码。注意看上面的redis模板配置，有个配置项是defaultSerializer，这里表示redis中的key和value遇到需要序列化的时候，都默认使用StringRedisSerializer这个类来进行序列化。如果不指定序列化的话，内容会带乱码。
spring-data-redis的序列化类有下面这几个:
GenericToStringSerializer: 可以将任何对象泛化为字符串并序列化
Jackson2JsonRedisSerializer: 跟JacksonJsonRedisSerializer实际上是一样的
JacksonJsonRedisSerializer: 序列化object对象为json字符串
JdkSerializationRedisSerializer: 序列化java对象
StringRedisSerializer: 简单的字符串序列化
一般如果key-value都是string的话，使用StringRedisSerializer就可以了，如果需要保存对象为json的话推荐使用JacksonJsonRedisSerializer，它不仅可以将对象序列化，还可以将对象转换为json字符串并保存到redis中，但需要和jackson配合一起使用。
简单的redis操作
代码示例如下，使用redis进行set和get操作。
MyUserRepository.java

Java代码

@Repository

public class MyUserRepository {

//直接使用autowire就可以引用到配置文件中的redis-template

@Autowired

private RedisTemplate<String, MyUser> template;

private ValueOperations<String, MyUser> operations;

@PostConstruct

public void init() {

//这里设置value的序列化方式为JacksonJsonRedisSerializer

template.setValueSerializer(new JacksonJsonRedisSerializer<>(MyUser.class));

operations = template.opsForValue();

}

public void set(String key, MyUser value) {

operations.set(key, value);

}

public MyUser get(String key) {

return operations.get(key);

}

// model

public class MyUser {

private String username;

private int age;

// ... setter and getter

}

// 在Controller中调用

@Controller

public class MainController {

@Autowired

private MyUserRepository myUserRepository;

@RequestMapping(value = "/test", method = RequestMethod.GET)

public

@ResponseBody

ResponseEntity<?> test() throws Exception {

MyUser user = new MyUser("zhaozhiming", 100);

String key = "my:user:zhaozhiming";

myUserRepository.set(key, user);

MyUser myUser = myUserRepository.get(key);

log.debug(String.format("my user:%s", myUser));

String result = mapper.writeValueAsString(user);

return new ResponseEntity<>(result, HttpStatus.OK);

}

调用set方法后，可以在日志中看到get后的MyUser对象。
– my user:MyUser{age=100, username=’zhaozhiming’}
也可以在redis里面看到保存后的json字符串了。

一个工具类: RedisUtil 是用来缓存和去除数据的实例, 如果没必要, 请改成
private RedisTemplate<String, Object> redisTemplate;

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

Java代码

package com.pandy.framework.base.redis.utils;

/**

* Created by pandy on 16-5-3.

import org.apache.log4j.Logger;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.data.redis.core.ValueOperations;

import java.io.Serializable;

import java.util.Set;

import java.util.concurrent.TimeUnit;

/**

* redis cache 工具类

public final class RedisUtil {

private Logger logger = Logger.getLogger(RedisUtil.class);

private RedisTemplate<Serializable, Object> redisTemplate;

/**

* 批量删除对应的value

* @param keys

public void remove(final String... keys) {

for (String key : keys) {

remove(key);

}

/**

* 批量删除key

* @param pattern

public void removePattern(final String pattern) {

Set<Serializable> keys = redisTemplate.keys(pattern);

if (keys.size() > 0)

redisTemplate.delete(keys);

}

/**

* 删除对应的value

* @param key

public void remove(final String key) {

if (exists(key)) {

redisTemplate.delete(key);

}

/**

* 判断缓存中是否有对应的value

* @param key

* @return

public boolean exists(final String key) {

return redisTemplate.hasKey(key);

}

/**

* 读取缓存

* @param key

* @return

public Object get(final String key) {

Object result = null;

ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();

result = operations.get(key);

return result;

}

public <T> T get(final String key, Class<T> t) {

Object result = null;

ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();

result = operations.get(key);

return (T)result;

}

/**

* 写入缓存

* @param key

* @param value

* @return

public boolean set(final String key, Object value) {

boolean result = false;

try {

ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();

operations.set(key, value);

result = true;

} catch (Exception e) {

e.printStackTrace();

}

return result;

}

/**

* 写入缓存

* @param key

* @param value

* @return

public boolean set(final String key, Object value, Long expireTime) {

boolean result = false;

try {

ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();

operations.set(key, value);

redisTemplate.expire(key, expireTime, TimeUnit.SECONDS);

result = true;

} catch (Exception e) {

e.printStackTrace();

}

return result;

}

public void setRedisTemplate(RedisTemplate<Serializable, Object> redisTemplate) {

this.redisTemplate = redisTemplate;

}

不静之心

使用Spring-data进行Redis操作

发表评论取消回复

访问信息

功能

近期评论

不静之心

使用Spring-data进行Redis操作

发表评论 取消回复

访问信息

功能

近期评论

发表评论取消回复