添加依赖

                 
      
       org.springframework.boot
       
      
       spring-boot-starter-redis
       
     

Redis配置

package com.wisely.ij.config;    import com.fasterxml.jackson.annotation.JsonAutoDetect; import com.fasterxml.jackson.annotation.PropertyAccessor; import com.fasterxml.jackson.databind.ObjectMapper; import org.springframework.cache.CacheManager; import org.springframework.cache.annotation.CachingConfigurerSupport; import org.springframework.cache.annotation.EnableCaching; import org.springframework.cache.interceptor.KeyGenerator; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.redis.cache.RedisCacheManager; import org.springframework.data.redis.connection.RedisConnectionFactory; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; import java.lang.reflect.Method; @Configuration @EnableCaching public class RedisConfig extends CachingConfigurerSupport{ @Bean public KeyGenerator wiselyKeyGenerator(){ return new KeyGenerator() { @Override public Object generate(Object target, Method method, Object... params) { StringBuilder sb = new StringBuilder(); sb.append(target.getClass().getName()); sb.append(method.getName()); for (Object obj : params) { sb.append(obj.toString()); } return sb.toString(); } }; } @Bean public CacheManager cacheManager( @SuppressWarnings("rawtypes") RedisTemplate redisTemplate) { return new RedisCacheManager(redisTemplate); } @Bean public RedisTemplate
     
       redisTemplate( RedisConnectionFactory factory) { StringRedisTemplate template = new StringRedisTemplate(factory); Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); ObjectMapper om = new ObjectMapper(); om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); jackson2JsonRedisSerializer.setObjectMapper(om); template.setValueSerializer(jackson2JsonRedisSerializer); template.afterPropertiesSet(); return template; } }
     

# REDIS (RedisProperties)  spring.redis.database= # database name  spring.redis.host=localhost # server host  spring.redis.password= # server password  spring.redis.port=6379 # connection port spring.redis.pool.max-idle=8 # pool settings ... spring.redis.pool.min-idle=0 spring.redis.pool.max-active=8 spring.redis.pool.max-wait=-1 spring.redis.sentinel.master= # name of Redis server spring.redis.sentinel.nodes= # comma-separated list of host:port pairs

 

@Conditional(MyCondition.class)

 

这句代码可以标注在类上面，表示该类下面的所有@Bean都会启用配置

也可以标注在方法上面，只是对该方法启用配置

 

除了自己自定义Condition之外，Spring还提供了很多Condition给我们用

@ConditionalOnBean（仅仅在当前上下文中存在某个对象时，才会实例化一个Bean）

@ConditionalOnClass（某个class位于类路径上，才会实例化一个Bean）

@ConditionalOnExpression（当表达式为true的时候，才会实例化一个Bean）

@ConditionalOnMissingBean（仅仅在当前上下文中不存在某个对象时，才会实例化一个Bean）

@ConditionalOnMissingClass（某个class类路径上不存在的时候，才会实例化一个Bean）

@ConditionalOnNotWebApplication（不是web应用）

org.springframework.boot:spring-boot-autoconfigure:1.3.0.M2

