Spring data redis的简单应用
package com.wanmei.redis.test.service;import java.util.Collection;import java.util.Set;/** * <pre> * @author xuepeng<br> * @date 2013年12月25日<br> * @Copyright wanmei.com [2004-2013]<br> * @Description redis 的服务接口 * </pre> */public interface RedisService {/** * <pre> * 通过key删除 * @param keys * @return 被删除的记录数 * </pre> */public long delete(String... keys);/** * <pre> * 通过keys删除 * @param keys * @return 被删除的记录数 * </pre> */public long delete(Collection<String> keys);/** * <pre> * @param key * @param value * @param activeTime 秒 * @return 添加key value 并且设置存活时间 * </pre> */public boolean set(byte[] key, byte[] value, long activeTime);/** * <pre> * @param key * @param value * @param activeTime 秒 * @return 添加key value 并且设置存活时间 * </pre> */public boolean set(String key, String value, long activeTime);/** * <pre> * @param key * @param value * @return 添加key value * </pre> */public boolean set(String key, String value);/** * <pre> * @param key * @param value * @return 添加key value * </pre> */public boolean set(byte[] key, byte[] value);/** * <pre> * @param key * @return 获得value * </pre> */public String get(String key);/** * <pre> * @param pattern * @return 通过正则匹配keys * </pre> */public Set<String> matchKeys(String pattern);/** * <pre> * @param key * @return 检查key是否已经存在 * </pre> */public boolean exists(String key);/** * <pre> * @return 清空所有数据 * </pre> */public boolean flushDB();}
?
?
package com.wanmei.redis.test.service.impl;import java.io.Serializable;import java.io.UnsupportedEncodingException;import java.util.ArrayList;import java.util.Collection;import java.util.Set;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.dao.DataAccessException;import org.springframework.data.redis.connection.RedisConnection;import org.springframework.data.redis.core.RedisCallback;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.stereotype.Service;import com.wanmei.redis.test.service.RedisService;/** * <pre> * @author xuepeng<br> * @date 2013年12月25日<br> * @Copyright wanmei.com [2004-2013]<br> * @Description Redis 服务实现类 * </pre> */@Service(value = "redisService")public class RedisServiceImpl implements RedisService {private static final String CHARSET = "UTF8";@Autowiredprivate RedisTemplate<String, Serializable> redisTemplate;public void setRedisTemplate(RedisTemplate<String, Serializable> redisTemplate) {this.redisTemplate = redisTemplate;}@Overridepublic boolean set(final byte[] key, final byte[] value,final long activeTime) {return redisTemplate.execute(new RedisCallback<Boolean>() {public Boolean doInRedis(RedisConnection connection)throws DataAccessException {boolean rs = true;connection.set(key, value);if (activeTime > 0) {rs = connection.expire(key, activeTime);}return rs;}});}@Overridepublic boolean set(String key, String value, long activeTime) {return this.set(key.getBytes(), value.getBytes(), activeTime);}@Overridepublic boolean set(String key, String value) {return this.set(key, value, 0L);}@Overridepublic boolean set(byte[] key, byte[] value) {return this.set(key, value, 0L);}@Overridepublic String get(final String key) {return redisTemplate.execute(new RedisCallback<String>() {public String doInRedis(RedisConnection connection)throws DataAccessException {try {byte[] value = connection.get(key.getBytes());return value == null ? "" : new String(value, CHARSET);} catch (UnsupportedEncodingException e) {e.printStackTrace();}return "";}});}@Overridepublic Set<String> matchKeys(String pattern) {return redisTemplate.keys(pattern);}@Overridepublic boolean exists(final String key) {return redisTemplate.execute(new RedisCallback<Boolean>() {public Boolean doInRedis(RedisConnection connection)throws DataAccessException {return connection.exists(key.getBytes());}});}@Overridepublic boolean flushDB() {return redisTemplate.execute(new RedisCallback<Boolean>() {public Boolean doInRedis(RedisConnection connection)throws DataAccessException {connection.flushDb();return true;}});}@Overridepublic long delete(final Collection<String> keys) {return redisTemplate.execute(new RedisCallback<Long>() {public Long doInRedis(RedisConnection connection)throws DataAccessException {long result = 0;for (String key : keys) {result = connection.del(key.getBytes());}return result;}});}@Overridepublic long delete(final String... keys) {Collection<String> cols = new ArrayList<String>();for (String key : keys) {cols.add(key);}return this.delete(cols);}}?
?
package com.wanmei.redis;import static org.junit.Assert.assertEquals;import org.junit.Before;import org.junit.Test;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;import com.alibaba.fastjson.JSON;import com.google.common.base.Strings;import com.wanmei.redis.test.bean.User;import com.wanmei.redis.test.service.RedisService;/** * <pre> * @author xuepeng<br> * @date 2013年12月25日<br> * @Copyright wanmei.com [2004-2013]<br> * @Description 单元测试类 * </pre> */public class UserServiceTest {private ApplicationContext app;private RedisService redisService;@Beforepublic void before() throws Exception {app = new ClassPathXmlApplicationContext("com/wanmei/redis/spring-ctx-application.xml");redisService = (RedisService) app.getBean("redisService");}@Testpublic void crud() {for (;;) {System.out.println(Strings.repeat("-", 50));// -------------- Create ---------------String address1 = Strings.repeat("上海", 50);User user = new User();user.setAddress(address1);user.setUid("u123456");String key = toJSONString(user);String value = key;long beforeSave = System.currentTimeMillis();redisService.set(key, value);System.out.println("save consumes : "+ (System.currentTimeMillis() - beforeSave));// ---------------Read ---------------long beforeRead = System.currentTimeMillis();String r1 = redisService.get(key);System.out.println("read consumes : "+ (System.currentTimeMillis() - beforeRead));user = parse(r1, User.class);System.out.println("address1=" + user.getAddress());assertEquals(address1, user.getAddress());// --------------Update ------------String address2 = "北京";user.setAddress(address2);final String key1 = toJSONString(user);String value1 = key1;redisService.set(key1, value1);String r2 = redisService.get(key1);user = parse(r2, User.class);System.out.println("address2Save=" + user.getAddress());assertEquals(address2, user.getAddress());// --------------Delete ------------long beforeDelete = System.currentTimeMillis();long rs = redisService.delete(key1);System.out.println("delete record's count : " + rs);System.out.println("delete consumes : "+ (System.currentTimeMillis() - beforeDelete));String r3 = redisService.get(key1);System.out.println("addressdel=" + r3);assertEquals("", r3);// -------------exist----------------user.setAddress("呵呵");user.setUid("哈哈哈");String lastKey = user.toString();redisService.set(lastKey, lastKey);boolean r4 = redisService.exists(lastKey);assertEquals(true, r4);// -------------flushDB----------------System.out.println("flushDB:" + redisService.flushDB());String r5 = redisService.get(lastKey);assertEquals("", r5);}}private static String toJSONString(Object t) {return JSON.toJSONString(t);}private static <T> T parse(String text, Class<T> clazz) {return JSON.parseObject(text, clazz);}}下面是Spring的XML配置：
? ?spring-ctx-application.xml
<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"xmlns:context="http://www.springframework.org/schema/context"xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:jee="http://www.springframework.org/schema/jee"xmlns:jms="http://www.springframework.org/schema/jms" xmlns:lang="http://www.springframework.org/schema/lang"xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:oxm="http://www.springframework.org/schema/oxm"xmlns:p="http://www.springframework.org/schema/p" xmlns:sec="http://www.springframework.org/schema/security"xmlns:task="http://www.springframework.org/schema/task" xmlns:tx="http://www.springframework.org/schema/tx"xmlns:util="http://www.springframework.org/schema/util" xmlns:cache="http://www.springframework.org/schema/cache"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsdhttp://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsdhttp://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsdhttp://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-3.0.xsdhttp://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.0.xsdhttp://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsdhttp://www.springframework.org/schema/lang http://www.springframework.org/schema/lang/spring-lang-3.0.xsdhttp://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsdhttp://www.springframework.org/schema/oxm http://www.springframework.org/schema/oxm/spring-oxm-3.0.xsdhttp://www.springframework.org/schema/security http://www.springframework.org/schema/security/spring-security-3.0.xsdhttp://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.0.xsdhttp://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsdhttp://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsdhttp://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache.xsd"><context:annotation-config /><context:component-scan base-package="com.wanmei.redis"></context:component-scan><context:property-placeholderlocation="classpath:com/wanmei/redis/test/config/redis.properties" /><!-- 对象池配置： --><bean id="jedisPoolConfig" value="${redis.pool.maxActive}" /><property name="maxIdle" value="${redis.pool.maxIdle}" /><property name="maxWait" value="${redis.pool.maxWait}" /></bean><!-- 工厂实现： --><bean id="jedisConnectionFactory"value="${redis.ip}" /><property name="port" value="${redis.port}" /><property name="poolConfig" ref="jedisPoolConfig" /></bean><!--模板类： --><bean id="redisTemplate" /></beans>?
? ? ?redis.properties
redis.pool.maxActive=1000redis.pool.maxIdle=100redis.pool.maxWait=500redis.ip=test-serverredis.port=6379
?
?