Springboot緩存實現（redis_sentinel版實現）

Sentinel含義

Sentinel版是master/slave集羣的加強版，sentinel自己是哨兵的意思，常規的master/slave集羣中一旦master節點宕機，整個集羣也就不能提供服務了。但sentinel版的出現，就是爲了解決這個問題，當master宕機的時候，會自動從slave節點中選舉新的master節點，以繼續工做。

redis_sintinel配置

本實例中採用windows版1master+2slave+3sentinel配置。

master節點redis配置：

port 6379

bind 127.0.0.1

複製兩個redis.conf文件，做爲slave節點的配置：

redis6380.conf：

port 6380

bind 127.0.0.1

slaveof 127.0.0.1 6379 --指定主節點IP+port

 

redis6381.conf：

port 6381

bind 127.0.0.1

slaveof 127.0.0.1 6379  --指定主節點IP+port

Sentinel節點配置：

在redis文件夾中加入sentinel26379.conf、sentinel26380.conf、sentinel26381.conf三個文件。

配置以sentinel26379.conf爲例：

port 26379

#告訴sentinel去監聽地址爲ip:port的一個master，mymaster指的是master節點的名字，

#能夠自定義。2指的是有多少個slave認爲master節點失效，才真正認爲master以失效。

sentinel monitor mymaster 127.0.0.1 6379 2

#這個配置項指定了須要多少失效時間，一個master纔會被這個sentinel主觀地認爲是不可

#用的。 單位是毫秒，默認爲30秒。

sentinel down-after-milliseconds mymaster 30000

#這個配置項指定了在發生failover主備切換時最多能夠有多少個slave同時對新的master

#進行 同步，這個數字越小，完成failover所需的時間就越長，可是若是這個數字越大，就

#意味着越 多的slave由於replication而不可用。能夠經過將這個值設爲 1 來保證每次只有一#個slave 處於不能處理命令請求的狀態。

sentinel parallel-syncs mymaster 1

 

sentinel26380.conf、sentinel26381.conf配置與sentinel26379.conf相似。

啓動redis：

> redis-server.exe redis.conf

> redis-server.exe redis6380.conf

> redis-server.exe redis6381.conf

啓動sentinel：

> redis-server.exe sentinel26379.conf --sentinel

> redis-server.exe sentinel26380.conf --sentinel

> redis-server.exe sentinel26381.conf --sentinel

Springboot+redis(sentinel)實例

Pom.xml:

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>cn.sunzy.springcache</groupId>
    <artifactId>springcache</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.2.RELEASE</version>
    </parent>

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

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

 

RedisSentinelConfig：主要生產RedisTemplate實例，注入到容器。

 

import org.springframework.cache.annotation.EnableCaching;
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.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import java.util.Arrays;

@Configuration
@EnableCaching
public class RedisSentinelConfig {

    private LettuceConnectionFactory getConncetionFactory() {
        RedisSentinelConfiguration redisSentinelConfiguration = new RedisSentinelConfiguration();
        redisSentinelConfiguration.setPassword("");
        redisSentinelConfiguration.setMaster("mymaster");

        RedisNode[] redisNodes = new RedisNode[3];
        redisNodes[0] = new RedisNode("127.0.0.1",26379);
        redisNodes[1] = new RedisNode("127.0.0.1",26380);
        redisNodes[2] = new RedisNode("127.0.0.1",26381);
        redisSentinelConfiguration.setSentinels(Arrays.asList(redisNodes));

        LettuceConnectionFactory lettuceConnectionFactory = new LettuceConnectionFactory(redisSentinelConfiguration);
        return lettuceConnectionFactory;
    }

    @Bean
    public RedisTemplate<String ,Object> getRedisTemplate() {
        RedisTemplate<String,Object> redisTemplate = null;
        RedisConnectionFactory redisConnectionFactory = getConncetionFactory();
        if(redisConnectionFactory != null) {
            redisTemplate = new RedisTemplate<>();
            redisTemplate.setConnectionFactory(redisConnectionFactory);
            redisTemplate.setKeySerializer(new StringRedisSerializer());
            redisTemplate.setValueSerializer(new StringRedisSerializer());
            redisTemplate.afterPropertiesSet();
        }

        return redisTemplate;
    }
}

 

CacheController：一個demo使用例子。

 

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.concurrent.TimeUnit;

@RestController
public class CacheController {

    @Autowired
    private RedisTemplate<String,String> redisTemplate;

    @RequestMapping("/set")
    public void set() {
        redisTemplate.opsForValue().set("a","1");
        // 設置失效時間
        redisTemplate.expire("a",10, TimeUnit.SECONDS);
    }

    @RequestMapping("/get")
    public String get() {
        return redisTemplate.opsForValue().get("a").toString();
    }
}

 

App：啓動springboot主類

 

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class App {
    public static void main(String[] args) {
        SpringApplication.run(App.class,args);
    }
}