spring redis整合

zhk2369

spring-data-redis下载地址：
http://www.springsource.org/download/community?project=Spring%2520Data%2520Redis&version=1.0.1.RELEASE


//spring-redis.xml
<?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?><beans xmlns=&quot;http://www.springframework.org/schema/beans&quot;xmlns:xsi=&quot;http://www.w3.org/2001/XMLSchema-instance&quot; xmlns:aop=&quot;http://www.springframework.org/schema/aop&quot;xmlns:cache=&quot;http://www.springframework.org/schema/cache&quot;xmlns:context=&quot;http://www.springframework.org/schema/context&quot;xmlns:mvc=&quot;http://www.springframework.org/schema/mvc&quot; xmlns:oxm=&quot;http://www.springframework.org/schema/oxm&quot;xmlns:p=&quot;http://www.springframework.org/schema/p&quot; xmlns:util=&quot;http://www.springframework.org/schema/util&quot;xsi:schemaLocation=&quot;http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd     http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd    http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.1.xsd   http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.1.xsd&quot;><context:annotation-config /><context:component-scan base-package=&quot;com.abin.lee.spring.redis&quot;></context:component-scan><context:property-placeholder location=&quot;classpath:com/abin/lee/spring/redis/redis.properties&quot; /><!-- 对象池配置： --><beanid=&quot;jedisPoolConfig&quot;class=&quot;redis.clients.jedis.JedisPoolConfig&quot;><propertyname=&quot;maxActive&quot;value=&quot;${redis.pool.maxActive}&quot; /><propertyname=&quot;maxIdle&quot;value=&quot;${redis.pool.maxIdle}&quot; /><propertyname=&quot;maxWait&quot;value=&quot;${redis.pool.maxWait}&quot; /><propertyname=&quot;testOnBorrow&quot;value=&quot;${redis.pool.testOnBorrow}&quot; /></bean><!-- 工厂实现： --><beanid=&quot;jedisConnectionFactory&quot;class=&quot;org.springframework.data.redis.connection.jedis.JedisConnectionFactory&quot;><propertyname=&quot;hostName&quot;value=&quot;${redis.ip}&quot; /><propertyname=&quot;port&quot;value=&quot;${redis.port}&quot; /><propertyname=&quot;poolConfig&quot;ref=&quot;jedisPoolConfig&quot; /></bean><!--模板类： --><beanclass=&quot;org.springframework.data.redis.core.RedisTemplate&quot;p:connection-factory-ref=&quot;jedisConnectionFactory&quot; /></beans>





//User.java
package com.abin.lee.spring.redis.pojo;import java.io.Serializable;public class User implements Serializable {/*** */private static final long serialVersionUID = 2668307865623183776L;private String uid;private String address;public User() {super();}public User(String uid, String address) {super();this.uid = uid;this.address = address;}public String getUid() {return uid;}public void setUid(String uid) {this.uid = uid;}public String getAddress() {return address;}public void setAddress(String address) {this.address = address;}@Overridepublic String toString() {return &quot;User [uid=&quot; &#43; uid &#43; &quot;, address=&quot; &#43; address &#43; &quot;]&quot;;}@Overridepublic int hashCode() {final int prime = 31;int result = 1;result = prime * result &#43; ((address == null) ? 0 : address.hashCode());result = prime * result &#43; ((uid == null) ? 0 : uid.hashCode());return result;}@Overridepublic boolean equals(Object obj) {if (this == obj)return true;if (obj == null)return false;if (getClass() != obj.getClass())return false;User other = (User) obj;if (address == null) {if (other.address != null)return false;} else if (!address.equals(other.address))return false;if (uid == null) {if (other.uid != null)return false;} else if (!uid.equals(other.uid))return false;return true;}}





//UserDao.java
package com.abin.lee.spring.redis.dao;import com.abin.lee.spring.redis.pojo.User;public interface UserDao {/*** @param uid* @param address*/void save(User user);/*** @param uid* @return*/User read(String uid);/*** @param uid*/void delete(String uid);}




//UserDaoImpl.java
package com.abin.lee.spring.redis.dao.impl;import java.io.Serializable;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.Repository;import com.abin.lee.spring.redis.dao.UserDao;import com.abin.lee.spring.redis.pojo.User;@Repository(&quot;userDao&quot;)public class UserDaoImpl implements UserDao{@Autowiredprivate RedisTemplate<Serializable, Serializable> redisTemplate;@Overridepublic void save(final User user) {redisTemplate.execute(new RedisCallback<Object>() {@Overridepublic Object doInRedis(RedisConnection connection)throws DataAccessException {connection.set(redisTemplate.getStringSerializer().serialize(&quot;user.uid.&quot; &#43; user.getUid()),redisTemplate.getStringSerializer().serialize(user.getAddress()));return null;}});}@Overridepublic User read(final String uid) {return redisTemplate.execute(new RedisCallback<User>() {@Overridepublic User doInRedis(RedisConnection connection)throws DataAccessException {byte[] key = redisTemplate.getStringSerializer().serialize(&quot;user.uid.&quot; &#43; uid);if (connection.exists(key)) {byte[] value = connection.get(key);String address = redisTemplate.getStringSerializer().deserialize(value);User user = new User();user.setAddress(address);user.setUid(uid);return user;}return null;}});}@Overridepublic void delete(final String uid) {redisTemplate.execute(new RedisCallback<Object>() {public Object doInRedis(RedisConnection connection) {connection.del(redisTemplate.getStringSerializer().serialize(&quot;user.uid.&quot; &#43; uid));return null;}});}}

//UserDaoTest.java
package com.abin.lee.spring.redis.dao.test;import static org.junit.Assert.assertEquals;import static org.junit.Assert.assertNull;import org.junit.Before;import org.junit.Test;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;import com.abin.lee.spring.redis.dao.UserDao;import com.abin.lee.spring.redis.pojo.User;public class UserDaoTest {private ApplicationContext app;private UserDao userDao;@Beforepublic void before() throws Exception {app = new ClassPathXmlApplicationContext(&quot;com/abin/lee/spring/redis/spring-redis.xml&quot;);userDao = (UserDao) app.getBean(&quot;userDao&quot;);}@Testpublic void crud() {// -------------- Create ---------------String uid = &quot;u123456&quot;;String address1 = &quot;上海&quot;;User user = new User();user.setAddress(address1);user.setUid(uid);userDao.save(user);// ---------------Read ---------------user = userDao.read(uid);System.out.println(&quot;address1=&quot;&#43;user.getAddress());assertEquals(address1, user.getAddress());// --------------Update ------------String address2 = &quot;北京&quot;;user.setAddress(address2);userDao.save(user);user = userDao.read(uid);System.out.println(&quot;address2Save=&quot;&#43;user.getAddress());assertEquals(address2, user.getAddress());// --------------Delete ------------userDao.delete(uid);user = userDao.read(uid);System.out.println(&quot;addressdel=&quot;&#43;user.getAddress());assertNull(user);}}         版权声明：本文为博主原创文章，未经博主允许不得转载。