public interface JRedisService {
/**
*
* @Description （删除键）
* @param key
* @date 2017年12月26日
*/
public void deleteKey(String... key);
/**
*
* @Description （判断key是否存在）
* @param key
* @return
* @date 2017年12月26日
*/
public boolean exists(String key);
/**
*
* @Description （设置key和value）
* @param key
* @param value
* @date 2017年12月26日
*/
public void set(String key, Object value);
/**
*
* @Description （设置key和value）
* @param key
* @param value
* @param isExpire
* 是否缓存
* @date 2018年10月20日
*/
public void set(String key, Object value, boolean isExpire);
/**
*
* @Description （设置key和value）
* @param key
* @param value
* @param seconds
* 缓存时间，单位秒
* @date 2018年10月20日
*/
public void set(String key, Object value, int seconds);
/**
*
* @Description （获取值）
* @param key
* @return
* @date 2017年12月26日
*/
public <T> T getBykey(String key);
/**
*
* @Description （设置String类型：key和value）
* @param key
* @param value
* @date 2018年11月15日
*/
public void setString(String key, String value);
/**
*
* @Description （设置String类型：key和value，是否缓存）
* @param key
* @param value
* @param isExpire
* @date 2018年11月15日
*/
public void setString(String key, String value, boolean isExpire);
/**
*
* @Description （设置String类型：key和value，设置时间）
* @param key
* @param value
* @param seconds
* @date 2018年11月15日
*/
public void setString(String key, String value, int seconds);
/**
*
* @Description （获取String值）
* @param key
* @return
* @date 2018年11月15日
*/
public String getSring(String key);
/**
*
* @Description （删除String值）
* @param key
* @date 2018年11月15日
*/
public void delString(String key);
}
import org.springframework.stereotype.Service;
import com.hesc.sifa.service.JRedisService;
import com.hesc.sifa.utils.JRedisUtils;
import com.hesc.sifa.utils.SerializeUtils;
import com.hesc.sifa.utils.StrToolUtils;
import com.hesc.trundle.message.Message;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.Pipeline;
@Service("jRedisService")
public class JRedisServiceImpl implements JRedisService {
// 单位是秒，默认10分钟
private final static int EXPIRE = Integer.parseInt(Message.getMessage("redis.expire"));
/**
*
* @Description （删除键）
* @param key
* @date 2017年12月26日
*/
public void deleteKey(String... key) {
Jedis jedis = JRedisUtils.getJedis();
if (jedis != null) {
try {
jedis.del(key);
} catch (Exception e) {
e.printStackTrace();
} finally {
JRedisUtils.close(jedis);
}
}
}
/**
*
* @Description （判断key是否存在）
* @param key
* @return
* @date 2017年12月26日
*/
public boolean exists(String key) {
Jedis jedis = JRedisUtils.getJedis();
boolean flag = false;
if (jedis != null) {
try {
flag = jedis.exists(key);
} catch (Exception e) {
e.printStackTrace();
} finally {
JRedisUtils.close(jedis);
}
}
return flag;
}
/**
*
* @Description （设置key和value）
* @param key
* @param value
* @date 2017年12月26日
*/
public void set(String key, Object value) {
set(key, value, true, EXPIRE);
}
public void set(String key, Object value, boolean isExpire) {
set(key, value, isExpire, EXPIRE);
}
public void set(String key, Object value, int seconds) {
set(key, value, true, seconds);
}
public void set(String key, Object value, boolean isExpire, int seconds) {
Jedis jedis = JRedisUtils.getJedis();
if (jedis != null) {
try {
jedis.set(key.getBytes(), SerializeUtils.serialize(value));
if (isExpire) {
jedis.expire(key.getBytes(), seconds);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
JRedisUtils.close(jedis);
}
}
}
/**
*
* @Description （获取值）
* @param key
* @return
* @date 2017年12月26日
*/
@SuppressWarnings("unchecked")
public <T> T getBykey(String key) {
Jedis jedis = JRedisUtils.getJedis();
byte[] byt = null;
if (jedis != null) {
try {
byt = jedis.get(key.getBytes());
} catch (Exception e) {
e.printStackTrace();
} finally {
JRedisUtils.close(jedis);
}
if (null == byt) {
return null;
} else {
return (T) SerializeUtils.unserialize(byt);
}
}
return null;
}
/**
*
* @Description （设置key和value）
* @param key
* @param value
* @date 2017年12月26日
*/
public void setString(String key, String value) {
setString(key, value, true, EXPIRE);
}
public void setString(String key, String value, boolean isExpire) {
setString(key, value, isExpire, 0);
}
public void setString(String key, String value, int seconds) {
setString(key, value, true, seconds);
}
public void setString(String key, String value, boolean isExpire, int seconds) {
Jedis jedis = JRedisUtils.getJedis();
if (jedis != null) {
try {
Pipeline pipeline = jedis.pipelined();
jedis.set(key, value);
if (isExpire) {
jedis.expire(key, seconds);
}
pipeline.sync();
} catch (Exception e) {
e.printStackTrace();
} finally {
JRedisUtils.close(jedis);
}
}
}
/**
*
* @Description （获取值）
* @param key
* @return
* @date 2017年12月26日
*/
public String getSring(String key) {
Jedis jedis = JRedisUtils.getJedis();
String value = "";
if (jedis != null) {
try {
value = jedis.get(key);
} catch (Exception e) {
e.printStackTrace();
} finally {
JRedisUtils.close(jedis);
}
return StrToolUtils.isEmptyDefault(value);
}
return value;
}
/**
*
* @Description （删除key）
* @param key
* @date 2018年11月15日
*/
public void delString(String key) {
Jedis jedis = JRedisUtils.getJedis();
if (jedis != null) {
try {
jedis.del(key);
} catch (Exception e) {
e.printStackTrace();
} finally {
JRedisUtils.close(jedis);
}
}
}
}
import org.apache.log4j.Logger;
import com.hesc.trundle.message.Message;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
public class JRedisUtils {
private static final Logger log = Logger.getLogger(JRedisUtils.class);
private static JedisPool jedisPool = null;
// Redis服务器IP
private static String ADDR = Message.getMessage("redis.addr");
// Redis的端口号
private static int PORT = Integer.parseInt(Message.getMessage("redis.port"));
private static int MaxTotal = Integer.parseInt(Message.getMessage("redis.maxTotal"));
private static int MaxWait = Integer.parseInt(Message.getMessage("redis.maxWait"));
private static int MaxIdle = Integer.parseInt(Message.getMessage("redis.maxIdle"));
static {
initPool();
}
/**
*
* @Description （初始化Redis连接池）
* @date 2017年12月26日
*/
private static synchronized void initPool() {
try {
if (jedisPool == null) {
// 初始化非切片池
jedisPool = new JedisPool(getJedisPoolConfig(), ADDR, PORT, MaxWait);
}
} catch (Exception e) {
log.error(e);
}
}
/**
*
* @Description （获取配置）
* @return
* @date 2017年12月26日
*/
private static JedisPoolConfig getJedisPoolConfig() {
JedisPoolConfig config = new JedisPoolConfig();
// 连接耗尽时是否阻塞, false报异常,ture阻塞直到超时, 默认true
config.setBlockWhenExhausted(true);
// 设置的逐出策略类名, 默认DefaultEvictionPolicy(当连接超过最大空闲时间,或连接数超过最大空闲连接数)
config.setEvictionPolicyClassName("org.apache.commons.pool2.impl.DefaultEvictionPolicy");
// 是否启用pool的jmx管理功能, 默认true
config.setJmxEnabled(true);
// 是否启用后今后出
config.setLifo(true);
// 最大连接数, 默认8个，为负数的时候没有限制。
config.setMaxTotal(MaxTotal);
// 最大空闲连接数, 默认8个，为负数的时候没有限制。
config.setMaxIdle(MaxIdle);
// 最小空闲连接数, 默认0
// config.setMinIdle(0);
// 表示当borrow(引入)一个jedis实例时，最大的等待时间，如果超过等待时间，则直接抛出JedisConnectionException；
config.setMaxWaitMillis(MaxWait);
// 在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；
config.setTestOnBorrow(false);
// 在还会给pool时，是否提前进行validate操作
config.setTestOnReturn(false);
// 自动测试池中的空闲连接是否都是可用连接
config.setTestWhileIdle(true);
// 逐出连接的最小空闲时间
// config.setMinEvictableIdleTimeMillis(500);
// 对象空闲多久后逐出, 当空闲时间>该值 且 空闲连接>最大空闲数 时直接逐出
// config.setSoftMinEvictableIdleTimeMillis(500);
// config.setTimeBetweenEvictionRunsMillis(30000);
// 每次逐出检查时 逐出的最大数目 如果为负数就是 : 1/abs(n), 默认3
// config.setNumTestsPerEvictionRun(100);
return config;
}
/**
* 获取Jedis实例
*
* @return
*/
public synchronized static Jedis getJedis() {
if (jedisPool == null) {
initPool();
}
log.info("Redis活跃数=" + jedisPool.getNumActive() + " 空闲数=" + jedisPool.getNumIdle() + " 等待数="
+ jedisPool.getNumWaiters() + " jedisPool状态=" + jedisPool.isClosed());
try {
if (jedisPool.isClosed() || jedisPool.getNumActive() < 0) {
log.info("*** 重新新建线程池jedisPool ***");
jedisPool = null;
initPool();
}
if (jedisPool != null) {
log.info("+++ 获取Redis实例 +++");
return jedisPool.getResource();
} else {
return null;
}
} catch (Exception e) {
e.printStackTrace();
log.error(e);
return null;
}
}
/**
* 释放jedis资源
*
* @param jedis
*/
public synchronized static void close(final Jedis jedis) {
try {
if (jedis != null) {
// 高版本采用close来归还
log.info("jedis状态：" + jedis.isConnected());
if (jedis.isConnected()) {
log.info("--- 释放Redis实例 ---");
jedis.close();
}
}
// 活跃数超过一定的数量时，进行关闭重新创造线程池
if (jedisPool.getNumActive() > MaxTotal - 100) {
log.info("*** jedisPool.close() ***");
jedisPool.close();
jedisPool.destroy();
}
} catch (Exception e) {
e.printStackTrace();
log.error(e);
/*
* if (jedis.isConnected()) { jedis.quit(); jedis.disconnect(); }
*/
if (jedis != null) {
// 高版本采用close来归还
log.info("jedis状态：" + jedis.isConnected());
if (jedis.isConnected()) {
log.info("--- 释放Redis实例 ---");
jedis.close();
}
}
// jedisPool.close();
// jedisPool.destroy();
}
}
/**
*
* @Description （清空库中所有数据，谨慎操作）
* @date 2017年12月26日
*/
public static void flushDatabase() {
Jedis jedis = getJedis();
if (jedis != null) {
try {
log.info("*** 清空Redis库中所有数据 ***");
jedis.flushDB();
} catch (Exception e) {
e.printStackTrace();
log.error(e);
} finally {
close(jedis);
}
}
}
public static void main(String[] args) {
Jedis jedis = JRedisUtils.getJedis();
if (jedis != null) {
try {
//jedis.set("pxc", "pxc");
//jedis.expire("pxc", 10);
System.out.println(jedis.get("pxc"));
} catch (Exception e) {
e.printStackTrace();
} finally {
JRedisUtils.close(jedis);
}
}
}
}
相关推荐
### 使用Redisson替代Jedis 在分布式系统中，Redis作为一种高性能的键值存储数据库，被广泛应用于缓存、消息队列、数据同步等场景。在Java开发领域，开发者可以选择多种客户端来与Redis进行交互，其中最常用的是...
赠送jar包：jedis-3.6.0.jar； 赠送原API文档：jedis-3.6.0-javadoc.jar； 赠送源代码：jedis-3.6.0-sources.jar； 赠送Maven依赖信息文件：jedis-3.6.0.pom； 包含翻译后的API文档：jedis-3.6.0-javadoc-API文档-...
标题中的“jedis相关jar包”指的是用于操作Redis数据库的Java客户端库Jedis的相关依赖文件。Jedis是一个高效、轻量级的Java客户端，它使得Java开发者能够方便地与Redis进行交互，执行各种数据操作。 描述中提到了两...
jedis-2.9.0.jar jedis-2.9.0 jar 包，不包含源码，源码下载地址： http://download.csdn.net/download/tan3739/9993938 测试代码： 导入依赖包： commons-lang-2.5.jar commons-pool2-2.4.2.jar jedis-2.9.0 jar ...
标题"jedis-2.9.0.jar和commons-pool2-2.6.0.jar下载（jedis连接redis数据库）"指的是两个Java库的下载信息，用于连接Redis数据库。其中，`jedis-2.9.0.jar`是Jedis的特定版本，它是Java开发人员用来操作Redis的...
赠送jar包：jedis-2.9.0.jar； 赠送原API文档：jedis-2.9.0-javadoc.jar； 赠送源代码：jedis-2.9.0-sources.jar； 包含翻译后的API文档：jedis-2.9.0-javadoc-API文档-中文(简体)版.zip 对应Maven信息：groupId...
**Jedis：Redis的Java客户端** Jedis是Java开发者用于操作Redis数据库的首选客户端库。Redis是一个开源的、高性能的键值对存储系统，常被用作数据缓存、消息中间件以及数据库。Jedis提供了丰富的API，允许开发人员...
Jedis API中文使用文档详解 Jedis 是 Redis 官方首选的 Java 客户端开发包，用于操作 Redis 数据库。下面是 Jedis API 的详细使用文档，适合新手和老程序员进行复习。 Jedis 的基本使用 Jedis 提供了多种方式来...
Jedis是Java开发的一款高效、轻量级的Redis客户端，专为处理Redis数据库服务而设计。Redis是一款开源的、高性能的键值存储系统，常用于数据缓存、消息队列、分布式锁等场景。Jedis提供了丰富的API，使得开发者能够...
在Java环境中与Redis进行交互，我们通常会使用Jedis这个客户端库。Jedis提供了丰富的API，能够帮助开发者轻松完成各种Redis操作，如设置和获取键值、执行事务、订阅/发布消息等。 Jedis的主要功能包括： 1. 基本...
**Redis与Jedis** Redis，全称Remote Dictionary Server，是一款高性能的键值对存储系统，常用于数据库缓存和消息中间件。它支持丰富的数据结构，如字符串、哈希、列表、集合、有序集合等，这使得Redis在各种场景下...
jedis调用redis源码Demo，直接导入工程就可以运行。 redis目录下有redis安装文件和入门电子书 redis64-2.8.9.zip redisbin_x32.zip Redis入门指南(JB51.NET).pdf Redis设计与实现.pdf src: FirestJedisTest.java ...
Jedis是Java开发的一款高效的Redis客户端库，广泛应用于与Redis服务器进行交互的Java项目中。在本资源包中，我们提供了jedis-2.9.0.jar，这是Jedis的一个稳定版本，支持多种Redis操作，如键值操作、事务处理、发布...
Jedis是一个Java客户端，用于高效地与Redis服务器通信。在这个主题中，我们将深入探讨`jedis-2.9.0.jar`和`commons-pool2-2.4.2.jar`这两个jar包在Redis连接池中的作用。 `jedis-2.9.0.jar`是Jedis的特定版本，它是...
Jedis是Java开发的一款高效的Redis客户端库，广泛用于与Redis服务器进行交互，提供丰富的API来操作Redis中的数据结构。在学习Jedis的过程中，了解其源码对于深入理解Redis操作的底层实现以及提升Java编程能力非常有...
1. 创建Jedis实例：`Jedis jedis = new Jedis("localhost", 6379);` 2. 配置连接池：使用`JedisPoolConfig`和`JedisPool`，以更好地管理和复用连接。 3. 执行命令：如`jedis.set("key", "value")`来设置键值对，`...
标题中的"jedis-2.9.0+commons-pool2-2.4.2redis依赖包"指的是一款基于Java实现的Redis客户端库Jedis的2.9.0版本，与Apache Commons Pool 2.4.2版本相结合的依赖包。这个组合主要用于优化Redis连接池管理，提高应用...
**Jedis：Redis操作的Java库** `Jedis` 是一个高效的、开源的 Java 客户端，专门用于连接和操作 Redis 数据库。它提供了全面的 Redis 命令支持，使得在 Java 应用中集成 Redis 变得简单易行。在本文中，我们将深入...
标题中的"jedis-3.2.0.jar + commons-pool2-2.6.2.jar"提到了两个关键的Java库：Jedis和Apache Commons Pool2。Jedis是Java编程语言中广泛使用的Redis客户端，而Apache Commons Pool2则是一个对象池实现，用于有效地...