文档章节

JedisUtils,Jedis工具类

铂金小鸟
 铂金小鸟
发布于 2013/12/30 14:18
字数 911
阅读 746
收藏 12
点赞 0
评论 1

这两天折腾了下Redis,第一次用这玩意,参考网上的几个 Jedis工具类的例子,不过网上的几个比较复杂,啰嗦,大部分功能用不到。还是自己写的简单实用,特此记录。

 JedisUtil.java

package com.fants.redis;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public class JedisUtil {
	protected Logger log = LoggerFactory.getLogger(getClass());

	private static JedisPool jedisPool = null;
	
	/** 缓存生存时间 */
	private final static int expire = 60000;

	static {
		JedisPoolConfig config = new JedisPoolConfig();
		config.setMaxActive(JRedisPoolConfig.MAX_ACTIVE);
		config.setMaxIdle(JRedisPoolConfig.MAX_IDLE);
		config.setMaxWait(JRedisPoolConfig.MAX_WAIT);
		config.setTestOnBorrow(JRedisPoolConfig.TEST_ON_BORROW);
		config.setTestOnReturn(JRedisPoolConfig.TEST_ON_RETURN);
		// redis如果设置了密码:
		jedisPool = new JedisPool(config, JRedisPoolConfig.REDIS_IP,
				JRedisPoolConfig.REDIS_PORT, 10000,
				JRedisPoolConfig.REDIS_PASSWORD);
	}

	public static JedisPool getPool() {
		return jedisPool;
	}

	/**
	 * 从jedis连接池中获取获取jedis对象
	 */
	public static Jedis getJedis() {
		return jedisPool.getResource();
	}

	/**
	 * 回收jedis
	 */
	public static void returnJedis(Jedis jedis) {
		if(jedis!=null)
			jedisPool.returnResource(jedis);
	}

	/**
	 * 设置过期时间
	 */
	public static void expire(String key, int seconds) {
		if (seconds <= 0) {
			return;
		}
		Jedis jedis = getJedis();
		jedis.expire(key, seconds);
		returnJedis(jedis);
	}

	/**
	 * 设置默认过期时间
	 */
	public static void expire(String key) {
		expire(key, expire);
	}
	
	public static void set(String key,String value){
		if(isBlank(key)) return;
		Jedis jedis = getJedis();
		jedis.set(key, value);
		returnJedis(jedis);
	}
	
	public static void set(String key,Object value){
		if(isBlank(key)) return;
		Jedis jedis = getJedis();
		jedis.set(key.getBytes(), SerializeUtil.serialize(value));
		returnJedis(jedis);
	}
	
	public static void set(String key,int value){
		if(isBlank(key)) return;
		set(key, String.valueOf(value));
	}
	
	public static void set(String key,long value){
		if(isBlank(key)) return;
		set(key, String.valueOf(value));
	}
	
	public static void set(String key,float value){
		if(isBlank(key)) return;
		set(key, String.valueOf(value));
	}
	
	public static void set(String key,double value){
		if(isBlank(key)) return;
		set(key, String.valueOf(value));
	}
	
	public static Float getFloat(String key){
		if(isBlank(key)) return null;
		return Float.valueOf(getStr(key));
	}
	
	public static Double getDouble(String key){
		if(isBlank(key)) return null;
		return Double.valueOf(getStr(key));
	}
	
	public static Long getLong(String key){
		if(isBlank(key)) return null;
		return Long.valueOf(getStr(key));
	}
	
	public static Integer getInt(String key){
		if(isBlank(key)) return null;
		return Integer.valueOf(getStr(key));
	}
	
	public static String getStr(String key){
		if(isBlank(key)) return null;
		Jedis jedis = getJedis();
		String value = jedis.get(key);
		returnJedis(jedis);
		return value;
	}
	
	public static Object getObj(String key){
		if(isBlank(key)) return null;
		Jedis jedis = getJedis();
		byte[] bits = jedis.get(key.getBytes());
		Object obj = SerializeUtil.unserialize(bits);
		returnJedis(jedis);
		return obj;
	}
	
	public static boolean isBlank(String str){
		return str==null||"".equals(str.trim());
	}
}


