Java操作redis

Redis作为服务器缓存，用处比较多。本文使用java操作redis，对操作进行简单的封装，并介绍如何将其集成到spring中，最后介绍redis分页查询。

首先定义操作接口，为redis的单机操作和集群操作提供标准。

public interface JedisClient
{
void set(String key, String value);

String get(String key);

void hset(String hkey, String key, String value);

String hget(String hkey, String key);

long incr(String key);

void expire(String key, int seconds);

long ttl(String key);

long del(String key);

long hdel(String hkey, String key);

/**
* redis list操作
*
* @param name
* @param value
*/
long rpush(String key, String value);

long lpush(String key, String value);

String rpop(String key);

String lpop(String key);

long llen(String key);

List<String> lrange(String key, long start, long end);

long zadd(String key, double score, String value);

Set<String> zrange(String key, long start, long end);//递增

Set<String> zrevrange(String key, long start, long end);//递减
}

定义单机版实现类

public class JedisClientSingle implements JedisClient
{
// 注意，JedisPool这个类型已经在spring中注册过了。这种方式直根据类型来注入
@Autowired
private JedisPool jedisPool;

@Override
public void set(String key, String value)
{
Jedis jedis = jedisPool.getResource();
jedis.set(key, value);
jedis.close();
}

@Override
public String get(String key)
{
Jedis jedis = jedisPool.getResource();
String value = jedis.get(key);
jedis.close();
return value;
}

@Override
public void hset(String hkey, String key, String value)
{
Jedis jedis = jedisPool.getResource();
jedis.hset(hkey, key, value);
jedis.close();
}

@Override
public String hget(String hkey, String key)
{
Jedis jedis = jedisPool.getResource();
String value = jedis.hget(hkey, key);
jedis.close();
return value;
}

@Override
public long incr(String key)
{
Jedis jedis = jedisPool.getResource();
long value = jedis.incr(key);
jedis.close();
return value;
}

@Override
public void expire(String key, int seconds)
{
Jedis jedis = jedisPool.getResource();
jedis.expire(key, seconds);
jedis.close();
}

@Override
public long ttl(String key)
{
Jedis jedis = jedisPool.getResource();
long value = jedis.ttl(key);
jedis.close();
return value;
}

@Override
public long del(String key)
{
Jedis jedis = jedisPool.getResource();
long result = jedis.del(key);
jedis.close();
return result;
}

@Override
public long hdel(String hkey, String key)
{
Jedis jedis = jedisPool.getResource();
long result = jedis.hdel(hkey, key);
jedis.close();
return result;
}

@Override
public long rpush(String key, String value)
{
Jedis jedis = jedisPool.getResource();
long result = jedis.rpush(key, value);
jedis.close();
return result;
}

@Override
public long lpush(String key, String value)
{
Jedis jedis = jedisPool.getResource();
long result = jedis.lpush(key, value);
jedis.close();
return result;
}

@Override
public String rpop(String key)
{
Jedis jedis = jedisPool.getResource();
String result = jedis.rpop(key);
jedis.close();
return result;
}

@Override
public String lpop(String key)
{
Jedis jedis = jedisPool.getResource();
String result = jedis.lpop(key);
jedis.close();
return result;
}

@Override
public long llen(String key)
{
Jedis jedis = jedisPool.getResource();
long result = jedis.llen(key);
jedis.close();
return result;
}

@Override
public List<String> lrange(String key, long start, long end)
{
Jedis jedis = jedisPool.getResource();
List<String> result = jedis.lrange(key, start, end);
jedis.close();
return result;
}

@Override
public long zadd(String key, double score, String value)
{
Jedis jedis = jedisPool.getResource();
long result = jedis.zadd(key, score, value);
jedis.close();
return result;
}

@Override
public Set<String> zrange(String key, long start, long end)
{
Jedis jedis = jedisPool.getResource();
Set<String> result = jedis.zrange(key, start, end);
jedis.close();
return result;
}

@Override
public Set<String> zrevrange(String key, long start, long end)
{
Jedis jedis = jedisPool.getResource();
Set<String> result = jedis.zrevrange(key, start, end);
jedis.close();
return result;
}

}

如下是集群操作实现类

public class JedisClientCluster implements JedisClient
{
// 注意，jedisCluster这个类型已经在spring中注册过了。这种方式直接根据类型来注入,不需要进行关闭操作
@Autowired
private JedisCluster jedisCluster;

@Override
public void set(String key, String value)
{
jedisCluster.set(key, value);
}

@Override
public String get(String key)
{
return jedisCluster.get(key);
}

@Override
public void hset(String hkey, String key, String value)
{
jedisCluster.hset(hkey, key, value);
}

@Override
public String hget(String hkey, String key)
{
return jedisCluster.hget(hkey, key);
}

@Override
public long incr(String key)
{
return jedisCluster.incr(key);
}

@Override
public void expire(String key, int seconds)
{
jedisCluster.expire(key, seconds);
}

@Override
public long ttl(String key)
{
return jedisCluster.ttl(key);
}

@Override
public long del(String key)
{
return jedisCluster.del(key);
}

@Override
public long hdel(String hkey, String key)
{
return jedisCluster.hdel(hkey, key);
}

@Override
public long rpush(String key, String value)
{
return jedisCluster.rpush(key, value);
}

@Override
public long lpush(String key, String value)
{
return jedisCluster.lpush(key, value);
}

@Override
public String rpop(String key)
{
return jedisCluster.rpop(key);
}

@Override
public String lpop(String key)
{
return jedisCluster.lpop(key);
}

@Override
public long llen(String key)
{
return jedisCluster.llen(key);
}

@Override
public List<String> lrange(String key, long start, long end)
{
return jedisCluster.lrange(key, start, end);
}

@Override
public long zadd(String key, double score, String value)
{
return jedisCluster.zadd(key, score, value);
}

@Override
public Set<String> zrange(String key, long start, long end)
{
return jedisCluster.zrange(key, start, end);
}

@Override
public Set<String> zrevrange(String key, long start, long end)
{
return jedisCluster.zrange(key, start, end);
}

}

　　

