spring 整合 redis的配置
Posted xiexin2015
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了spring 整合 redis的配置相关的知识，希望对你有一定的参考价值。
废话不说，直接上代码：
1、先添加依赖包
<!--redis-->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.8.1</version>
</dependency>
2、新建 applicationContext-redis.xml 文件
在里面配置 jedisPoolConfig， ShardedJedisPool（也可以配置JedisPool）：
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" 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.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.0.xsd"> <!-- 加载配置文件 --> <context:property-placeholder location="classpath:resource/*.properties" /> <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig"> <property name="maxTotal" value="60000" /> <property name="maxIdle" value="1000" /> <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="shardedJedisPool" class="redis.clients.jedis.ShardedJedisPool"> <constructor-arg index="0" ref="jedisPoolConfig"/> <constructor-arg index="1"> <list> <!-- <bean name="slaver" class="redis.clients.jedis.JedisShardInfo"> <constructor-arg index="0" value="${redis.slaver.host}"/> <constructor-arg index="1" value="${redis.slaver.port}" type="int"/> </bean>--> <bean name="master" class="redis.clients.jedis.JedisShardInfo"> <constructor-arg index="0" value="${redis.master.host}"/> <constructor-arg index="1" value="${redis.master.port}" type="int"/> <property name="password" value="${redis.master.auth}"/> </bean> </list> </constructor-arg> </bean> <bean id="shardedRedisManager" class="com.jdd.core.redis.ShardedRedisManager"></bean> </beans>
3、再创建一个缓存管理类 ShardedRedisManager：
// // Source code recreated from a .class file by IntelliJ IDEA // (powered by Fernflower decompiler) // package com.jdd.core.redis; import com.jdd.core.log.LogExceptionStackTrace; import com.jdd.core.utils.GfJsonUtil; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import redis.clients.jedis.*; import java.util.List; public class ShardedRedisManager { @Autowired private ShardedJedisPool shardedJedisPool; private String host; private int port; private static final Logger logger = LoggerFactory.getLogger(ShardedRedisManager.class); public ShardedRedisManager() { } public String getHost() { return this.host; } public void setHost(String host) { this.host = host; } public int getPort() { return this.port; } public void setPort(int port) { this.port = port; } public ShardedJedisPool getShardedJedisPool() { return this.shardedJedisPool; } private void returnResource(ShardedJedis sj) { sj.close(); } private ShardedJedis getResource() { return this.shardedJedisPool.getResource(); } private ShardedJedisPipeline pipelined(ShardedJedis sj) { return sj.pipelined(); } public Long incr(String key) { Long start = System.currentTimeMillis(); ShardedJedis sj = null; try { sj = this.getResource(); Long v = sj.incr(key); Long end = System.currentTimeMillis(); Long time = end - start; if (time > 500L) { logger.warn("ip:{} port:{} command：incr key:{} execution time:{}ms", new Object[]{this.host, this.port, key, time}); } Long var7 = v; return var7; } catch (Exception var11) { logger.error("command：incr key:{} ex={}", key, LogExceptionStackTrace.erroStackTrace(var11)); } finally { if (sj != null) { this.returnResource(sj); } } return null; } public String type(String key) { Long start = System.currentTimeMillis(); ShardedJedis sj = null; try { sj = this.getResource(); String v = sj.type(key); Long end = System.currentTimeMillis(); Long time = end - start; if (time > 500L) { logger.warn("ip:{} port:{} command：type key:{} execution time:{}ms", new Object[]{this.host, this.port, key, time}); } String var7 = v; return var7; } catch (Exception var11) { logger.error("command：type key:{} ex={}", key, LogExceptionStackTrace.erroStackTrace(var11)); } finally { if (sj != null) { this.returnResource(sj); } } return null; } public Long incr(String key, Long integer) { Long start = System.currentTimeMillis(); ShardedJedis sj = null; try { sj = this.getResource(); Long v = sj.incrBy(key, integer); Long end = System.currentTimeMillis(); Long time = end - start; if (time > 500L) { logger.warn("ip:{} port:{} command：incr key:{} execution time:{}ms", new Object[]{this.host, this.port, key, time}); } Long var8 = v; return var8; } catch (Exception var12) { logger.error("command：incr key:{} ex={}", key, LogExceptionStackTrace.erroStackTrace(var12)); } finally { if (sj != null) { this.returnResource(sj); } } return null; } public String get(String key) { Long start = System.currentTimeMillis(); ShardedJedis sj = null; try { sj = this.getResource(); String v = sj.get(key); Long end = System.currentTimeMillis(); Long time = end - start; if (time > 500L) { logger.warn("ip:{} port:{} command：get key:{} execution time:{}ms", new Object[]{this.host, this.port, key, time}); } String var7 = v; return var7; } catch (Exception var11) { logger.error("command：get key:{} ex={}", key, LogExceptionStackTrace.erroStackTrace(var11)); } finally { if (sj != null) { this.returnResource(sj); } } return null; } public String set(String key, String value) { Long start = System.currentTimeMillis(); ShardedJedis sj = null; try { sj = this.getResource(); String v = sj.set(key, value); Long end = System.currentTimeMillis(); Long time = end - start; if (time > 500L) { logger.warn("ip:{} port:{} command：set key:{} execution time:{}ms", new Object[]{this.host, this.port, key, time}); } String var8 = v; return var8; } catch (Exception var12) { logger.error("command：set key:{} ex={}", key, LogExceptionStackTrace.erroStackTrace(var12)); } finally { if (sj != null) { this.returnResource(sj); } } return null; } public void set(List<String> keys, List<String> values) { Long start = System.currentTimeMillis(); ShardedJedis sj = null; try { sj = this.getResource(); ShardedJedisPipeline pip = sj.pipelined(); for(int i = 0; i < keys.size(); ++i) { pip.set((String)keys.get(i), (String)values.get(i)); } pip.sync(); Long end = System.currentTimeMillis(); Long time = end - start; if (time > 500L) { logger.warn("ip:{} port:{} command：set list key:{} execution time:{}ms", new Object[]{this.host, this.port, GfJsonUtil.toJSONString(keys), time}); } } catch (Exception var11) { logger.error("command：set key:{} ex={}", GfJsonUtil.toJSONString(keys), LogExceptionStackTrace.erroStackTrace(var11)); } finally { if (sj != null) { this.returnResource(sj); } } } }
4、然后你就可以在service里注入这个 ShardedRedisManager 类使用啦。
结束！
以上是关于spring 整合 redis的配置的主要内容，如果未能解决你的问题，请参考以下文章