JRedisPoolConfig.java

package com.fants.redis;

import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.util.Properties;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.jfinal.kit.PathKit;

public class JRedisPoolConfig {
	protected static Logger log = LoggerFactory.getLogger(JRedisPoolConfig.class);
	public static String REDIS_IP;
	public static int REDIS_PORT;
	public static String REDIS_PASSWORD;
	public static int MAX_ACTIVE;
	public static int MAX_IDLE;
	public static long MAX_WAIT;
	public static boolean TEST_ON_BORROW;
	public static boolean TEST_ON_RETURN;

	static {
		init();
	}

	public static void init() {
		try {
			String fullFile = PathKit.getWebRootPath() + File.separator + "WEB-INF" + File.separator + "redis.properties";
			File file = new File(fullFile);
			if(file.exists()){
				log.info("loading redis config from redis.properties.......");
				InputStream in = new FileInputStream(fullFile);
				Properties p = new Properties();
				p.load(in);
				REDIS_IP = p.getProperty("redis.ip");
				REDIS_PORT = Integer.parseInt(p.getProperty("redis.port"));
				REDIS_PASSWORD = p.getProperty("redis.password");
				MAX_ACTIVE = Integer.parseInt(p.getProperty("redis.pool.maxActive"));
				MAX_IDLE = Integer.parseInt(p.getProperty("redis.pool.maxIdle"));
				MAX_WAIT = Integer.parseInt(p.getProperty("redis.pool.maxWait"));
				TEST_ON_BORROW = Boolean.parseBoolean(p.getProperty("redis.pool.testOnBorrow"));
				TEST_ON_RETURN = Boolean.parseBoolean(p.getProperty("redis.pool.testOnReturn"));
				log.info("redis config load Completed。");
				in.close();
				in=null;
			}else{
				log.error("redis.properties is not found!");
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

SerializeUtil.java

package com.fants.redis;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;

public class SerializeUtil {
    /**
     * 序列化
     * 
     * @param object
     * @return
     */
    public static byte[] serialize(Object object) {
        ObjectOutputStream oos = null;
        ByteArrayOutputStream baos = null;
        try {
            // 序列化
            baos = new ByteArrayOutputStream();
            oos = new ObjectOutputStream(baos);
            oos.writeObject(object);
            byte[] bytes = baos.toByteArray();
            return bytes;
        } catch (Exception e) {
        	e.printStackTrace();
        }
        return null;
    }

    /**
     * 反序列化
     * 
     * @param bytes
     * @return
     */
    public static Object unserialize(byte[] bytes) {
        ByteArrayInputStream bais = null;
        try {
            // 反序列化
            bais = new ByteArrayInputStream(bytes);
            ObjectInputStream ois = new ObjectInputStream(bais);
            return ois.readObject();
        } catch (Exception e) {
        	e.printStackTrace();
        }
        return null;
    }
}


redis.properties

#\u63A7\u5236\u4E00\u4E2Apool\u53EF\u5206\u914D\u591A\u5C11\u4E2Ajedis\u5B9E\u4F8B\uFF0C\u901A\u8FC7pool.getResource()\u6765\u83B7\u53D6\uFF1B\u5982\u679C\u8D4B\u503C\u4E3A-1\uFF0C\u5219\u8868\u793A\u4E0D\u9650\u5236\uFF1B\u5982\u679Cpool\u5DF2\u7ECF\u5206\u914D\u4E86maxActive\u4E2Ajedis\u5B9E\u4F8B\uFF0C\u5219\u6B64\u65F6pool\u7684\u72B6\u6001\u5C31\u6210exhausted\u4E86\uFF0C\u5728JedisPoolConfig
redis.pool.maxActive=1024
#\u63A7\u5236\u4E00\u4E2Apool\u6700\u591A\u6709\u591A\u5C11\u4E2A\u72B6\u6001\u4E3Aidle\u7684jedis\u5B9E\u4F8B\uFF1B
redis.pool.maxIdle=200
#\u8868\u793A\u5F53borrow\u4E00\u4E2Ajedis\u5B9E\u4F8B\u65F6\uFF0C\u6700\u5927\u7684\u7B49\u5F85\u65F6\u95F4\uFF0C\u5982\u679C\u8D85\u8FC7\u7B49\u5F85\u65F6\u95F4\uFF0C\u5219\u76F4\u63A5\u629B\u51FAJedisConnectionException\uFF1B
redis.pool.maxWait=1000
#\u5728borrow\u4E00\u4E2Ajedis\u5B9E\u4F8B\u65F6\uFF0C\u662F\u5426\u63D0\u524D\u8FDB\u884Calidate\u64CD\u4F5C\uFF1B\u5982\u679C\u4E3Atrue\uFF0C\u5219\u5F97\u5230\u7684jedis\u5B9E\u4F8B\u5747\u662F\u53EF\u7528\u7684\uFF1B
redis.pool.testOnBorrow=true
#\u5728return\u7ED9pool\u65F6\uFF0C\u662F\u5426\u63D0\u524D\u8FDB\u884Cvalidate\u64CD\u4F5C\uFF1B
redis.pool.testOnReturn=true
#ip
redis.ip=localhost
#port
redis.port=6379
#password
redis.password=myredis


© 著作权归作者所有

共有 人打赏支持
铂金小鸟

铂金小鸟

粉丝 265
博文 11
码字总数 4041
作品 1
闵行
高级程序员
加载中

评论(1)

yangkf
yangkf
楼主,在高并发下,redis的线程池的配置怎么样设置呢?
Java实现Redis发布/订阅

今天经理让我实现一个Redis发布/订阅功能,用来记录审计信息。我查了一天,才弄出来。总结如下,大神勿喷。第二天我百度“JedisPubSub ”发现好多代码,后来测试了一下发现,百度关键词“Jed...

夜辰
2016/03/28
2.2K
2
布隆过滤器:Google Guava类库源码分析及基于Redis Bitmaps的重构

本文作者:伯乐在线 -fullstackyang 。未经作者许可,禁止转载! 欢迎加入伯乐在线专栏作者。 本文源地址:http://www.fullstackyang.com/archives/464.html,转发请注明该地址或伯乐在线地址...

伯乐在线
2017/12/30
0
0
Java实现Redis发布/订阅

今天经理让我实现一个Redis发布/订阅功能,用来记录审计信息。我查了一天,才弄出来。总结如下,大神勿喷。 客户端1订阅bar频道。格式:SUBSCRIBE name1 name2。成功订阅回复,分别对应订阅类...

问题达人
2016/03/29
175
0
redis通用工具类

public class RedisUtil { private static final Logger LOGGER = Logger.getLogger(RedisUtil.class); private static JedisPool pool = null; private static RedisUtil ru = new RedisUti......

glen_xu
2016/02/26
97
0
崛起于Springboot2.X之Jedis+Redis单机(15)

1、pom添加依赖 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency> <dependency><groupId>redis.clients</gr......

木九天
07/15
0
0
Redis笔记整理(二):Java API使用与Redis分布式集群环境搭建

[TOC] Redis Java API使用(一):单机版本Redis API使用 Redis的Java API通过Jedis来进行操作,因此首先需要Jedis的第三方库,因为使用的是Maven工程,所以先给出Jedis的依赖: 基本代码示例...

xpleaf
06/26
0
0
Spring集成Redis方案(spring-data-redis)(基于Jedis的单机模式)(待实践)

说明:请注意Spring Data Redis的版本以及Spring的版本!最新版本的Spring Data Redis已经去除Jedis的依赖包,需要自行引入,这个是个坑点。并且会与一些低版本的Spring有冲突,要看官方文档...

easonjim
2017/10/05
0
0
Jedis cluster集群初始化源码剖析

在项目中我们经常使用spring-data-redis来操作Redis,它封装了Jedis客户端来与Redis服务器进行各种命令操作。由于最近用到了Redis Cluster集群功能,这里就分析总结一下Jedis cluster集群初始...

九州暮云
2017/10/30
0
0
java Jedis使用示例

package com.wujintao.redis; import java.util.Date; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Set; import......

TreasureWe
2015/09/28
339
0
Redis 连接池配置及redis操作

redis连接池配置如下: [java] view plain copy [java] view plain copy package com.ecshipper_manager.redis; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool;......

杀神之疯子
2017/06/02
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

实现异步有哪些方法

有哪些方法可以实现异步呢? 方式一:java 线程池 示例: @Test public final void test_ThreadPool() throws InterruptedException { ScheduledThreadPoolExecutor scheduledThre......

黄威
今天
0
0
linux服务器修改mtu值优化cpu

一、jumbo frames 相关 1、什么是jumbo frames Jumbo frames 是指比标准Ethernet Frames长的frame,即比1518/1522 bit大的frames,Jumbo frame的大小是每个设备厂商规定的,不属于IEEE标准;...

六库科技
今天
0
0
牛客网刷题

1. 二维数组中的查找(难度:易) 题目描述 在一个二维数组中(每个一维数组的长度相同),每一行都按照从左到右递增的顺序排序,每一列都按照从上到下递增的顺序排序。请完成一个函数,输入...

大不了敲一辈子代码
今天
0
0
linux系统的任务计划、服务管理

linux任务计划cron 在linux下,有时候要在我们不在的时候执行一项命令,或启动一个脚本,可以使用任务计划cron功能。 任务计划要用crontab命令完成 选项: -u 指定某个用户,不加-u表示当前用...

黄昏残影
昨天
0
0
设计模式:单例模式

单例模式的定义是确保某个类在任何情况下都只有一个实例,并且需要提供一个全局的访问点供调用者访问该实例的一种模式。 实现以上模式基于以下必须遵守的两点: 1.构造方法私有化 2.提供一个...

人觉非常君
昨天
0
0
《Linux Perf Master》Edition 0.4 发布

在线阅读:https://riboseyim.gitbook.io/perf 在线阅读:https://www.gitbook.com/book/riboseyim/linux-perf-master/details 百度网盘【pdf、mobi、ePub】:https://pan.baidu.com/s/1C20T......

RiboseYim
昨天
1
0
conda 换源

https://mirrors.tuna.tsinghua.edu.cn/help/anaconda/ conda config --add channels https://mirrors.tuna.tsinghua.edu.cn/anaconda/pkgs/free/conda config --add channels https://mir......

阿豪boy
昨天
1
0
Confluence 6 安装补丁类文件

Atlassian 支持或者 Atlassian 缺陷修复小组可能针对有一些关键问题会提供补丁来解决这些问题,但是这些问题还没有放到下一个更新版本中。这些问题将会使用 Class 类文件同时在官方 Jira bug...

honeymose
昨天
0
0
非常实用的IDEA插件之总结

1、Alibaba Java Coding Guidelines 经过247天的持续研发,阿里巴巴于10月14日在杭州云栖大会上,正式发布众所期待的《阿里巴巴Java开发规约》扫描插件!该插件由阿里巴巴P3C项目组研发。P3C...

Gibbons
昨天
1
0
Tomcat介绍,安装jdk,安装tomcat,配置Tomcat监听80端口

Tomcat介绍 Tomcat是Apache软件基金会(Apache Software Foundation)的Jakarta项目中的一个核心项目,由Apache、Sun和其他一些公司及个人共同开发而成。 java程序写的网站用tomcat+jdk来运行...

TaoXu
昨天
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部