Redis在SpringBoot 2.0中的整合

2018-04-18

earth

JAVA

今天开始给大家分享Java相关的技术开发知识，在以后的开发和学习中，还希望大家多多指教，对于我发表的相关内容，如有错误，请大家指出来，一起学习。更要记住这句话：Stay Hungry, Stay Foolish.

一、Redis的安装

为了方便教程这里先简单介绍Redis的安装。

1. windows平台的安装

现在官网已经不提供windows平台的下载，所以只能去github上下载安装 github下载网址进入之后选择好版本点击msi下载 Redis 然后双击安装。默认是直接运行的。可以通过控制台访问如 Redis 具体语法可以在相关网上查阅。 ### 2. Linux平台的安装直接到官网下载 Redis.io 解压并安装

wget http://download.redis.io/releases/redis-4.0.9.tar.gz
tar xzf redis-4.0.9.tar.gz
cd redis-4.0.9
make

服务端运行脚本

1	src/redis-server

客户端运行脚本

1	src/redis-cli

3. SpringBoot2.0相关配置

pom文件加入以下依赖

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

我这里SpringBoot的配置文件使用的是YAML。在相应环境中配置Redis ##### application-local.yml

spring:
    datasource:
        name: test
        driverClassName: com.mysql.jdbc.Driver
        url: jdbc:mysql://127.0.0.1:3306/local?useUnicode=true&characterEncoding=UTF-8
        username: root
        password: root
    redis:
          database: 0
          host: localhost
          port: 6379
          jedis:
            pool:
              min-idle: 0
              max-idle: 8
              max-active: 8
              max-wait: -1ms

4.代码级别配置

import com.xxx.controller.entry.entity.AccessToken;
import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.cache.annotation.EnableCaching;
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.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.convert.KeyspaceConfiguration;
import org.springframework.data.redis.repository.configuration.EnableRedisRepositories;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

import java.util.Collections;

/**
 * @Author ：yaxuSong
 * @Description:
 * @Date: 18:35 2018/4/17
 * @Modified by:
 */
@Configuration
@EnableCaching
//增加Respository支持，并使其支持@TimeToLive
@EnableRedisRepositories(keyspaceConfiguration = RedisCacheConfig.MyKeyspaceConfiguration.class)
public class RedisCacheConfig extends CachingConfigurerSupport{

    @Bean
    public RedisCacheManager cacheManager(RedisConnectionFactory connectionFactory) {
        return RedisCacheManager.builder(connectionFactory).build();
    }

//    @Bean
//    public RedisConnectionFactory connectionFactory() {
//        return new JedisConnectionFactory();
//    }

    @Bean
    public RedisTemplate<?, ?> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        RedisTemplate<byte[], byte[]> template = new RedisTemplate<byte[], byte[]>();
        template.setConnectionFactory(redisConnectionFactory);
        return template;
    }

//    @Bean
//    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory){
//        RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<Object, Object>();
//        redisTemplate.setConnectionFactory(redisConnectionFactory);
//        redisTemplate.setKeySerializer(new StringRedisSerializer());//key序列化
//        redisTemplate.setValueSerializer(new Jackson2JsonRedisSerializer(Object.class));  //value序列化
//        redisTemplate.afterPropertiesSet();
//        return redisTemplate;
//    }

    public static class MyKeyspaceConfiguration extends KeyspaceConfiguration {

        @Override
        protected Iterable<KeyspaceSettings> initialConfiguration() {
            return Collections.singleton(new KeyspaceSettings(AccessToken.class, "accessToken"));
        }
    }
}

缓存对象AccessToken

import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.redis.core.RedisHash;
import org.springframework.data.redis.core.TimeToLive;

/**
 * @Author ：yaxuSong
 * @Description:
 * @Date: 14:26 2018/4/18
 * @Modified by:
 */
@RedisHash("accessToken")
@Data
public class AccessToken {
    @Id
    String id;
    String accessToken;
    @TimeToLive
    Long expire;
}

创建Respository

import com.xxx.controller.entry.entity.AccessToken;
import org.springframework.data.repository.CrudRepository;
import org.springframework.stereotype.Repository;

/**
 * @Author ：yaxuSong
 * @Description:
 * @Date: 14:34 2018/4/18
 * @Modified by:
 */
@Repository
// 继承自CURD，里边有最基本的方法
public interface AccessTokenRepository extends CrudRepository<AccessToken, String> {

}

接下来完成自己的业务服务类

import com.xxx.controller.entry.entity.AccessToken;

/**
 * @Author ：yaxuSong
 * @Description:
 * @Date: 14:50 2018/4/18
 * @Modified by:
 */
public interface AccessTokenService {

    AccessToken save(AccessToken accessToken);

    void delete(AccessToken accessToken);

    AccessToken get(String id);
}

业务服务类的实现

import com.xxx.controller.entry.entity.AccessToken;
import com.xxx.dao.repository.AccessTokenRepository;
import com.xxx.service.AccessTokenService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.Optional;

/**
 * @Author ：yaxuSong
 * @Description:
 * @Date: 14:52 2018/4/18
 * @Modified by:
 */
@Service("accessTokenService")
public class AccessTokenServiceImpl implements AccessTokenService {

    @Autowired
    private AccessTokenRepository repo;

    @Override
    public AccessToken save(AccessToken accessToken) {
        return  repo.save(accessToken);
    }

    @Override
    public void delete(AccessToken accessToken) {
        repo.delete(accessToken);
    }

    @Override
    public AccessToken get(String id) {
        Optional<AccessToken> accessToken = repo.findById(id);
        return accessToken.orElse(null);
    }
}

以上完成了整个整合过程。 ### 5. 简单的测试

import com.xxx.controller.entry.entity.AccessToken;
import com.xxx.service.AccessTokenService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @Author ：yaxuSong
 * @Description:
 * @Date: 15:16 2018/4/18
 * @Modified by:
 */
@RestController
@RequestMapping("test")
public class TestController {

    @Autowired
    private AccessTokenService accessTokenService;

    @RequestMapping("add")
    public String test(){
        AccessToken accessToken = new AccessToken();
        accessToken.setAccessToken("dadaadadsdadewqeqfskksdbfdbkfsdkdajdhwke2elhsbcslc/DNDAWDAWWAFEWFSD23E2342");
        accessToken.setExpire(60L);
		//单位 秒
        AccessToken at = accessTokenService.save(accessToken);
        return "成功"+"键值为："+at.getId();
    }
    @RequestMapping("get")
    public String get(String id){
        AccessToken accessToken = accessTokenService.get(id);
        return accessToken==null?"已过期":accessToken.toString();
    }
}