首页 > 代码库 > redis在spring中的配置及java代码实现
redis在spring中的配置及java代码实现
1、建一个redis.properties属性文件
# Redis Setting
redis.addr = 127.0.0.1
redis.port = 6379
redis.auth = master
redis.maxIdle = 200
redis.maxActive = 1024
redis.maxWait = 10000
redis.timeOut = 10000
redis.testOnBorrow = true
2、新建一个RedisUtil.java文件,文件代码如下:
package cn.com.taiji.sample.utils; import java.io.Serializable; import java.util.ArrayList; import java.util.List; 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 RedisUtil implements Serializable{ private static final long serialVersionUID = -1149678082569464779L; //Redis服务器IP private static String addr; //Redis的端口号 private static int port; //访问密码 private static String auth; //可用连接实例的最大数目,默认值为8; //如果赋值为-1,则表示不限制;如果pool已经分配了maxActive个jedis实例,则此时pool的状态为exhausted(耗尽)。 private static int maxActive; //控制一个pool最多有多少个状态为idle(空闲的)的jedis实例,默认值也是8。 private static int maxIdle; //等待可用连接的最大时间,单位毫秒,默认值为-1,表示永不超时。如果超过等待时间,则直接抛出JedisConnectionException; private static int maxWait; private static int timeOut; //在borrow一个jedis实例时,是否提前进行validate操作;如果为true,则得到的jedis实例均是可用的; private static boolean testOnBorrow; public static Jedis jedis;//非切片额客户端连接 public static JedisPool jedisPool;//非切片连接池 public static ShardedJedis shardedJedis;//切片额客户端连接 public static ShardedJedisPool shardedJedisPool;//切片连接池 /** * 初始化非切片池 */ private static void initialPool() { // 池基本配置 JedisPoolConfig config = new JedisPoolConfig(); config.setMaxTotal(maxActive); config.setMaxIdle(maxIdle); config.setMaxWaitMillis(maxWait); config.setTestOnBorrow(testOnBorrow); jedisPool = new JedisPool(config, addr, port); } /** * 初始化切片池 */ private static void initialShardedPool() { // 池基本配置 JedisPoolConfig config = new JedisPoolConfig(); config.setMaxTotal(maxActive); config.setMaxIdle(maxIdle); config.setMaxWaitMillis(maxWait); config.setTestOnBorrow(testOnBorrow); // slave链接 List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>(); shards.add(new JedisShardInfo(addr, port, auth)); // 构造池 shardedJedisPool = new ShardedJedisPool(config, shards); } public static void afterPropertiesSet() throws Exception { // TODO Auto-generated method stub initialPool(); initialShardedPool(); try { shardedJedis = shardedJedisPool.getResource(); } catch (Exception e) { System.out.println("连接shardedJedisPool失败!"); } try { jedis = jedisPool.getResource(); } catch (Exception e) { System.out.println("连接jedisPool失败!"); } } public String getAddr() { return addr; } public void setAddr(String addr) { this.addr = addr; } public int getPort() { return port; } public void setPort(int port) { this.port = port; } public String getAuth() { return auth; } public void setAuth(String auth) { this.auth = auth; } public int getMaxActive() { return maxActive; } public void setMaxActive(int maxActive) { this.maxActive = maxActive; } public int getMaxIdle() { return maxIdle; } public void setMaxIdle(int maxIdle) { this.maxIdle = maxIdle; } public int getMaxWait() { return maxWait; } public void setMaxWait(int maxWait) { this.maxWait = maxWait; } public int getTimeOut() { return timeOut; } public void setTimeOut(int timeOut) { this.timeOut = timeOut; } public boolean isTestOnBorrow() { return testOnBorrow; } public void setTestOnBorrow(boolean testOnBorrow) { this.testOnBorrow = testOnBorrow; } }
在set方法中会飘黄,不影响使用。
3、在spring-servlet.xml配置文件中,加入以下代码:
<context:component-scan base-package="cn.com.taiji.sample.config.web" /> <context:property-placeholder location="file:#{systemProperties[‘webapp.sample‘]}/WEB-INF/conf/redis.properties" /> <bean id="redisUtil" class="cn.com.taiji.sample.utils.RedisUtil"> <property name="addr"><value>${redis.addr}</value></property> <property name="port"><value>${redis.port}</value></property> <property name="auth"><value>${redis.auth}</value></property> <property name="maxIdle"><value>${redis.maxIdle}</value></property> <property name="maxActive"><value>${redis.maxActive}</value></property> <property name="maxWait"><value>${redis.maxWait}</value></property> <property name="timeOut"><value>${redis.timeOut}</value></property> <property name="testOnBorrow"><value>${redis.testOnBorrow}</value></property> </bean>
<context:property-placeholder location="" />指的是redis.properties的文件路径。
到此,redis的spring配置就已经完成了。
下一篇将介绍redis在java项目中的使用。
redis在spring中的配置及java代码实现
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。