文档章节

redis使用

yabushan
 yabushan
发布于 2016/04/16 15:02
字数 505
阅读 17
收藏 0
package yabushan.Redis;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;


import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.JedisShardInfo;
import redis.clients.jedis.ShardedJedis;
import redis.clients.jedis.ShardedJedisPool;

public class RedisClient {
	

	private Jedis jedis;// 非切片额客户端连接
	private JedisPool jedisPool;// 非切片连接池
	private ShardedJedis shardedJedis;// 切片额客户端连接
	private ShardedJedisPool shardedJedisPool=null;// 切片连接池
	private int MaxTotal = 300;
	private int maxIdle = 100;
	private long maxWait = 3000;
	private final int ONE_MONTH=2592000;
	private final int ONE_WEEK=7*24*60*60*1000;
	
	private static RedisClient redisClient;

	public static RedisClient getInstance() {
		if (redisClient == null) {
			redisClient = new RedisClient();
		}
		return redisClient;
	}

	public RedisClient() {
		initialPool();
		initialShardedPool();
		shardedJedis = shardedJedisPool.getResource();
		jedis = jedisPool.getResource();

	}

	/**
	 * 初始化非切片池
	 */
	private void initialPool() {
		// 池基本配置
		JedisPoolConfig config = new JedisPoolConfig();
		// config.setMaxActive(20);
		// config.setMaxIdle(5);
		// config.setMaxWait(1000l);
		// 设置最大连接数
		config.setMaxTotal(MaxTotal);
		// 设置最大空闲数
		config.setMaxIdle(maxIdle);
		// 设置超时时间
		config.setMaxWaitMillis(maxWait);
		config.setTestOnBorrow(false);

		jedisPool = new JedisPool(config, "127.0.0.1", 6379);
	}

	/**
	 * 初始化切片池
	 */
	private void initialShardedPool() {
		// 池基本配置
		JedisPoolConfig config = new JedisPoolConfig();
		// 设置最大连接数
		config.setMaxTotal(MaxTotal);
		// 设置最大空闲数
		config.setMaxIdle(maxIdle);
		// 设置超时时间
		config.setMaxWaitMillis(maxWait);
		config.setTestOnBorrow(false);
		// slave链接
		List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>();
		shards.add(new JedisShardInfo("127.0.0.1", 6379));

		// 构造池
		shardedJedisPool = new ShardedJedisPool(config, shards);
	}
	
	  public ShardedJedis getJedis(){
	        return this.shardedJedisPool.getResource();
	    }
	    
	    public void returnBrokenResource(ShardedJedis jedis){
	    	this.shardedJedisPool.returnBrokenResource(jedis);
	    }
	    
	    public void returnJedis(ShardedJedis jedis){
	        this.shardedJedisPool.returnResource(jedis);
	    }

	
	
	
	
	
	public void cloes() {
		jedisPool.returnResource(jedis);
		shardedJedisPool.returnResource(shardedJedis);
		//System.out.println("show");
	}

	public void setString(String phoneNum, String code) {
		jedis.set(phoneNum, code);
		jedis.expire(phoneNum, 600);

	}
	
	public  void setToken(String userId,String refleshtoken){
		Map<String, String> tokenMap=new HashMap<String, String>();
		tokenMap.put("retoken", refleshtoken);
		tokenMap.put("retime", String.valueOf(System.currentTimeMillis()));
		jedis.hmset(userId, tokenMap);
		jedis.expire(refleshtoken,ONE_WEEK);
		
	}
	
	//检查验证码是否过期
	public boolean outDate(String phoneNum){
		return jedis.exists(phoneNum);
	}

	public boolean isExist(String phoneNum, String code) {
		if (jedis.exists(phoneNum) && jedis.get(phoneNum).equals(code)) {
			jedis.del(phoneNum);
			
			return true;
		}
		return false;
	}
	
	
	public boolean setHashMap(String key,Map<String , String> map){
		
		try {
			
			jedis.hmset(key, map);
			jedis.expire(key, ONE_MONTH);
			return true;
		} catch (Exception e) {
			
			return false;
		}
	
	}
	
	public Map<String, String> hget(String key){
		
		Map<String, String> map=new HashMap<String, String>();
		try {
		map=jedis.hgetAll(key);
		} catch (Exception e) {
			map=null;
		}
		
		return map;
	}
	
	public boolean Hset(String key,String field,String value){
		
		boolean result=false;
		try {
			jedis.hset(key, field, value);
			
			result= true;
			
		} catch (Exception e) {
			
			
		}
		
		return result;
	}
	
	
	
	
	public List<Map<String, String>> gethashMaplist(Map<String, String> map){
		List<String> keyList=new ArrayList<String>();
		for(String key:map.keySet()){
			keyList.add(key);
		}
		List<Map<String, String>> maps=new ArrayList<Map<String,String>>();
		for(String keyString:keyList){
			Map<String, String> mpaMap=new HashMap<String, String>();
		mpaMap=	jedis.hgetAll(keyString);
		maps.add(mpaMap);
		}
		
		return maps;
	}
	
	
	public boolean deleteSuccssCheackShop(String key,String filed){
		boolean result=true;
		try {
			jedis.del(filed);//此处的filed为shopId
			jedis.hdel(key, filed);
			
		} catch (Exception e) {
			
			result=false;
		}
		
		return result;
	}
	
}


© 著作权归作者所有

共有 人打赏支持
yabushan
粉丝 1
博文 38
码字总数 34355
作品 0

暂无文章

困扰当前数据中心管理的三大难题

导读 当企业发展到一定程度,或者之前的机房不能满足现在的数据中心使用时,企业会对数据中心进行迁移。那么在数据中心进行迁移的时候会遇到哪些风险呢?针对这些风险我们应该做出怎样的措施来...

问题终结者
2分钟前
0
0
设计模式:工厂方法模式(工厂模式)

工厂方法模式才是真正的工厂模式,前面讲到的静态工厂模式实际上不能说是一种真正意义上的设计模式,只是一种变成习惯。 工厂方法的类图: 这里面涉及到四个种类: 1、抽象产品: Product 2、...

京一
18分钟前
0
0
区块链和数据库,技术到底有何区别?

关于数据库和区块链,总会有很多的困惑。区块链其实是一种数据库,因为他是数字账本,并且在区块的数据结构上存储信息。数据库中存储信息的结构被称为表格。但是,区块链是数据库,数据库可不...

HiBlock
26分钟前
0
0
react native 开发碰到的问题

react-navigation v2 问题 问题: static navigationOptions = ({navigation, navigationOptions}) => ({ headerTitle: ( <Text style={{color:"#fff"}}>我的</Text> ), headerRight: ( <View......

罗培海
33分钟前
0
0
Mac Docker安装流程

久仰Docker大名已久,于是今天趁着有空,尝试了一下Docker 先是从docker的官网上下载下来mac版本的docker安装包,安装很简易,就直接拖图标就好了。 https://www.docker.com/products/docker...

writeademo
41分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部