spring data redis 高级篇list的相关用法

lovefef

2013-03-22

oyhk 学习笔记

最近算是对redis研究了一下,为什么会用到redis,由于公司这次要做一个队列的缓存系统,基于这个项目要求,我选择了redis

这次具体对redis list的数据结构进行了简单的操作...

这次依然使用spring data redis去操作redis..个人喜欢啊,我真心喜欢spring,我选择用它...

至于一些简单的操作,我上次写了一篇文章:spring 结合 Redis 例子,简单入门例子,至于怎么安装redis这些,大家自己去查查怎么安装吧.安装方法也非常简单官网上也有..现在对于想研究redis更深入的朋友们,我推荐大家看这本书http://www.redisbook.com/en/latest/..我自己认为真的非常不错...

这次的代码是基于原来的基础上,去完善

下面是对于RedisService的简单测试用例

package com.xiangrikui.iaskservice.controller;

import java.util.List;

import org.junit.Assert;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.xiangrikui.iaskservice.common.redis.RedisService;

/**
 * 简单的测试用例
 * 
 * @author oyhk
 * 
 */
public class TestRedis {
	ApplicationContext app = new ClassPathXmlApplicationContext(new String[] { "classpath:spring-redis.xml" });
	// 这里已经配置好,属于一个redis的服务接口
	RedisService redisService = (RedisService) app.getBean("redisService");

	/**
	 * 往list1中添加三条记录
	 */
	@Test
	public void lpush() {
		long result = redisService.lpush("list1", new String[] { "list1.1", "list1.2", "list1.3" });
		System.out.println(result);
		// 这里是junit的断言,简单的测试用例,如果不抛出异常,证明添加数据到列表成功
	}

	/**
	 * 查看从0开始到10的位置的数据
	 */
	@Test
	public void lrange() {
		Listresults = redisService.lrange("list2", 0, 10);
		System.out.println(results);
		Assert.assertNotNull(results);
	}

	/**
	 * 从左边的开始元素出队列
	 */
	@Test
	public void lpop() {
		String result = redisService.lpop("list1");
		System.out.println(result);
		Assert.assertNotNull(result);
	}

	/**
	 * 从右边的开始元素出队列
	 */
	@Test
	public void rpop() {
		String result = redisService.rpop("list1");
		System.out.println(result);
		Assert.assertNotNull(result);
	}

	/**
	 * 指定的列表中,指定的位置元素修改值
	 */
	@Test
	public void lset() {
		String result = redisService.lset("list1", 1, "list1.3");
		System.out.println(result);
		Assert.assertEquals("OK", result);
	}

	/**
	 * 删除指定列表中1个值为list1.3的元素
	 */
	@Test
	public void lrem() {
		long result = redisService.lrem("list1", 1, "list1.3");
		System.out.println(result);
		Assert.assertEquals(1L, result);
	}

	/**
	 * 从指定的列表右边出队,添加到目的列表中 -->>注意:这个方法必须源list有数据,那么目的list你可以随便起个名
	 * 
	 */
	@Test
	public void rpoppush() {
		String result = redisService.rpoppush("list1", "list2");
		System.out.println(result);
		Assert.assertNotNull(result);
	}
}

服务接口类RedisService

package com.xiangrikui.iaskservice.common.redis;

import java.util.List;
import java.util.Set;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;

import redis.clients.jedis.Jedis;

/**
 * 封装redis 缓存服务器服务接口
 * 
 * @author hk
 * 
 *         2012-12-16 上午3:09:18
 */
public class RedisService {

	/**
	 * 从指定的列表右边出队,添加到目的列表中
	 * 
	 * @param srckey
	 *            源列表
	 * @param dstkey
	 *            　目的列表
	 * @return
	 */
	public String rpoppush(String srckey, String dstkey) {
		return this.getJedis().rpoplpush(srckey, dstkey);
	}

	/**
	 * 获取指定列表的范围数据
	 * 
	 * @param key
	 *            　列表名
	 * @param start
	 *            　开始位置
	 * @param end
	 *            　结束位置
	 * @return
	 */
	public Listlrange(String key, int start, int end) {
		return this.getJedis().lrange(key, start, end);
	}

	/**
	 * 从队列的左边取出一条数据
	 * 
	 * @param key
	 *            　列表名
	 * @return
	 */
	public String lpop(String key) {
		return this.getJedis().lpop(key);
	}

	/**
	 * 从队列的右边取出一条数据
	 * 
	 * @param key
	 *            列表名
	 * @return
	 */
	public String rpop(String key) {
		return this.getJedis().rpop(key);
	}

	/**
	 * 把一个值添加到对应列表中
	 * 
	 * @param key
	 *            列表名
	 * @param index
	 *            　添加的位置
	 * @param value
	 *            　数据
	 * @return
	 */
	public String lset(String key, long index, String value) {
		return this.getJedis().lset(key, index, value);
	}

