Redis学习记录(二)--使用Jedis连接
标签（空格分隔）： javaWEB
在Java环境中连接Redis首选Jedis,因为Jedis封装的特别好,所以连接对于开发者也就变得很简单了,本文主要讲述如何写出优雅的Jedis连接代码.
1.设计模式分析
对于Jedis,有一个连接池JedisPool,这个连接池管理着程序中的jedis示例,对于单机部署,每一次使用jedis都是去池中取出来连接池,然后再使用他获取我们想要的结果.是不是有点感觉像数据库连接池?那么一般形式代码如下:
public String get(final String key) {
Jedis jedis = jedisPool.getResource();
String result = jedis.get(key);
jedis.close();
return result;
}
然而这样写方法多的话,每一个都要如此重复获取,然后执行,然后关闭,返回结果,一套流程,就像模板一样,那么设计模式就可以考虑模板模式.
模板设计模式主要是将通用的逻辑都抽离出来,不通用的逻辑根据实现类的具体策略而执行不同的策略.因为JedisPool比较类似数据库连接池,因此我们可以参考Spring里的JdbcTemplate,里面有如下代码:
public <T> T execute(ConnectionCallback<T> action) throws DataAccessException {
Assert.notNull(action, "Callback object must not be null");
//获取连接
Connection con = DataSourceUtils.getConnection(getDataSource());
try {
Connection conToUse = con;
if (this.nativeJdbcExtractor != null) {
conToUse = this.nativeJdbcExtractor.getNativeConnection(con);
}
else {
// Create close-suppressing Connection proxy, also preparing returned Statements.
conToUse = createConnectionProxy(con);
}
//执行策略
return action.doInConnection(conToUse);
}
catch (SQLException ex) {
DataSourceUtils.releaseConnection(con, getDataSource());
con = null;
throw getExceptionTranslator().translate("ConnectionCallback", getSql(action), ex);
}
finally {
//关闭连接
DataSourceUtils.releaseConnection(con, getDataSource());
}
}
分析:
代码分为三部分,获取连接,执行策略,关闭释放连接.除了策略,其他都是模板,而策略是一个函数式接口,如下:
public interface ConnectionCallback<T> {
T doInConnection(Connection con) throws SQLException, DataAccessException;
}
那么具体策略就是实现该接口的实现类里面的策略了.这样就很好地做到模板和策略分离,还有一个好处就是函数式接口可以很好地配合java8语法,写出相当优雅的代码.
2.实现
2.1 函数式接口实现
首先参照Spring,实现自己的函数式接口:
比上面多了一个泛型E代表传入参数,这样做的话,就会使得该接口更加具有通用性.
/**
* 模仿Spring ConnectionCallback写的模板接口
* T为操作返回值 E为参数类型
* 配合java8使用,效果更佳
* @author Niu Li
* @date 2016/12/8
*/
public interface WorkCallback<T,E> {
/**
* 具体执行策略
* @param e 传入参数
* @return 结果
*/
T doWorkCallback(E e);
}
2.2 实现单机版Jedis
实现思路,首先在JedisClientSingle写一个私有的excute方法,用于实现函数式接口,定义不同策略,代码具体如下:
/**
* 单机版jedis(配置建议都放在依赖注入配置中)
* @author Niu Li
* @date 2016/12/8
*/
public class JedisClientSingle{
/**
* 连接池,建议使用其他工具注入进来
*/
private JedisPool jedisPool;
public String get(final String key) {
return excute(new WorkCallback<String, Jedis>() {
public String doWorkCallback(Jedis jedis) {
return jedis.get(key);
}
});
}
public String set(final String key, final String value) {
return excute(new WorkCallback<String, Jedis>() {
public String doWorkCallback(Jedis jedis) {
return jedis.set(key,value);
}
});
}
/**
* 模板方法,很适合提取公共操作
* @param workCallback 处理函数
* @param <T> 返回类型
* @return 结果
*/
private <T> T excute(WorkCallback<T, Jedis> workCallback) {
Jedis jedis=null;
try {
jedis = jedisPool.getResource();
return workCallback.doWorkCallback(jedis);
} catch (Exception e) {
e.printStackTrace();
}finally {
if (null !=jedis){
jedis.close();
}
}
return null;
}
}
对于jedisPool的注入的话,Spring中可以如下配置
<!-- 配置redis客户端单机版 -->
<bean id="jedispoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<property name="maxTotal" value="${redis.maxactive}"/>
<property name="maxIdle" value="${redis.maxidle}"/>
<property name="minIdle" value="${redis.minidle}"/>
<property name="maxWaitMillis" value="${redis.timeout}"/>
</bean>
<bean id="jedisPool" class="redis.clients.jedis.JedisPool" destroy-method="destroy" depends-on="jedispoolConfig">
<constructor-arg name="poolConfig" ref="jedispoolConfig"/>
<constructor-arg name="host" value="${redis.ip}"/>
<constructor-arg name="port" value="${redis.port}"/>
</bean>
2.3实现集群版
集群版就简单很多了,只能说Jedis封装的太好了
/**
* jedis集群
* @author Niu Li
* @date 2016/12/8
*/
public class JedisClientCluster {
/**
* 集群控制,建议使用其他工具注入进来
*/
private JedisCluster jedisCluster;
/**
* 其他的直接使用jedisCluster的方法即可
*/
public String get(final String key) {
return jedisCluster.get(key);
}
}
对于jedisCluster的注入,Spring配置如下:
<!-- 配置redis客户端集群版 -->
<!--<bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">
<constructor-arg>
<set>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.1.101"/>
<constructor-arg name="port" value="1001"/>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.1.101"/>
<constructor-arg name="port" value="1002"/>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.1.101"/>
<constructor-arg name="port" value="1003"/>
</bean>
</set>
</constructor-arg>
</bean>
这种实现是不是很优雅?
参考代码:
https://github.com/nl101531/JavaWEB 下Util-Demo
参考链接:
本文从该博客学习总结而得
https://muyinchen.github.io