1. 程式人生 > >Idea + Springboot 下 java 對Redis的基本操作。

Idea + Springboot 下 java 對Redis的基本操作。

一、引入redis pom依賴,程式碼如下:

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

二、建立config包,在包下建立RedisConfig類,程式碼如下:

@Configuration
@EnableCaching
public class RedisConfig {

    @Bean
    public RedisTemplate<Serializable,Object>  redisTemplate(RedisConnectionFactory redisConnectionFactory){

        RedisTemplate<Serializable,Object> template = new RedisTemplate<>();
        template.setConnectionFactory(redisConnectionFactory);
        template.afterPropertiesSet();
        template.setKeySerializer(new StringRedisSerializer());
        template.setValueSerializer(new ObjectRadisSerializer());
        return template;

    }
}

注意:

1、@Configuration和@EnableCaching註解,宣告是springboot配置類,和springboot啟動快取的,@Bean是宣告此方法是一個依賴。

2、而RedisTemplate<Serializable,Object> 是用來操作redis 的一個類,RedisConnectionFactory是用來連線redis的一個類,Serializable是可序列化物件,因為redis儲存是以二進位制形式儲存的。

3、template.afterPropertiesSet()是表面在application.properties(在下面會給出)配置檔案載入完成後再執行下面的程式。

三、application.properties配置檔案程式碼如下:

spring.redis.database=0
spring.redis.host=127.0.0.1
spring.redis.port=6379
spring.redis.password=
spring.redis.timeout=2000ms

注意這是redis資料庫的一些配置,在執行上面方法之前先執行此配置連線到redis資料庫。

四、在util包下建立一個序列化POJO物件的類ObjectRedisSerializer,程式碼如下:

public class ObjectRadisSerializer implements RedisSerializer<Object> {

    /**
     * ObjectRadisSerializer序列化VO物件的類,要實現RedisSerializer介面
     * */
    /**
    * 新建序列化和反序列化物件
    * */
    private Converter<Object,byte[]> serializer = new SerializingConverter();
    private Converter<byte[],Object> deSerializer = new DeserializingConverter();
    /***
     * 定義一個位元組空陣列
     */
    private static final byte[] EMPTY_ARRAY = new byte[0];

    /**
     * 下面為序列化方法
     * @param obj
     * @return
     * @throws SerializationException
     */
    @Override
    public byte[] serialize(Object obj) throws SerializationException {

        byte[] byteArray = null;
        if (obj == null){
            byteArray = EMPTY_ARRAY;
        }else {
            try {
                byteArray = serializer.convert(obj);
            } catch (Exception e){
                System.out.print("==============>redis序列化失敗=======");
                byteArray = EMPTY_ARRAY;
            }

        }

        return byteArray;
    }

    /**
     * 這是反序列化的方法
     * @param datas
     * @return
     * @throws SerializationException
     */
    @Override
    public Object deserialize(byte[] datas) throws SerializationException {
        Object object = null;
        if (datas == null || datas.length ==0){
            System.out.print("=================>redis待反序列化物件為空");
        }else {
            object = deSerializer.convert(datas);
        }
        return object;
    }
}

注意:要實現RedisSerializer介面,這是redis序列化的一個類。

四、建立POJO物件,此處用User,程式碼如下:

public class User implements Serializable {

    private  String id;
    private String name;
    private String password;
    private String nickname;
    private String gender;

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    public String getNickname() {
        return nickname;
    }

    public void setNickname(String nickname) {
        this.nickname = nickname;
    }

    public String getGender() {
        return gender;
    }

    public void setGender(String gender) {
        this.gender = gender;
    }
}

五、測試,程式碼如下:

 /**
     * 定義操作redis的物件redisTemplate,序列化設定值時要用set,取值要有get
     */
    @Autowired
    private RedisTemplate<Serializable,Object> redisTemplate;

    @RequestMapping("/setPOJO")
    public  String setPOJO(){
        User user = new User();
        user.setName("cjx");
        user.setPassword("123");
        user.setNickname("lhy");
        user.setGender("16");
        user.setId("001");
        redisTemplate.opsForValue().set("love",user);
        return "設定成功";
    }
    @RequestMapping("/getPOJO")
    public Object getPOJO(){
        if (!redisTemplate.hasKey("love")){
            return null;
        }else {
            return  redisTemplate.opsForValue().get("love");
        }
    }