sentinel myid 8d992c54df8f8677b0b345825f61fb733c73d14c

sentinel deny-scripts-reconfig yes

sentinel monitor mymaster 127.0.0.1 6379 2

sentinel down-after-milliseconds mymaster 10000

# Generated by CONFIG REWRITE

protected-mode no

port 26379

user default on nopass ~* +@all

dir "/Users/kimmking/kimmking/JavaCourseCodes/08cache/ha/conf"

sentinel config-epoch mymaster 2

sentinel leader-epoch mymaster 2

sentinel known-replica mymaster 127.0.0.1 6380

sentinel known-sentinel mymaster 127.0.0.1 26380 8d992c54df8f8677b0b345825f61fb733c73d14d

sentinel current-epoch 2

sentinel myid 8d992c54df8f8677b0b345825f61fb733c73d14d

sentinel deny-scripts-reconfig yes

sentinel monitor mymaster 127.0.0.1 6379 2

sentinel down-after-milliseconds mymaster 10000

# Generated by CONFIG REWRITE

protected-mode no

port 26380

user default on nopass ~* +@all

dir "/Users/kimmking/kimmking/JavaCourseCodes/08cache/ha/conf"

sentinel config-epoch mymaster 2

sentinel leader-epoch mymaster 2

sentinel known-replica mymaster 127.0.0.1 6380

sentinel known-sentinel mymaster 127.0.0.1 26379 8d992c54df8f8677b0b345825f61fb733c73d14c

sentinel current-epoch 2

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">

<modelVersion>4.0.0</modelVersion>

<parent>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-parent</artifactId>

<version>2.0.9.RELEASE</version>

<relativePath/> <!-- lookup parent from repository -->

</parent>

<groupId>io.kimmking.08cache</groupId>

<artifactId>redis</artifactId>

<version>0.0.1-SNAPSHOT</version>

<name>redis</name>

<description>Demo project for Spring Boot</description>

<properties>

<java.version>1.8</java.version>

</properties>

<dependencies>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter</artifactId>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-web</artifactId>

</dependency>

<dependency>

<groupId>org.projectlombok</groupId>

<artifactId>lombok</artifactId>

</dependency>

<dependency>

<groupId>redis.clients</groupId>

<artifactId>jedis</artifactId>

</dependency>

<dependency>

<groupId>com.alibaba</groupId>

<artifactId>fastjson</artifactId>

<version>1.2.70</version>

</dependency>

<dependency>

<groupId>org.redisson</groupId>

<artifactId>redisson-spring-boot-starter</artifactId>

<version>3.14.1</version>

</dependency>

<dependency>

<groupId>com.hazelcast</groupId>

<artifactId>hazelcast</artifactId>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-data-redis</artifactId>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-test</artifactId>

<scope>test</scope>

<exclusions>

<exclusion>

<groupId>org.junit.vintage</groupId>

<artifactId>junit-vintage-engine</artifactId>

</exclusion>

</exclusions>

</dependency>

</dependencies>

<build>

<plugins>

<plugin>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-maven-plugin</artifactId>

</plugin>

</plugins>

</build>

</project>

package io.kimmking.cache;

import lombok.SneakyThrows;

import redis.clients.jedis.HostAndPort;

import redis.clients.jedis.JedisCluster;

import redis.clients.jedis.JedisPoolConfig;

import java.util.HashSet;

import java.util.Set;

public final class ClusterJedis {

private static JedisCluster CLUSTER = createJedisCluster();

private static JedisCluster createJedisCluster() {

JedisCluster jedisCluster = null;

// 添加集群的服务节点Set集合

Set<HostAndPort> hostAndPortsSet = new HashSet<HostAndPort>();

// 添加节点

hostAndPortsSet.add(new HostAndPort("127.0.0.1", 6379));

hostAndPortsSet.add(new HostAndPort("127.0.0.1", 6380));

// Jedis连接池配置

JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();

// 最大空闲连接数, 默认8个

jedisPoolConfig.setMaxIdle(12);

// 最大连接数, 默认8个

jedisPoolConfig.setMaxTotal(16);

//最小空闲连接数, 默认0

jedisPoolConfig.setMinIdle(4);

// 获取连接时的最大等待毫秒数(如果设置为阻塞时BlockWhenExhausted),如果超时就抛异常, 小于零:阻塞不确定的时间, 默认-1

jedisPoolConfig.setMaxWaitMillis(2000); // 设置2秒

//对拿到的connection进行validateObject校验

jedisPoolConfig.setTestOnBorrow(true);

jedisCluster = new JedisCluster(hostAndPortsSet, jedisPoolConfig);

return jedisCluster;

}

public static JedisCluster getJedisCluster() {

return CLUSTER;

}

@SneakyThrows

public static void close(){

CLUSTER.close();

}

}

