java操作redis工具类与配置文件，详细版

共5个文件

java：3个

png：1个

xml：1个

需积分: 2 145 浏览量 2018-01-18 16:08:59 上传评论 1 收藏 16KB ZIP 举报

Redis是一种高性能的键值对数据存储系统，常用于缓存、消息队列和数据库功能。在Java中操作Redis，我们通常会使用一个客户端库，如Jedis或Lettuce，来建立连接、执行命令和处理响应。下面我们将详细介绍Java操作Redis的工具类以及配置文件的设置。 **1. Jedis库的引入** 我们需要在项目中引入Jedis库。如果你使用的是Maven，可以在`pom.xml`文件中添加以下依赖： ```xml <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>3.7.0</version> </dependency> ``` **2. Redis配置文件** 创建一个`redis.properties`配置文件，用来存储Redis服务器的相关信息，例如： ``` redis.host=localhost redis.port=6379 redis.timeout=2000 redis.password= ``` 这些配置可以根据实际的Redis服务器设置进行修改。 **3. 创建Redis工具类** 接下来，编写一个`RedisUtil`工具类，用于管理Redis连接和提供常用操作方法。以下是一个简单的示例： ```java import redis.clients.jedis.Jedis; import java.util.Properties; public class RedisUtil { private static Jedis jedis = null; private static Properties prop = new Properties(); static { try { prop.load(RedisUtil.class.getClassLoader().getResourceAsStream("redis.properties")); jedis = new Jedis(prop.getProperty("redis.host"), Integer.parseInt(prop.getProperty("redis.port")), Integer.parseInt(prop.getProperty("redis.timeout"))); if (!prop.getProperty("redis.password").equals("")) { jedis.auth(prop.getProperty("redis.password")); } } catch (Exception e) { e.printStackTrace(); } } public static Jedis getJedis() { return jedis; } // 其他常用操作方法，例如： public static void set(String key, String value) { getJedis().set(key, value); } public static String get(String key) { return getJedis().get(key); } // ...其他方法（如：删除、更新、获取列表、集合等操作） } ``` 这个工具类提供了连接Redis和执行基本操作的方法，如设置键值对、获取键值对等。 **4. 使用Redis工具类** 在Java Web项目中，你可以直接使用`RedisUtil`来操作Redis，如下所示： ```java public class SomeController { @RequestMapping("/save") public String saveData(@RequestParam String key, @RequestParam String value) { RedisUtil.set(key, value); return "数据保存成功"; } @RequestMapping("/getData") public String getData(@RequestParam String key) { String value = RedisUtil.get(key); return "数据为：" + value; } } ``` 以上代码展示了如何在控制器中使用`RedisUtil`来保存和获取数据。 **5. 连接池配置** 在实际生产环境中，为了提高性能和资源利用率，我们会使用连接池来管理Redis连接。Jedis提供了JedisPool，你可以通过以下方式配置： ```java import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; // ... public class RedisUtil { private static JedisPool pool; static { JedisPoolConfig config = new JedisPoolConfig(); config.setMaxTotal(100); // 最大连接数 config.setMaxIdle(50); // 最大空闲连接 config.setMinIdle(10); // 最小空闲连接 config.setTestOnBorrow(true); // 借出连接时检查有效性 pool = new JedisPool(config, prop.getProperty("redis.host"), Integer.parseInt(prop.getProperty("redis.port")), Integer.parseInt(prop.getProperty("redis.timeout")), prop.getProperty("redis.password")); } public static Jedis getJedis() { return pool.getResource(); } // ...其他方法 } ``` 这样，每次获取连接时，都会从连接池中获取，用完后归还到池中。总结，Java操作Redis主要包括引入Jedis库、配置Redis连接参数、编写工具类以及使用连接池管理连接。在实际开发中，还需要考虑异常处理、连接池关闭以及更复杂的操作，如事务处理、发布订阅等。这个提供的`redis在Java web项目的简单应用`可能涵盖了基础的操作，但深入学习还需要了解更多的Redis特性和Java客户端的高级用法。

资源推荐

资源详情

资源评论

收起资源包目录

redis在Java web项目的简单应用.zip （5个子文件）

redis在Java web项目的简单应用

RedisDataSourceImpl.java 2KB

RedisClientTemplate.java 54KB

R~}@I4S0%V9B7N7NWO]3KDS.png 10KB

RedisDataSource.java 562B

spring.xml 2KB

