springboo-redis详解编程语言

<dependency> 
            <groupId>org.springframework.boot</groupId> 
            <artifactId>spring-boot-starter-redis</artifactId> 
</dependency>

package com.mlxs.springboot05.redis; 
 
 
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; 
import java.util.HashMap; 
import java.util.Map; 
 
/** 
 * RedisConfig类描述: redis配置类 
 * 
 * @author yangzhenlong 
 * @since 2017/2/16 
 */ 
@Configuration 
@EnableCaching 
public class RedisConfig extends CachingConfigurerSupport{ 
 
    /** 
     * key生成策略 
     * @return 
     */ 
    @Bean 
    public KeyGenerator keyGenerator(){ 
        return new KeyGenerator() { 
            @Override 
            public String generate(Object targetClass, Method targetMethod, Object... params) { 
                StringBuffer stringBuffer = new StringBuffer(); 
                stringBuffer.append(targetClass.getClass().getName()); 
                stringBuffer.append("." + targetMethod.getName()); 
                for (Object param : params){ 
                    stringBuffer.append("_" + param.toString()); 
                } 
 
                return stringBuffer.toString(); 
            } 
        }; 
    } 
 
    /** 
     * redis缓存配置 
     * @param redisTemplate 
     * @return 
     */ 
    @Bean 
    public CacheManager cacheManager(RedisTemplate redisTemplate){ 
        RedisCacheManager redisCacheManager = new RedisCacheManager(redisTemplate); 
        redisCacheManager.setDefaultExpiration(60 * 5);//设置过期时间 单位：秒 
 
        Map<String, Long> expires = new HashMap<>(); 
        expires.put("test", 300L); 
        redisCacheManager.setExpires(expires);//设置value过期时间 
        return redisCacheManager; 
    } 
 
    /** 
     * 设置redisTemplate 
     * @param factory 
     * @return 
     */ 
    @Bean 
    public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory){ 
        StringRedisTemplate stringRedisTemplate = new StringRedisTemplate(factory); 
 
        //设置序列化方式 
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class); 
        ObjectMapper objectMapper = new ObjectMapper(); 
        objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); 
        objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); 
        jackson2JsonRedisSerializer.setObjectMapper(objectMapper); 
        stringRedisTemplate.setValueSerializer(jackson2JsonRedisSerializer); 
 
        stringRedisTemplate.afterPropertiesSet(); 
        return stringRedisTemplate; 
    } 
}

package com.mlxs.springboot05.redis.use01; 
 
 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.data.redis.core.RedisTemplate; 
import org.springframework.data.redis.core.ValueOperations; 
import org.springframework.stereotype.Component; 
 
import java.util.concurrent.TimeUnit; 
 
/** 
 * RedisUtil类描述: 
 * 
 * @author yangzhenlong 
 * @since 2017/2/16 
 */ 
@Component 
public class RedisUtil { 
 
    @Autowired 
    private RedisTemplate redisTemplate; 
 
    /** 
     * 根据key删除 
     * @param key 
     */ 
    public void remove(String key){ 
        if(this.isExistKey(key)){ 
            redisTemplate.delete(key); 
        } 
    } 
 
    /** 
     * 根据key批量删除 
     * @param keys 
     */ 
    public void remove(String... keys){ 
        for(String key : keys){ 
            this.remove(key); 
        } 
    } 
 
    /** 
     * 根据key判断是否存在对应的value 
     * @param key 
     * @return 
     */ 
    public boolean isExistKey(String key){ 
        return redisTemplate.hasKey(key); 
    } 
 
    /** 
     * 根据key获取值 
     * @param key 
     * @return 
     */ 
    public Object get(String key){ 
        ValueOperations valueOperations = redisTemplate.opsForValue(); 
        return valueOperations.get(key); 
    } 
 
    /** 
     * 写入缓存 
     * @param key 
     * @param value 
     * @return 
     */ 
    public boolean set(String key, Object value){ 
        try { 
            ValueOperations valueOperations = redisTemplate.opsForValue(); 
            valueOperations.set(key, value); 
            return true; 
        }catch (Exception e){ 
            e.printStackTrace(); 
            return false; 
        } 
    } 
 
    /** 
     * 写入缓存 
     * @param key 
     * @param value 
     * @param expireTime 
     * @return 
     */ 
    public boolean set(String key, Object value, Long expireTime){ 
        try { 
            ValueOperations valueOperations = redisTemplate.opsForValue(); 
            valueOperations.set(key, value); 
            redisTemplate.expire(key, expireTime, TimeUnit.SECONDS); 
            return true; 
        }catch (Exception e){ 
            e.printStackTrace(); 
            return false; 
        } 
    } 
 
}

import com.mlxs.springboot05.redis.MainApp; 
import com.mlxs.springboot05.redis.use01.RedisUtil; 
import org.junit.Test; 
import org.junit.runner.RunWith; 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.boot.test.SpringApplicationConfiguration; 
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; 
 
import java.util.Arrays; 
import java.util.List; 
 
/** 
 * Use01Test类描述: 
 * 
 * @author yangzhenlong 
 * @since 2017/2/16 
 */ 
@RunWith(SpringJUnit4ClassRunner.class) 
@SpringApplicationConfiguration(MainApp.class) 
public class Use01Test { 
 
    @Autowired 
    private RedisUtil redisUtil; 
 
    @Test 
    public void test(){ 
        //设置值 
        List<String> stringList = Arrays.asList("aaa", "bbb", "ccc"); 
        boolean setResult = redisUtil.set("strList", stringList); 
        System.out.println("保存redis结果：" + setResult); 
 
        //获取值 
        Object getResult = redisUtil.get("strList"); 
        System.out.println("查询redis结果：" + getResult); 
    } 
}

package com.mlxs.springboot05.redis.use02; 
 
 
import org.springframework.cache.annotation.Cacheable; 
import org.springframework.web.bind.annotation.PathVariable; 
import org.springframework.web.bind.annotation.RequestMapping; 
import org.springframework.web.bind.annotation.RestController; 
 
/** 
 * TestMethod类描述: 
 * 
 * @author yangzhenlong 
 * @since 2017/2/16 
 */ 
@RestController 
@RequestMapping("/redis") 
public class RedisController { 
 
    @RequestMapping("/str/{str}") 
    @Cacheable(value = "redisTest") 
    public String queryStr(@PathVariable String str){ 
        System.out.println("---请求参数---" + str); 
 
        return "queryStr return: " + str; 
    } 
}