文档章节

redis使用

yabushan
 yabushan
发布于 2016/04/16 15:02
字数 505
阅读 27
收藏 0

精选30+云产品,助力企业轻松上云!>>>

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
私信 提问
加载中
请先登录后再评论。

暂无文章

App Builder 2020中文版

教程: 1、断开网络连接,下载解压,运行对应操作系统App Builder 2020安装包; 2、在弹出的窗口中勾选同意条款协议,点击【Next】; 3、创建桌面快捷方式,点击【Next】; 4、一切准备就绪,...

osc_62a7f5bj
4分钟前
11
0
蚂蚁金服轻量级类隔离框架 Maven 打包插件解析 | SOFAArk 源码解析

SOFAStack(Scalable Open Financial Architecture Stack)是蚂蚁金服自主研发的金融级云原生架构,包含了构建金融级云原生架构所需的各个组件,是在金融场景里锤炼出来的最佳实践。 本文为《...

SOFAStack
03/19
0
0
Java 高级 面试题 及 参考答案

一、面试题基础总结 1、 JVM结构原理、GC工作机制详解 答:具体参照:JVM结构、GC工作机制详解 ,说到GC,记住两点:1、GC是负责回收所有无任何引用对象的内存空间。 注意:垃圾回收回收的是无...

osc_np3y0rbq
5分钟前
6
0
面试准备季——MyBatis 面试专题(含答案)

写在前面:2020年面试必备的Java后端进阶面试题总结了一份复习指南在Github上,内容详细,图文并茂,有需要学习的朋友可以Star一下! GitHub地址:https://github.com/abel-max/Java-Study-...

osc_1ipdqsf2
6分钟前
8
0
Redis 高频面试题:10w+QPS 的 Redis 真的只是因为单线程和基于内存?

你以为 Redis 这么快仅仅因为单线程和基于内存? 那么你想得太少了,我个人认为 Redis 的快是基于多方面的:不但是单线程和内存,还有底层的数据结构设计,网络通信的设计,主从、哨兵和集群...

osc_qgfjs4a5
7分钟前
10
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部