	/**
	 * 把所有数据添加到一个列表中
	 * 
	 * @param key
	 *            列表名
	 * @param values
	 *            　数据
	 * @return
	 */
	public long lpush(String key, String... values) {
		return this.getJedis().lpush(key, values);
	}

	/**
	 * 把所有数据添加到一个列表中,并且设置列表的存活时间
	 * 
	 * @param key
	 *            列表名
	 * @param values
	 *            数据
	 * @param liveTime
	 *            存活时间--单位(秒)
	 * @return
	 */
	public long lpush(String key, String[] values, int liveTime) {
		long result = this.getJedis().lpush(key, values);
		this.getJedis().expire(key, liveTime);
		return result;
	}

	/**
	 * 删除列表中对应值的元素
	 * 
	 * @param key
	 *            列表名
	 * @param count
	 *            删除多少个相同的元素
	 * @param value
	 *            数据
	 * @return
	 */
	public long lrem(String key, long count, String value) {
		return this.getJedis().lrem(key, count, value);
	}

	/**
	 * 返回指定列表范围内的元素
	 * 
	 * @param key
	 *            列表名
	 * @param start
	 *            开始位置
	 * @param end
	 *            结束位置
	 * @return
	 */
	public List lrange(String key, long start, long end) {
		return this.getJedis().lrange(key, start, end);
	}

	/**
	 * 通过key删除（字节）
	 * 
	 * @param key
	 */
	public void del(byte[] key) {
		this.getJedis().del(key);
	}

	/**
	 * 通过key删除
	 * 
	 * @param key
	 */
	public void del(String key) {
		this.getJedis().del(key);
	}

	/**
	 * 添加key value 并且设置存活时间(byte)
	 * 
	 * @param key
	 * @param value
	 * @param liveTime
	 *            　单位(秒)
	 */
	public void set(byte[] key, byte[] value, int liveTime) {
		this.set(key, value);
		this.getJedis().expire(key, liveTime);
	}

	/**
	 * 添加key value 并且设置存活时间
	 * 
	 * @param key
	 * @param value
	 * @param liveTime
	 *            　单位(秒)
	 */
	public void set(String key, String value, int liveTime) {
		this.set(key, value);
		this.getJedis().expire(key, liveTime);
	}

	/**
	 * 添加key value
	 * 
	 * @param key
	 * @param value
	 */
	public void set(String key, String value) {
		this.getJedis().set(key, value);
	}

	/**
	 * 添加key value (字节)(序列化)
	 * 
	 * @param key
	 * @param value
	 */
	public void set(byte[] key, byte[] value) {
		this.getJedis().set(key, value);
	}

	/**
	 * 获取redis value (String)
	 * 
	 * @param key
	 * @return
	 */
	public String get(String key) {
		String value = this.getJedis().get(key);
		return value;
	}

	/**
	 * 获取redis value (byte [] )(反序列化)
	 * 
	 * @param key
	 * @return
	 */
	public byte[] get(byte[] key) {
		return this.getJedis().get(key);
	}

	/**
	 * 通过正则匹配keys
	 * 
	 * @param pattern
	 * @return
	 */
	public Setkeys(String pattern) {
		return this.getJedis().keys(pattern);
	}

	/**
	 * 检查key是否已经存在
	 * 
	 * @param key
	 * @return 存在返回true
	 */
	public boolean exists(String key) {
		return this.getJedis().exists(key);
	}

	/**
	 * 清空redis 所有数据
	 * 
	 * @return
	 */
	public String flushDB() {
		return this.getJedis().flushDB();
	}

	/**
	 * 查看redis里有多少数据
	 */
	public long dbSize() {
		return this.getJedis().dbSize();
	}

	/**
	 * 检查是否连接成功
	 * 
	 * @return
	 */
	public String ping() {
		return this.getJedis().ping();
	}

	/**
	 * 通过多个key一次返回多个值
	 * 
	 * @param keys
	 */
	public Listmget(String... keys) {
		return this.getJedis().mget(keys);
	}

	/**
	 * 一次添加多个key value到redis中
	 * 
	 * @param keysvalues
	 */
	public void mset(String... keysvalues) {
		this.getJedis().mset(keysvalues);
	}

	/**
	 * 获取一个jedis 客户端
	 * 
	 * @return
	 */
	private Jedis getJedis() {
		if (jedis == null) {
			return jedisConnectionFactory.getShardInfo().createResource();
		}
		return jedis;
	}

	private RedisService() {

	}

	// 操作redis客户端
	private static Jedis jedis;
	@Autowired
	private JedisConnectionFactory jedisConnectionFactory;
}

把这个类复盖上篇文章的类,就可以直接使用...

大家多多交流

本文章来自：http://blog.mkfree.com/posts/5147c478975a24f6a830e53d

http://blog.mkfree.com/posts/5147c478975a24f6a830e53d

redis list