package io.kimmking.cache;

import com.alibaba.fastjson.JSON;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import redis.clients.jedis.Jedis;

import redis.clients.jedis.JedisCluster;

import java.util.List;

import java.util.Map;

@SpringBootApplication(scanBasePackages = "io.kimmking.cache")

public class RedisApplication {

public static void main(String[] args) {

// C1.最简单demo

Jedis jedis = new Jedis("localhost", 6379);

System.out.println(jedis.info());

jedis.set("uptime", new Long(System.currentTimeMillis()).toString());

System.out.println(jedis.get("uptime"));

// C2.基于sentinel和连接池的demo

// C3. 直接连接sentinel进行操作

// 作业：

// 1. 参考C2，实现基于Lettuce和Redission的Sentinel配置

// 2. 实现springboot/spring data redis的sentinel配置

// 3. 使用jedis命令，使用java代码手动切换 redis 主从

// Jedis jedis1 = new Jedis("localhost", 6379);

// jedis1.info...

// jedis1.set xxx...

// Jedis jedis2 = new Jedis("localhost", 6380);

// jedis2.slaveof...

// jedis2.get xxx

// 4. 使用C3的方式，使用java代码手动操作sentinel

// C4. Cluster

// 作业：

// 5.使用命令行配置cluster:

// 1) 以cluster方式启动redis-server

// 2) 添加cluster节点，确认集群节点数目

// 3) 分配槽位，确认分配成功

// 4) 测试简单的get/set是否成功

// 然后运行如下代码

//SpringApplication.run(RedisApplication.class, args);

}

}

package io.kimmking.cache;

import redis.clients.jedis.HostAndPort;

import redis.clients.jedis.Jedis;

import redis.clients.jedis.JedisPoolConfig;

import redis.clients.jedis.JedisSentinelPool;

import java.util.HashSet;

import java.util.Set;

public final class SentinelJedis {

//可用连接实例的最大数目，默认为8；

//如果赋值为-1，则表示不限制，如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)

private static Integer MAX_TOTAL = 16;

//控制一个pool最多有多少个状态为idle(空闲)的jedis实例，默认值是8

private static Integer MAX_IDLE = 12;

//等待可用连接的最大时间，单位是毫秒，默认值为-1，表示永不超时。

//如果超过等待时间，则直接抛出JedisConnectionException

private static Integer MAX_WAIT_MILLIS = 10000;

//客户端超时时间配置

private static Integer TIMEOUT = 10000;

//在borrow(用)一个jedis实例时，是否提前进行validate(验证)操作；

//如果为true，则得到的jedis实例均是可用的

private static Boolean TEST_ON_BORROW = true;

//在空闲时检查有效性, 默认false

private static Boolean TEST_WHILE_IDLE = true;

//是否进行有效性检查

private static Boolean TEST_ON_RETURN = true;

private static JedisSentinelPool POOL = createJedisPool();

/**

private static JedisSentinelPool createJedisPool() {

JedisPoolConfig config = new JedisPoolConfig();

/*注意：

config.setMaxTotal(MAX_TOTAL);

config.setMaxIdle(MAX_IDLE);

config.setMaxWaitMillis(MAX_WAIT_MILLIS);

config.setTestOnBorrow(TEST_ON_BORROW);

config.setTestWhileIdle(TEST_WHILE_IDLE);

config.setTestOnReturn(TEST_ON_RETURN);

String masterName = "mymaster";

Set<String> sentinels = new HashSet<String>();

sentinels.add(new HostAndPort("127.0.0.1",26379).toString());

sentinels.add(new HostAndPort("127.0.0.1",26380).toString());

JedisSentinelPool pool = new JedisSentinelPool(masterName, sentinels, config, TIMEOUT, null);

return pool;

}

public static Jedis getJedis() {

return POOL.getResource();

}

public static void close(){

POOL.close();

}

}

package io.kimmking.cache.controller;

import io.kimmking.cache.entity.User;

import org.springframework.boot.autoconfigure.EnableAutoConfiguration;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

import java.util.Arrays;

import java.util.List;

public class UserController {

@RequestMapping("/user/find")

User find(Integer id) {

return new User(1,"KK", 28);

}

@RequestMapping("/user/list")

List<User> list() {

return Arrays.asList(new User(1,"KK", 28),

new User(2,"CC", 18));

}

}

package io.kimmking.cache.entity;

import lombok.AllArgsConstructor;

import lombok.Data;

import lombok.NoArgsConstructor;

public class User {

private Integer id;

private String name;

private Integer age;

}