jedis相关的bean在spring中的配置

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"
xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.0.xsd"> <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<!-- <property name="maxIdle" value="300" /> --> <!-- 最大能够保持idel状态的对象数 -->
<!-- <property name="maxTotal" value="60000" />  --><!-- 最大分配的对象数 -->
<!-- <property name="testOnBorrow" value="true" /> --> <!-- 当调用borrow Object方法时，是否进行有效性检查 -->
</bean>
<!-- jedis客户端单机版，开发的时候，都是用单机版 -->
<bean id="redisClientSingle" class="redis.clients.jedis.JedisPool">
<constructor-arg name="poolConfig" ref="jedisPoolConfig" />
<constructor-arg name="host" value="192.168.1.1"></constructor-arg>
<constructor-arg name="port" value="6379"></constructor-arg>
<constructor-arg name="timeout" value="2000" type="int"></constructor-arg>
<constructor-arg name="password" value="xxx"></constructor-arg>
</bean>

<bean id="jedisClientSingle" class="org.redis.impl.JedisClientSingle"></bean>

<!-- jedis客户端集群版,生产环境使用 -->
<!-- <bean id="redisClientCluster" class="redis.clients.jedis.JedisCluster">
<constructor-arg name="nodes"> <set> <bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.25.128"></constructor-arg> <constructor-arg
name="port" value="7001"></constructor-arg> </bean> <bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.25.128"></constructor-arg> <constructor-arg
name="port" value="7002"></constructor-arg> </bean> <bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.25.128"></constructor-arg> <constructor-arg
name="port" value="7003"></constructor-arg> </bean> <bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.25.128"></constructor-arg> <constructor-arg
name="port" value="7004"></constructor-arg> </bean> <bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.25.128"></constructor-arg> <constructor-arg
name="port" value="7005"></constructor-arg> </bean> <bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.25.128"></constructor-arg> <constructor-arg
name="port" value="7006"></constructor-arg> </bean> </set> </constructor-arg>
<constructor-arg name="poolConfig" ref="jedisPoolConfig"></constructor-arg>
</bean> <bean id="jedisClientCluster" class="org.redis.impl..JedisClientCluster"></bean> -->
</beans>

java中redis分页查询

package common.model;

import java.util.ArrayList;
import java.util.List;

public class PageRedis<A>
{
private int totalNum; // 总行数
private int totalPage; // 总页数
private int pageIndex; // 当前页数
private int pageSize; // 每页几行

private List<A> rows;

public PageRedis()
{

}

public int getTotalPage()
{
return totalPage;
}

public int getPageIndex()
{
return pageIndex;
}

public void setPageIndex(int pageIndex)
{
this.pageIndex = pageIndex;
}

public int getPageSize()
{
return pageSize;
}

public void setPageSize(int pageSize)
{
this.pageSize = pageSize;
}

public int getTotalNum()
{
return totalNum;
}

public void setTotalNum(int totalNum)
{
this.totalNum = totalNum;
}

// 设置总页数

public List<A> getRows()
{
return rows;
}

public void setRows(List<A> rows)
{
this.rows = rows;
}

public void setTotalPage()
{
// 如果总行数整除每页的行数
if (this.getTotalNum() % this.getPageSize() == 0)
{
this.totalPage = this.getTotalNum() / this.getPageSize();
}
else
{
this.totalPage = this.getTotalNum() / this.getPageSize() + 1;
}
}

public <T> List<T> getPage(List<T> list)
{
List<T> sub = new ArrayList<T>();

// 当前页的起始记录（非最后一页）
int start = (this.getPageIndex() - 1) * this.getPageSize();

// 当前页的截止记录（非最后一页）
int end = this.getPageIndex() * this.getPageSize();

// 最后一页
int endOfLast = (this.getPageIndex() - 1) * this.getPageSize() + this.getTotalNum() % this.getPageSize();

// 如果说，当前页数等于总页数 并且 总行数除以每页几行不能整除
if (this.getPageIndex() == this.getTotalPage() && this.getTotalNum() % this.getPageSize() != 0)
{
for (int i = start; i < endOfLast; i++)
{
if (i < list.size())
{
sub.add(list.get(i));
}
}
}
else
{
for (int i = start; i < end; i++)
{
if (i < list.size())
{
sub.add(list.get(i));
}
}
}

return sub;
}

public static void main(String[] args)
{
/*List<Integer> list = new LinkedList<Integer>();
list.add(1);
list.add(2);
list.add(3);
list.add(4);
list.add(5);

PageRedis page = new PageRedis();
page.setTotalNum(list.size());
page.setPageSize(4);
page.setPageIndex(3);
page.setTotalPage();
List<Integer> sub = page.getPage(list);
System.out.println(sub);*/

}
}

　　

注意，上文中有几点是个人认为比较麻烦的

1.spring集成含密码的redis

2.利用redis的list和sortset实现分页查询

有问题欢迎讨论