验证中...
开源中国 2018 年度最后一场技术盛会邀你来约~错过就要等明年啦!点此立即预约
语言: Java
分类: 常用工具包
最后更新于 2018-12-09 11:37
RedisUtils
原始数据 复制代码
package com.huawei.cache.redis;
import org.redisson.Config;
import org.redisson.Redisson;
import org.redisson.RedissonClient;
import org.redisson.core.RAtomicLong;
import org.redisson.core.RBucket;
import org.redisson.core.RCountDownLatch;
import org.redisson.core.RDeque;
import org.redisson.core.RList;
import org.redisson.core.RLock;
import org.redisson.core.RMap;
import org.redisson.core.RQueue;
import org.redisson.core.RSet;
import org.redisson.core.RSortedSet;
import org.redisson.core.RTopic;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/***
* Redis client的辅助工具类
* 用于连接Redis服务器 创建不同的Redis Server对应的客户端对象
* @author wangnian
* 博客地址:http://my.oschina.net/wangnian
*/
public class RedisUtils {
private static Logger logger= LoggerFactory.getLogger(RedisUtils.class);
private static RedisUtils redisUtils;
private RedisUtils(){}
/**
* 提供单例模式
* @return
*/
public static RedisUtils getInstance(){
if(redisUtils==null)
synchronized (RedisUtils.class) {
if(redisUtils==null) redisUtils=new RedisUtils();
}
return redisUtils;
}
/**
* 使用config创建Redisson
* Redisson是用于连接Redis Server的基础类
* @param config
* @return
*/
public RedissonClient getRedisson(Config config){
RedissonClient redisson=Redisson.create(config);
logger.info("成功连接Redis Server");
return redisson;
}
/**
* 使用ip地址和端口创建Redisson
* @param ip
* @param port
* @return
*/
public RedissonClient getRedisson(String ip,String port){
Config config=new Config();
config.useSingleServer().setAddress(ip+":"+port);
RedissonClient redisson=Redisson.create(config);
logger.info("成功连接Redis Server"+"\t"+"连接"+ip+":"+port+"服务器");
return redisson;
}
/**
* 关闭Redisson客户端连接
* @param redisson
*/
public void closeRedisson(RedissonClient redisson){
redisson.shutdown();
logger.info("成功关闭Redis Client连接");
}
/**
* 获取字符串对象
* @param redisson
* @param objectName
* @return
*/
public <T> RBucket<T> getRBucket(RedissonClient redisson,String objectName){
RBucket<T> bucket=redisson.getBucket(objectName);
return bucket;
}
/**
* 获取Map对象
* @param redisson
* @param objectName
* @return
*/
public <K,V> RMap<K, V> getRMap(RedissonClient redisson,String objectName){
RMap<K, V> map=redisson.getMap(objectName);
return map;
}
/**
* 获取有序集合
* @param redisson
* @param objectName
* @return
*/
public <V> RSortedSet<V> getRSortedSet(RedissonClient redisson,String objectName){
RSortedSet<V> sortedSet=redisson.getSortedSet(objectName);
return sortedSet;
}
/**
* 获取集合
* @param redisson
* @param objectName
* @return
*/
public <V> RSet<V> getRSet(RedissonClient redisson,String objectName){
RSet<V> rSet=redisson.getSet(objectName);
return rSet;
}
/**
* 获取列表
* @param redisson
* @param objectName
* @return
*/
public <V> RList<V> getRList(RedissonClient redisson,String objectName){
RList<V> rList=redisson.getList(objectName);
return rList;
}
/**
* 获取队列
* @param redisson
* @param objectName
* @return
*/
public <V> RQueue<V> getRQueue(RedissonClient redisson,String objectName){
RQueue<V> rQueue=redisson.getQueue(objectName);
return rQueue;
}
/**
* 获取双端队列
* @param redisson
* @param objectName
* @return
*/
public <V> RDeque<V> getRDeque(RedissonClient redisson,String objectName){
RDeque<V> rDeque=redisson.getDeque(objectName);
return rDeque;
}
/**
* 此方法不可用在Redisson 1.2 中
* 在1.2.2版本中 可用
* @param redisson
* @param objectName
* @return
*/
/**
public <V> RBlockingQueue<V> getRBlockingQueue(RedissonClient redisson,String objectName){
RBlockingQueue rb=redisson.getBlockingQueue(objectName);
return rb;
}*/
/**
* 获取锁
* @param redisson
* @param objectName
* @return
*/
public RLock getRLock(RedissonClient redisson,String objectName){
RLock rLock=redisson.getLock(objectName);
return rLock;
}
/**
* 获取原子数
* @param redisson
* @param objectName
* @return
*/
public RAtomicLong getRAtomicLong(RedissonClient redisson,String objectName){
RAtomicLong rAtomicLong=redisson.getAtomicLong(objectName);
return rAtomicLong;
}
/**
* 获取记数锁
* @param redisson
* @param objectName
* @return
*/
public RCountDownLatch getRCountDownLatch(RedissonClient redisson,String objectName){
RCountDownLatch rCountDownLatch=redisson.getCountDownLatch(objectName);
return rCountDownLatch;
}
/**
* 获取消息的Topic
* @param redisson
* @param objectName
* @return
*/
public <M> RTopic<M> getRTopic(RedissonClient redisson,String objectName){
RTopic<M> rTopic=redisson.getTopic(objectName);
return rTopic;
}
}

评论列表( 0 )

你可以在登录后,发表评论

搜索帮助