spring data redis 小例子

import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.logging.Logger;

import javax.annotation.Resource;

import org.apache.commons.lang.StringUtils;
import org.springframework.data.redis.core.BulkMapper;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.data.redis.core.query.SortQuery;
import org.springframework.data.redis.core.query.SortQueryBuilder;
import org.springframework.data.redis.hash.DecoratingStringHashMapper;
import org.springframework.data.redis.hash.HashMapper;
import org.springframework.data.redis.hash.JacksonHashMapper;
import org.springframework.data.redis.support.atomic.RedisAtomicLong;
import org.springframework.data.redis.support.collections.DefaultRedisList;
import org.springframework.data.redis.support.collections.DefaultRedisMap;
import org.springframework.data.redis.support.collections.DefaultRedisSet;
import org.springframework.data.redis.support.collections.RedisList;
import org.springframework.data.redis.support.collections.RedisMap;
import org.springframework.data.redis.support.collections.RedisSet;
import org.springframework.stereotype.Component;

import com.demo.entity.Post;

 
 

/**
 * @author zhaoqilong
 * @version 创建时间：2012-3-27 下午1:52:51
 * @param <K>
 * @param <V>
 * 
 */
@Component
public class RedisBasic<T> {

	@Resource
	private  StringRedisTemplate template;
	//string 操作
	private   ValueOperations<String, String> valueOps;
	 
	
	private  Class<T> entityClass;
  
 	private final HashMapper<T, String, String> entityMapper = new DecoratingStringHashMapper<T>(new JacksonHashMapper<T>((Class<T>) entityClass));
	 
	public RedisBasic(){
		 entityClass = (Class<T>) ((ParameterizedType) getClass().getGenericSuperclass()).getActualTypeArguments()[0];
	}
	 
	/**
	 * 查询数据根据用户编号
	 * @param key
	 * @return
	 */
	public List<T> findByUid(String key) {
		// test-user-1中数据 数据结构为key=test-user-1 value=pid (为*) ；#代表是查询 test-user-1 的value  test-map-*->uid代表  test-map-*map下的key为uid的值
		SortQuery<String> query = SortQueryBuilder.sort("test-user-1").noSort().get("#").get("test-map-*->uid").get("test-map-*->content").build();
		BulkMapper<T, String> hm = new BulkMapper<T, String>() {
			public T mapBulk(List<String> bulk) {
				Map<String, String> map = new LinkedHashMap<String, String>();
				Iterator<String> iterator = bulk.iterator();
				String pid=iterator.next();
				map.put("uid",iterator.next() );
				map.put("content",iterator.next() );
				return entityMapper.fromHash(map);//转型 将map转换成实体
			}
		};
		System.out.println(redisMap("test-map-1").values()+"======================");
		System.out.println(template.sort(query));
		 System.out.println( template.sort(query,hm));
		return  template.sort(query,hm);
	}
	/**
	 * 查询所有用户添加数据
	 * @param key
	 * @return
	 */
	public List<T> findByList() {
		// test-list中数据 数据结构为key=test-list value=pid (为*) ； test-map-*->uid  test-map-*->uid map下的key为uid的值
		SortQuery<String> query = SortQueryBuilder.sort("test-list").noSort().get("test-map-*->uid").get("test-map-*->content").build();
		BulkMapper<T, String> hm = new BulkMapper<T, String>() {
			public T mapBulk(List<String> bulk) {
				Map<String, String> map = new LinkedHashMap<String, String>();
				Iterator<String> iterator = bulk.iterator();
//				String pid=iterator.next();
				map.put("uid",iterator.next() );
				map.put("content",iterator.next() );
				return entityMapper.fromHash(map);//转型 将map转换成实体
			}
		};
		System.out.println(redisMap("test-map-1").values()+"=====================");//key为test-map-1 的 数据
		System.out.println(template.sort(query));
		System.out.println( template.sort(query,hm));
		return template.sort(query,hm);
	}
	/**
	 * 添加数据
	 * @param uid
	 * @param post
	 */
	public void post(String uid, Post post) {
//		String uid = findKey(username);
//		post.setUid(uid);
		// add post将entity转换成HASH
		String pid = String.valueOf(incrementAndGet("test"));
		redisMap("test-map-"+pid).putAll(entityMapper.toHash((T) post));
		redisList("test-user-"+uid).addFirst(pid);//操作用户Id保存操作的对象
		redisList("test-list").addFirst(pid);//保存所有的文章对象
	}
 
	
	


 
	/**
	 * 查找String key
	 * @param key
	 * @return
	 */
	public String findKey(String key) {
		return valueOps().get(key);
	}
	
	public void addListOne(String key,String value){
		redisList(key).addFirst(value);
	}
	/**
	 * 判断key是否存在
	 * @param key
	 * @return
	 */
	public boolean hasKey(String key) {
		return template.hasKey(key);
	}
	/**
	 * 获取自增索引
	 * @param key
	 * @return
	 */
	public String  incrementAndGet(String key){
		if(StringUtils.isNotEmpty(key)){
			RedisAtomicLong entityIdCounter=new RedisAtomicLong(key, template.getConnectionFactory());
			return String.valueOf(entityIdCounter.incrementAndGet());
		}else 
			return "";
		
	}
	/**
	 * 获取String操作项
	 * @return
	 */
	private ValueOperations<String, String> valueOps(){
		if(valueOps!=null){
			valueOps=template.opsForValue();
		}
		return valueOps;
	}
	/**
	 * 获取Set操作项
	 * @return
	 */
	private RedisSet<String> redisSet(String key) {
		return new DefaultRedisSet<String>(key, template);
	}
	/**
	 * 获取MAP操作项
	 * @return
	 */
	private RedisMap<String, String> redisMap(String key) {
		return new DefaultRedisMap<String, String>(key, template);
	}
	/**
	 * 获取List操作项
	 * @return
	 */
	private RedisList<String> redisList(String key) {
		return new DefaultRedisList<String>(key, template);
	}
	

配置文件

	<context:annotation-config />
		<bean id="connectionFactory" 
		class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"
		p:host-name="${redis.host}" 
		p:port="${redis.port}" 
		p:password="${redis.pass}"/>
		
    <context:component-scan base-package="com.demo"/>
    
	<bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate" 
		p:connection-factory-ref="connectionFactory"/>

maven

		<dependency>
			<groupId>org.codehaus.jackson</groupId>
			<artifactId>jackson-core-lgpl</artifactId>
			<version>1.6.4</version>
		</dependency>
		<dependency>
			<groupId>org.codehaus.jackson</groupId>
			<artifactId>jackson-mapper-lgpl</artifactId>
			<version>1.6.4</version>
		</dependency>
		<dependency>
			<groupId>org.codehaus.jackson</groupId>
			<artifactId>jackson-xc</artifactId>
			<version>1.6.4</version>
		</dependency>
		<dependency>
			<groupId>org.springframework.data</groupId>
			<artifactId>spring-data-redis</artifactId>
			<version>1.0.0.RELEASE</version>
		</dependency>

本人只做测试

如需demo可以下载springsource 下的demo 为方便 已上传到附件