`

JedisPool和spring

 
阅读更多
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd">

	<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
		<property name="maxTotal" value="2048" />
		<property name="maxIdle" value="200" />
		<property name="numTestsPerEvictionRun" value="1024" />
		<property name="timeBetweenEvictionRunsMillis" value="30000" />
		<property name="minEvictableIdleTimeMillis" value="-1" />
		<property name="softMinEvictableIdleTimeMillis" value="10000" />
		<property name="maxWaitMillis" value="1500" />
		<property name="testOnBorrow" value="true" />
		<property name="testWhileIdle" value="true" />
		<property name="testOnReturn" value="false" />
		<property name="jmxEnabled" value="true" />
		<property name="jmxNamePrefix" value="youyuan" />
		<property name="blockWhenExhausted" value="false" />
	</bean>
	
	<bean id="jedisPool" class="redis.clients.jedis.JedisPool">
		<constructor-arg index="0" ref="jedisPoolConfig"/>  
        <constructor-arg index="1" value="${redis.slaver.host}"/>  
        <constructor-arg index="2" value="${redis.slaver.port}" type="int"/>  
        <!-- 
        <constructor-arg index="3" value="${redis.timeout}" type="int"/>  
        <constructor-arg index="4" value="${redis.password}"/>
         -->
	</bean>
	
</beans>

 

#最大分配的对象数  
redis.pool.maxActive=1024  
#最大能够保持idel状态的对象数  
redis.pool.maxIdle=200  
#当池内没有返回对象时,最大等待时间  
redis.pool.maxWait=1000  
#当调用borrow Object方法时,是否进行有效性检查  
redis.pool.testOnBorrow=true  
#当调用return Object方法时,是否进行有效性检查
redis.pool.testOnReturn=true  
#IP
#redis.slaver.host=192.168.31.125
redis.slaver.host=127.0.0.1
#Port 
redis.slaver.port=6379  

 

package com.dongly.sssr.orm;

import java.util.List;
import java.util.Set;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;

@Component
public class RedisUtil {

	public static Logger logger = LoggerFactory.getLogger(RedisUtil.class);

	@Autowired
	private JedisPool jedisPool;

	/**
	 * 回收jedis
	 * 
	 * @param jedis
	 */
	private void returnJedis(Jedis jedis) {
		if (jedis != null) {
			try {
				jedis.close();
			} catch (Exception e) {
				logger.error("returnJedis error.", e);
			}
		}
	}

	/**
	 * 设置一个key的过期时间(单位:秒)
	 * 
	 * @param key
	 *            key值
	 * @param seconds
	 *            多少秒后过期
	 * @return true:设置了过期时间 false:没有设置过期时间/不能设置过期时间
	 */
	public Boolean expire(String key, int seconds) {
		if (key == null || key.equals("")) {
			return false;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			Long expire = jedis.expire(key, seconds);
			return expire == 1 ? true : false;
		} catch (Exception ex) {
			logger.error("expire error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return false;
	}

	/**
	 * 设置一个key在某个时间点过期
	 * 
	 * @param key
	 *            key值
	 * @param unixTimestamp
	 *            unix时间戳,从1970-01-01 00:00:00开始到现在的秒数
	 * @return true:设置了过期时间 false:没有设置过期时间/不能设置过期时间
	 */
	public Boolean expireAt(String key, long unixTimestamp) {
		if (StringUtils.isEmpty(key)) {
			return false;
		}

		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			Long expireAt = jedis.expireAt(key, unixTimestamp);
			return expireAt == 1 ? true : false;
		} catch (Exception ex) {
			logger.error("expireAt error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return false;
	}

	/**
	 * 截断一个List
	 * 
	 * @param key
	 *            列表key
	 * @param start
	 *            开始位置 从0开始
	 * @param end
	 *            结束位置
	 * @return true:表示成功
	 */
	public Boolean trimList(String key, long start, long end) {
		if (StringUtils.isEmpty(key)) {
			return false;
		}

		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			jedis.ltrim(key, start, end);
			return true;
		} catch (Exception ex) {
			logger.error("trimList error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return false;
	}

	/**
	 * 检查Set 元素个数
	 * 
	 * @param key
	 * @return -1:表示key 为空
	 */
	public long setSize(String key) {
		if (StringUtils.isEmpty(key)) {
			return -1;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			return jedis.scard(key);
		} catch (Exception ex) {
			logger.error("setSize error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return -1;
	}

	/**
	 * 添加到Set中(同时设置过期时间)
	 * 
	 * @param key
	 *            key值
	 * @param seconds
	 *            过期时间 单位s
	 * @param value
	 * @return 成功true
	 */
	public boolean addSet(String key, int seconds, String... value) {
		if (StringUtils.isEmpty(key)) {
			return false;
		}

		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			Boolean addSet = addSet(key, value);
			if (addSet) {
				expire(key, seconds);
				return true;
			}
		} catch (Exception ex) {
			logger.error("addSet error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return false;
	}

	/**
	 * 添加到Set中
	 * 
	 * @param key
	 * @param value
	 * @return -1 表示添加失败 1:成功
	 */
	public Boolean addSet(String key, String... value) {
		if (StringUtils.isEmpty(key)) {
			return false;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			jedis.sadd(key, value);
			return true;
		} catch (Exception ex) {
			logger.error("addSet error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return false;
	}

	/**
	 * @param key
	 * @param value
	 * @return 判断value值是否包含在set中
	 */
	public boolean containsInSet(String key, String value) {
		if (StringUtils.isEmpty(key)) {
			return false;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			return jedis.sismember(key, value);
		} catch (Exception ex) {
			logger.error("containsInSet error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return false;
	}

	/**
	 * 获取Set
	 * 
	 * @param key
	 * @return 返回null或者【】 表示 没有这个➹
	 */
	public Set<String> getSet(String key) {

		if (StringUtils.isEmpty(key)) {
			return null;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			return jedis.smembers(key);
		} catch (Exception ex) {
			logger.error("getSet error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return null;
	}

	/**
	 * 从set中删除value
	 * 
	 * @param key
	 * @return
	 */
	public boolean removeSetValue(String key, String... value) {
		if (StringUtils.isEmpty(key)) {
			return false;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			Long srem = jedis.srem(key, value);
			return true;
		} catch (Exception ex) {
			logger.error("removeSetValue error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return false;
	}

	/**
	 * 从list中删除value 默认count 1
	 * 
	 * @param key
	 * @param values
	 *            值list
	 * @return
	 */
	public int removeListValue(String key, List<String> values) {
		return removeListValue(key, 1, values);
	}

	/**
	 * 从list中删除value
	 * 
	 * @param key
	 * @param count
	 * @param values
	 *            值list
	 * @return
	 */
	public int removeListValue(String key, long count, List<String> values) {
		int result = 0;
		if (values != null && values.size() > 0) {
			for (String value : values) {
				if (removeListValue(key, count, value)) {
					result++;
				}
			}
		}
		return result;
	}

	/**
	 * 从list中删除value
	 * 
	 * @param key
	 * @param count
	 *            要删除个数
	 * @param value
	 * @return
	 */
	public boolean removeListValue(String key, long count, String value) {
		if (StringUtils.isEmpty(key)) {
			return false;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			jedis.lrem(key, count, value);
			return true;
		} catch (Exception ex) {
			logger.error("containsInSet error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return false;
	}

	/**
	 * 截取List
	 * 
	 * @param key
	 * @param start
	 *            起始位置
	 * @param end
	 *            结束位置
	 * @return
	 */
	public List<String> rangeList(String key, long start, long end) {

		if (StringUtils.isEmpty(key)) {
			return null;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			return jedis.lrange(key, start, end);
		} catch (Exception ex) {
			logger.error("rangeList 出错[key=" + key + " start=" + start + " end=" + end + "]" + ex.getMessage(), ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return null;
	}

	/**
	 * List长度
	 * 
	 * @param key
	 * @return
	 */
	public long countList(String key) {
		if (StringUtils.isEmpty(key)) {
			return -1;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			return jedis.llen(key);
		} catch (Exception ex) {
			logger.error("countList error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return -1;
	}

	/**
	 * 添加到List中(同时设置过期时间)
	 * 
	 * @param key
	 *            key值
	 * @param seconds
	 *            过期时间 单位s
	 * @param value
	 * @return
	 */
	public boolean addList(String key, int seconds, String... value) {
		boolean result = addList(key, value);
		if (result) {
			return expire(key, seconds);
		}
		return false;
	}

	/**
	 * 添加到List
	 * 
	 * @param key
	 * @param value
	 * @return
	 */
	public boolean addList(String key, String... value) {
		if (StringUtils.isEmpty(key)) {
			return false;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			jedis.rpush(key, value);
			return true;
		} catch (Exception ex) {
			logger.error("addList error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return false;
	}

	/**
	 * 添加到List(只新增)
	 * @param key
	 * @param value
	 * @return
	 */
	public boolean addList(String key, List<String> list) {
		if (key == null || list == null || list.size() == 0) {
			return false;
		}
		for (String value : list) {
			addList(key, value);
		}
		return true;
	}

	/**
	 * 获取List
	 * 
	 * @param key
	 * @return
	 */
	public List<String> getList(String key) {
		if (StringUtils.isEmpty(key)) {
			return null;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			return jedis.lrange(key, 0, -1);
		} catch (Exception ex) {
			logger.error("getList error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return null;
	}

	/**
	 * 设置HashSet对象
	 *
	 * @param domain 域名
	 * @param key 键值
	 * @param value Json String or String value
	 * @return -1:添加失败  0:field原来在map里面已经存在 1:field是一个新的字段
	 */
	public Long setHSet(String key, String field, String value) {
		if (StringUtils.isEmpty(key)) {
			return -1l;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			return jedis.hset(key, field, value);
		} catch (Exception ex) {
			logger.error("setHSet error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return -1l;
	}

	/**
	 * 获得HashSet对象
	 * @param field 域名
	 * @param key 键值
	 * @return Json String or String value
	 */
	public String getHSet(String key, String field) {
		if (StringUtils.isEmpty(key)) {
			return null;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			return jedis.hget(key, field);
		} catch (Exception ex) {
			logger.error("setHSet error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return null;
	}

	/**
	 * 删除HashSet对象
	 *
	 * @param domain
	 *            域名
	 * @param key
	 *            键值
	 * @return 删除的记录数 -1 表示异常  0 表示删除失败
	 */
	public long delHSet(String key, String field) {
		if (StringUtils.isEmpty(key)) {
			return -1;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			return jedis.hdel(key, field);
		} catch (Exception ex) {
			logger.error("delHSet error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return -1;
	}


	/**
	 * 判断Hash field是否存在
	 *
	 * @param domain
	 *            域名
	 * @param key
	 *            键值
	 * @return
	 */
	public boolean existsHSet(String key, String field) {
		if (StringUtils.isEmpty(key)) {
			return false;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			return jedis.hexists(key, field);
		} catch (Exception ex) {
			logger.error("delHSet error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return false;
	}

	/**
	 * 返回 Hash 集中所有字段的value值
	 * @param key
	 * @return
	 */

	public List<String> hvals(String key) {
		if (StringUtils.isEmpty(key)) {
			return null;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			return jedis.hvals(key);
		} catch (Exception ex) {
			logger.error("hvals error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return null;
	}

	/**
	 * 返回 Hash 集中所有字段的key值
	 * @param domain
	 * @return
	 */

	public Set<String> hkeys(String key) {
		if (StringUtils.isEmpty(key)) {
			return null;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			return jedis.hkeys(key);
		} catch (Exception ex) {
			logger.error("hkeys error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return null;
	}

	/**
	 * 返回 Hash 中字段值总数
	 * @param key
	 * @return
	 */
	public long lenHset(String key) {
		if (StringUtils.isEmpty(key)) {
			return -1;
		}
		Jedis jedis = null;
		try {
			jedis = jedisPool.getResource();
			return jedis.hlen(key);
		} catch (Exception ex) {
			logger.error("lenHset error.", ex);
			returnJedis(jedis);
		} finally {
			returnJedis(jedis);
		}
		return -1;
	}

}

 

 

分享到:
评论

相关推荐

    redis+spring jedis方式

    JedisPool jedisPool = new JedisPool(poolConfig, "localhost", 6379); ``` 总的来说,"redis+spring jedis方式"意味着通过Spring Data Redis的抽象层,结合Jedis客户端,实现与Redis的交互。这种方式既保留了...

    dubbo,redis_pool,springMVC(可用在wind上运行)

    总结来说,这个项目是一个基于 Java 的分布式应用,利用 Dubbo 实现服务的分布式架构,通过 Redis Pool 和 Jedis 实现高效的数据缓存,借助 Spring MVC 处理 Web 请求并实现业务逻辑,同时利用 AOP 进行日志记录,...

    jedis-3.3.0.jar文件

    JedisPool jedisPool = new JedisPool(poolConfig, "localhost", 6379); Jedis jedis = jedisPool.getResource(); try { jedis.set("key", "value"); String value = jedis.get("key"); } finally { jedis.close...

    spring整合redis

    整合Spring和Redis时,还需要注意以下几点: 1. 配置Redis服务器的地址、端口、密码等信息,确保Spring能够正确连接到Redis。 2. 考虑到线程安全,不要在多线程环境下直接使用Jedis实例,而应始终从JedisPool获取。 ...

    jedis-2.1.0

    3. **连接池支持:** Jedis提供JedisPool,这是一个连接池,可以有效地管理和复用与Redis服务器的连接,提高性能并减少资源消耗。 4. **多线程安全:** Jedis对象不是线程安全的,因此在多线程环境中,每个线程应...

    Redis最全资料+工具+案例+详细说明(有单独使用的jedis也有结合spring使用的redis)

    在实际项目中,为了管理连接池,可以使用`JedisPool`和`JedisPoolConfig`类。 接下来,我们将讨论Spring与Redis的集成。Spring Data Redis模块提供了对Redis的高级支持,包括模板、操作符和Repository。在Spring...

    commons-pool2-2.4.2和jedis-2.7.2

    接着,使用`JedisPool`构造函数初始化连接池,传入配置和Redis服务器的地址信息。在需要使用Redis时,从池中借用一个Jedis实例,执行完操作后归还回池,而不是直接关闭连接。这样,连接池会自动管理这些连接,确保在...

    使用Redis和Zookeeper实现分布式锁 基于redis和zookeeper工具集-包括循环锁实现、循环速率限制器、循环序列等.zip

    &lt;dependency&gt; &lt;groupId&gt;dance&lt;/groupId&gt; &lt;artifactId&gt;Distributed-Kit&lt;/artifactId&gt; &lt;version&gt;0.0.1&lt;/version&gt; &lt;/dependency&gt;## 基于Redis实现的全球锁(可重入)public static void main(String[] args){ JedisPool ...

    Spring+redis5.05配置过程.docx

    然后,我们使用该 Bean 创建了一个名为 `jedisPool` 的 JedisPool 对象,该对象负责管理 Redis 连接池。 Spring 和 Redis 的集成 在 Spring 应用程序中,我们可以使用 Jedis 客户端来连接 Redis 服务。我们定义了...

    jedis安装包

    例如,使用`JedisPool`和`JedisPoolConfig`: ```java JedisPoolConfig poolConfig = new JedisPoolConfig(); poolConfig.setMaxTotal(100); // 最大连接数 poolConfig.setMaxIdle(50); // 最大空闲连接 poolConfig....

    Redis和Jedis示例代码

    java源代码(基于spring-boot)工程介绍:(Jedis存取redis的测试)1、直接连接redis,通过jedis实例直接连接redis,并存入和获取数据2、连接池JedisPool方式连接redis,通过连接池连接redis,可配置最大连接数、...

    ssm整合redis1

    -- 把jedisPool交给spring管理 --&gt; &lt;bean class="redis.clients.jedis.JedisPool" &gt; &lt;constructor-arg name="poolConfig" ref="poolConfig"&gt;&lt;/constructor-arg&gt; ...

    spring+mybatis+redis整合.docx

    本文将详细介绍如何使用Redis解决用户状态管理问题,并对Spring和MyBatis进行整合。 知识点: 1. Redis的优点 Redis具有存取速度快、用户数据不容易丢失、支持集群和持久化等优点,解决了传统的Session和Cookie...

    spring中通过ApplicationContext getBean获取注入对象的方法实例

    jedisPool = (JedisPool) SpringContextUtil.getBean("jedisPool"); } // ...其他Redis操作方法 } ``` 在`RedisUtil`类中,我们直接通过`SpringContextUtil.getBean`静态方法获取了名为`jedisPool`的Bean。这样...

    spring-session+spring+redis的依赖包

    在Java Web开发中,Spring Session是一个非常重要的组件,它提供了会话管理的解决方案,使得...通过使用Redis作为存储,结合Spring Session的便捷性和Jedis的高效访问,可以在复杂环境中保证会话数据的一致性和可靠性。

    spring-session+spring依赖jar包

    spring-session+spring依赖jar包,包含spring4.0.2.RELEASE相关jar包和commons-pool2-2.4.2.jar,jedis-2.7.3.jar,spring-data-redis-1.6.2.RELEASE.jar,spring-session-1.1.1.RELEASE.jar

    redis和spring整合

    spring.redis.jedis.pool.max-active=8 ``` 3. **创建RedisTemplate**: 在Spring配置类中,定义一个`RedisTemplate` bean,配置序列化方式,这里我们使用JdkSerializationRedisSerializer和...

    spring整合redis项目

    spring.redis.jedis.pool.max-active=8 spring.redis.jedis.pool.max-idle=8 spring.redis.jedis.pool.min-idle=0 ``` 四、使用Spring Data Redis API 1. RedisTemplate:这是Spring Data Redis的核心类,提供了...

    Redis-3.2.100_java_

    `JedisPool`提供连接池管理,提高资源复用,避免频繁创建和销毁连接。以下是一个简单的连接池配置示例: ```java JedisPoolConfig poolConfig = new JedisPoolConfig(); poolConfig.setMaxTotal(100); // 最大连接...

    spring-redis.txt

    &lt;bean id="jedisPool" class="redis.clients.jedis.JedisPool"&gt; ``` 1. **根元素 `&lt;beans&gt;`**: - 定义了一个集合,用于存放 Bean 的定义。 - 通过 `xmlns` 和 `xsi:schemaLocation` 指定了命名空间...

Global site tag (gtag.js) - Google Analytics