package org.springframework.boot.autoconfigure.redis;import java.net.UnknownHostException;import java.util.ArrayList;import java.util.List;import org.apache.commons.pool2.impl.GenericObjectPool;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingClass;import org.springframework.boot.autoconfigure.redis.RedisProperties;import org.springframework.boot.autoconfigure.redis.RedisProperties.Pool;import org.springframework.boot.autoconfigure.redis.RedisProperties.Sentinel;import org.springframework.boot.context.properties.EnableConfigurationProperties;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.data.redis.connection.RedisConnectionFactory;import org.springframework.data.redis.connection.RedisNode;import org.springframework.data.redis.connection.RedisSentinelConfiguration;import org.springframework.data.redis.connection.jedis.JedisConnection;import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;import org.springframework.data.redis.core.RedisOperations;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.data.redis.core.StringRedisTemplate;import org.springframework.util.Assert;import org.springframework.util.StringUtils;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPoolConfig;@Configuration@ConditionalOnClass({JedisConnection.class, RedisOperations.class, Jedis.class})@EnableConfigurationPropertiespublic class RedisAutoConfiguration {    public RedisAutoConfiguration() {    }    @Bean(        name = {"org.springframework.autoconfigure.redis.RedisProperties"}    )    @ConditionalOnMissingBean    public RedisProperties redisProperties() {        return new RedisProperties();    }    @Configuration    protected static class RedisConfiguration {        protected RedisConfiguration() {        }        @Bean        @ConditionalOnMissingBean(            name = {"redisTemplate"}        )        public RedisTemplate
     
       redisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {            RedisTemplate template = new RedisTemplate();            template.setConnectionFactory(redisConnectionFactory);            return template;        }        @Bean        @ConditionalOnMissingBean({StringRedisTemplate.class})        public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {            StringRedisTemplate template = new StringRedisTemplate();            template.setConnectionFactory(redisConnectionFactory);            return template;        }    }    @Configuration    @ConditionalOnClass({GenericObjectPool.class})    protected static class RedisPooledConnectionConfiguration extends RedisAutoConfiguration.AbstractRedisConfiguration {        protected RedisPooledConnectionConfiguration() {        }        @Bean        @ConditionalOnMissingBean        public RedisConnectionFactory redisConnectionFactory() throws UnknownHostException {            return this.applyProperties(this.createJedisConnectionFactory());        }        private JedisConnectionFactory createJedisConnectionFactory() {            return this.properties.getPool() != null? new JedisConnectionFactory(this.getSentinelConfig(), this.jedisPoolConfig()): new JedisConnectionFactory(this.getSentinelConfig());
     

}        private JedisPoolConfig jedisPoolConfig() {            JedisPoolConfig config = new JedisPoolConfig();            Pool props = this.properties.getPool();            config.setMaxTotal(props.getMaxActive());            config.setMaxIdle(props.getMaxIdle());            config.setMinIdle(props.getMinIdle());            config.setMaxWaitMillis((long)props.getMaxWait());            return config;        }    }    @Configuration    @ConditionalOnMissingClass({
     "org.apache.commons.pool2.impl.GenericObjectPool"})    protected static class RedisConnectionConfiguration extends RedisAutoConfiguration.AbstractRedisConfiguration {        protected RedisConnectionConfiguration() {        }        @Bean        @ConditionalOnMissingBean        public RedisConnectionFactory redisConnectionFactory() throws UnknownHostException {            return this.applyProperties(new JedisConnectionFactory(this.getSentinelConfig()));        }    }    protected abstract static class AbstractRedisConfiguration {        @Autowired        protected RedisProperties properties;        @Autowired(            required = false        )        private RedisSentinelConfiguration sentinelConfiguration;        protected AbstractRedisConfiguration() {        }        protected final JedisConnectionFactory applyProperties(JedisConnectionFactory factory) {            factory.setHostName(this.properties.getHost());            factory.setPort(this.properties.getPort());            if(this.properties.getPassword() != null) {                factory.setPassword(this.properties.getPassword());            }            factory.setDatabase(this.properties.getDatabase());            if(this.properties.getTimeout() > 0) {                factory.setTimeout(this.properties.getTimeout());            }            return factory;        }        protected final RedisSentinelConfiguration getSentinelConfig() {            if(this.sentinelConfiguration != null) {                return this.sentinelConfiguration;            } else {                Sentinel sentinelProperties = this.properties.getSentinel();                if(sentinelProperties != null) {                    RedisSentinelConfiguration config = new RedisSentinelConfiguration();                    config.master(sentinelProperties.getMaster());                    config.setSentinels(this.createSentinels(sentinelProperties));                    return config;                } else {                    return null;                }            }        }        private List
     
       createSentinels(Sentinel sentinel) {            ArrayList sentinels = new ArrayList();            String nodes = sentinel.getNodes();            String[] var4 = StringUtils.commaDelimitedListToStringArray(nodes);            int var5 = var4.length;            for(int var6 = 0; var6 < var5; ++var6) {                String node = var4[var6];                try {                    String[] ex = StringUtils.split(node, ":");                    Assert.state(ex.length == 2, "Must be defined as \'host:port\'");                    sentinels.add(new RedisNode(ex[0], Integer.valueOf(ex[1]).intValue()));                } catch (RuntimeException var9) {                    throw new IllegalStateException("Invalid redis sentinel property \'" + node + "\'", var9);                }            }            return sentinels;        }    }}
     

 

package org.springframework.boot.autoconfigure.redis;import org.springframework.boot.context.properties.ConfigurationProperties;@ConfigurationProperties(    prefix = "spring.redis")public class RedisProperties {    private int database = 0;    private String host = "localhost";    private String password;    private int port = 6379;    private int timeout;    private RedisProperties.Pool pool;    private RedisProperties.Sentinel sentinel;    public RedisProperties() {    }    public int getDatabase() {        return this.database;    }    public void setDatabase(int database) {        this.database = database;    }    public String getHost() {        return this.host;    }    public void setHost(String host) {        this.host = host;    }    public String getPassword() {        return this.password;    }    public void setPassword(String password) {        this.password = password;    }    public int getPort() {        return this.port;    }    public void setPort(int port) {        this.port = port;    }    public void setTimeout(int timeout) {        this.timeout = timeout;    }    public int getTimeout() {        return this.timeout;    }    public RedisProperties.Sentinel getSentinel() {        return this.sentinel;    }    public void setSentinel(RedisProperties.Sentinel sentinel) {        this.sentinel = sentinel;    }    public RedisProperties.Pool getPool() {        return this.pool;    }    public void setPool(RedisProperties.Pool pool) {        this.pool = pool;    }    public static class Sentinel {        private String master;        private String nodes;        public Sentinel() {        }        public String getMaster() {            return this.master;        }        public void setMaster(String master) {            this.master = master;        }        public String getNodes() {            return this.nodes;        }        public void setNodes(String nodes) {            this.nodes = nodes;        }    }    public static class Pool {        private int maxIdle = 8;        private int minIdle = 0;        private int maxActive = 8;        private int maxWait = -1;        public Pool() {        }        public int getMaxIdle() {            return this.maxIdle;        }        public void setMaxIdle(int maxIdle) {            this.maxIdle = maxIdle;        }        public int getMinIdle() {            return this.minIdle;        }        public void setMinIdle(int minIdle) {            this.minIdle = minIdle;        }        public int getMaxActive() {            return this.maxActive;        }        public void setMaxActive(int maxActive) {            this.maxActive = maxActive;        }        public int getMaxWait() {            return this.maxWait;        }        public void setMaxWait(int maxWait) {            this.maxWait = maxWait;        }    }}

 

http://www.cnblogs.com/laoniu85/p/5224079.html