package com.redis; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisShardInfo; import redis.clients.jedis.ShardedJedis; /** * @Title: RedisClientTemplate.java * @copyright * @Package com.cy.redis * @Description: 用于操作redis取值、存值操作的工具类 * @author * @date 2016-10-21 下午04:21:59 */ public class RedisClientTemplate { private static final org.slf4j.Logger log=LoggerFactory.getLogger(RedisClientTemplate.class); @Autowired private RedisDataSource redisDataSource; public RedisDataSource getRedisDataSource() { return redisDataSource; } public void setRedisDataSource(RedisDataSource redisDataSource) { this.redisDataSource = redisDataSource; } public void disconnect(){ ShardedJedis shardedJedis=redisDataSource.getRedisClient(); shardedJedis.disconnect(); } /** * @Description: 在redis里设置单个值 * @author Mr.chen * @date 2016-10-21 下午04:37:06 */ public String set(String key, String value){ String result=null; ShardedJedis shardedJedis=redisDataSource.getRedisClient(); if(shardedJedis==null){ return result; } boolean broken=false; try { result=shardedJedis.set(key, value); } catch (Exception e) { broken=true; e.printStackTrace(); }finally{ redisDataSource.returnResource(shardedJedis, broken); } return result; } /** * @Description: 获取redis单个值 * @author Mr.chen * @date 2016-10-21 下午04:40:57 */ public String get(String key) { String result = null; ShardedJedis shardedJedis = redisDataSource.getRedisClient(); if (shardedJedis == null) { return result; } boolean broken = false; try { result = shardedJedis.get(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { redisDataSource.returnResource(shardedJedis, broken); } return result; } /** * @Description: 判断redis是否存在key * @author Mr.chen * @date 2016-10-21 下午04:41:39 */ public Boolean exists(String key) { Boolean result = false; ShardedJedis shardedJedis = redisDataSource.getRedisClient(); if (shardedJedis == null) { return result; } boolean broken = false; try { result = shardedJedis.exists(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { redisDataSource.returnResource(shardedJedis, broken); } return result; } /** * @Description: 获取key返回存储值的类型 * @author Mr.chen * @date 2016-10-21 下午04:42:08 */ public String type(String key) { String result = null; ShardedJedis shardedJedis = redisDataSource.getRedisClient(); if (shardedJedis == null) { return result; } boolean broken = false; try { result = shardedJedis.type(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { redisDataSource.returnResource(shardedJedis, broken); } return result; } /** * @Description: 在某段时间后实现 * @author Mr.chen * @date 2016-10-21 下午04:43:25 */ public Long expire(String key, int seconds) { Long result = null; ShardedJedis shardedJedis = redisDataSource.getRedisClient(); if (shardedJedis == null) { return result; } boolean broken = false; try { result = shardedJedis.expire(key, seconds); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { redisDataSource.returnResource(shardedJedis, broken); } return result; } /** * @Description: 在某个时间点失效 * @author Mr.chen * @date 2016-10-21 下午04:43:40 */ public Long expireAt(String key, long unixTime) { Long result = null; ShardedJedis shardedJedis = redisDataSource.getRedisClient(); if (shardedJedis == null) { return result; } boolean broken = false; try { result = shardedJedis.expireAt(key, unixTime); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { redisDataSource.returnResource(shardedJedis, broken); } return result; } /** * @Description: 以秒为单位，返回给定 key 的剩余生存时间 * @author Mr.chen * @date 2016-10-21 下午04:44:00 */ public Long ttl(String key) { Long result = null; ShardedJedis shardedJedis = redisDataSource.getRedisClient(); if (shardedJedis == null) { return result; } boolean broken = false; try { result = shardedJedis.ttl(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { redisDataSource.returnResource(shardedJedis, broken); } return result; } /** * @Description: 将 key 的值设为 value ，当且仅当 key 不存在 * @author Mr.chen * @date 2016-10-21 下午04:44:17 */ public Long setnx(String key, String value) { Long result = null; ShardedJedis shardedJedis = redisDataSource.getRedisClient(); if (shardedJedis == null) { return result; } boolean broken = false; try { result = shardedJedis.setnx(key, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { redisDataSource.returnResource(shardedJedis, broken); } return result; } /** * 将值 value 关联到 key ，并将 key 的生存时间设为 seconds (以秒为单位) * @param key * @param seconds * @param value * @return */ public String setex(String key, int seconds, String value) { String result = null; ShardedJedis shardedJedis = redisDataSource.getRedisClient(); if (shardedJedis == null) { return result; } boolean broken = false; try { result = shardedJedis.setex(key, seconds, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { redisDataSource.returnResource(shardedJedis, broken); } return result; } /** * 将 key 所储存的值减去减量 integer * @param key * @param integer * @return */ public Long decrBy(String key, l

评论收藏

内容反馈