文档章节

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
私信 提问

暂无文章

基于阿里云物联网平台实现的简易出入监控

本文通过一个简单实例,主要介绍了如何使用树莓派快速接入阿里云iot platform,并实现了一个简易的监控人员出入并拍照上送钉钉群的场景 场景 在公司大门入口处布点树莓派和红外感应,实现出入...

阿里云官方博客
2分钟前
0
0
基于阿里云物联网平台,我们这样实现简易出入监控

本文通过一个简单实例,主要介绍了如何使用树莓派快速接入阿里云iot platform,并实现了一个简易的监控人员出入并拍照上送钉钉群的场景 场景 在公司大门入口处布点树莓派和红外感应,实现出入...

阿里云云栖社区
7分钟前
1
0
fedora linux for 龙芯查看实时输出的tomcat日志

软件源带的tomcat版本较低,所以建议从官网下载最新版本。 解压后,执行./startup.sh文件。 查看实时输出的tomcat日志,请使用命令tail -f /usr/share/tomcat/logs/catalina.out。 “/usr/sh...

gugudu
8分钟前
0
0
为什么MySQL数据库要用B+树存储索引?

要回答好这个问题,首先我们要弄懂什么是索引?索引常见的数据结构有哪些?这些数据结构有何优缺点?只有弄懂这些,再去比较,才会知道为啥要用B+树作为MySQL数据库的存储索引了。 一、索引是...

Lienson
10分钟前
0
0
Java重点基础:反射机制

一、什么是反射? Java反射说的是在运行状态中,对于任何一个类,我们都能够知道这个类有哪些方法和属性。对于任何一个对象,我们都能够对它的方法和属性进行调用。我们把这种动态获取对象信...

一个程序员的成长
11分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部