首页 > 代码库 > spring中集成使用jedis(2)
spring中集成使用jedis(2)
本文主要就spring注入的连接池使用问题,做简要说明。
使用过JedisPool的同学会发现,通过JedisPool获取资源,在使用完毕后,需要显式的将资源放回连接池中,
如下:
JedisPool jedisPool; Jedis jedis = jedisPool.getResource(); //操作 jedisPool.returnResource(jedis);
如果未显示的回收资源,则在连接池中资源使用完毕后,系统会出现阻塞。
因为如果使用连接池,就相当于将客户端连接托管给池,而池中资源又是事先设定,及有限资源,
那么在资源都被占用,且无人回收时,就会出现一直阻塞等待资源。
但是在每个操作后都显示的调用资源回收,又显得代码臃肿,此处建议考虑通过动态代理实现,及在每次操作前
通过代理获取资源,操作后再将资源回收。代码设计如下:
public class RedisService implements IMemCached { /** * 连接池 */ @Getter @Setter private JedisPool jedisPool; @Getter @Setter private Jedis jedis; /** * * @Title: initJedis * @Description: 从连接池获取连接 */ public void initJedis(){ this.jedis = jedisPool.getResource(); } /** * * @Title: returnJedis * @Description: 将连接放回连接池 */ public void returnJedis(){ jedisPool.returnResource(jedis); } @Override public boolean setValue(String key, Object value) throws MemcachedOpException { return OK.equals(jedis.set(key, null == value ? StringUtils.EMPTY : value.toString())); } @Override public boolean setValue(String key, Object value, int expTime) throws MemcachedOpException { return OK.equals(jedis.setex(key,expTime, null == value ? StringUtils.EMPTY : value.toString())); } @Override public Object getValue(String key) throws MemcachedOpException { return jedis.get(key); } @Override public Object getValue(String key, long timeout) throws MemcachedOpException { return getValue(key); } public List<String> getValue(String... keys) throws MemcachedOpException { return jedis.mget(keys); } /** * * @Title: sadd * @Description: 添加一个或者多个元素到集合(set)里 * @param key * @param members * @return */ public boolean sadd(final String key,String... members) throws MemcachedOpException{ return 1==jedis.sadd(key, members); } /** * * @Title: sRandomMember * @Description: 从集合里面随机获取一个值 * @param key * @return */ public String sRandomMember(final String key) throws MemcachedOpException{ return jedis.srandmember(key); } @Override public IMemCached getProxy() { return new ProxyHandler().bind(this); } @Override public void flush() throws MemcachedFlushException { jedis.flushDB(); } } /** * 动态代理类 用于解决jedis需手工放回连接池的问题 * @author guozb * */ class ProxyHandler implements InvocationHandler{ private RedisService redis; /** * * @Title: bind * @Description: 绑定代理对象 * @param imem * @return */ public IMemCached bind(RedisService imem){ this.redis = (RedisService) imem; return (IMemCached)Proxy.newProxyInstance(RedisService.class.getClassLoader(), RedisService.class.getInterfaces(), this); } @Override public Object invoke(Object arg0, Method arg1, Object[] arg2) throws Throwable { //从连接池获取资源 redis.initJedis(); Object obj = arg1.invoke(redis, arg2); //将资源放回连接池 redis.returnJedis(); return obj; } }
这样在使用时,通过调用getProxy()进行具体操作即可。
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。