【server】springboot 整合 redis

1、redis 使用模式

1.1 单机模式

1.1.1 编译安装方式

1.1.1.1 下载

Redis的安装非常简单，到Redis的官网（Downloads - Redis），下载对应的版本，简单几个命令安装即可。

1.1.1.2 编译安装

tar xzf redis-stable.tar.gz
cd redis-stable/
make & make install

安装完成后

cd /usr/local/bin/

1.1.1.3 安装常见问题

如果执行make命令报错：cc 未找到命令，原因是虚拟机系统中缺少gcc，执行下面命令安装gcc：

yum -y install gcc automake autoconf libtool make

如果执行make命令报错：致命错误:jemalloc/jemalloc.h: 没有那个文件或目录，则需要在make指定分配器为libc。执行下面命令即可正常编译：

make MALLOC=libc

1.1.1.4 redis单机启动

Redis编译完成后，会生成几个可执行文件，这些文件各有各的作用，我们现在先简单了解下，后面的课程会陆续说到和使用这些可执行文件。

1.1.1.4.1 默认启动

使用Redis的默认配置来启动，在bin目录下直接输入 ./redis-server

可以看到直接使用redis-server启动Redis后，会打印出一些日志，通过日志可以看到一些信息：

当前的Redis版本的是64位的6.2.7，默认端口是6379。Redis建议要使用配置文件来启动。

因为直接启动无法自定义配置，所以这种方式是不会在生产环境中使用的。

1.1.1.4.2 带参启动

redis-server加上要修改配置名和值(可以是多对)，没有设置的配置将使用默认配置，例如：如果要用6380作为端口启动Redis，那么可以执行:

./redis-server --port 6380

这种方式一般我们也用得比较少。

1.1.1.4.3 配置文件启动

配置文件是我们启动的最多的模式，配置文件安装目录中有

一般会采用将redis.conf cp 到一个新文件夹的方式，并使用./redis-server <path>/redis.conf

的形式来开启一台新的redis 服务器

1.1.2 docker 安装方式

1.1.2.1 下载

docker pull redis

1.1.2.2 配置

mkdir -p /mydata/redis/conf
touch /mydata/redis/conf/redis.conf

#bind 127.0.0.1 #注释掉这部分，这是限制redis只能本地访问
#bind 127.0.0.1
#protected-mode no #默认yes，开启保护模式，限制为本地访问
protected-mode no
#daemonize no#默认no，改为yes意为以守护进程方式启动，可后台运行，除非kill进程，改为yes会使配置文件方式启动redis失败
daemonize no
#appendonly yes #redis持久化（可选）
appendonly yes#主从复制，从读
replica-read-only yesrequirepass admin123# min-replicas-to-write 3
# min-replicas-max-lag 10

1.1.2.3 启动

docker run -p 6379:6379 --name redis -v /mydata/redis/data:/data \
-v /mydata/redis/conf/:/etc/redis/ \
--restart=always \
-d redis --appendonly yes

1.2 主从模式

主从模式与哨兵模式的区别为，哨兵模式需要另外启动3个哨兵

1.2.1 配置

daemonize yes
#bind 127.0.0.1
protected-mode no
port 6380
appendonly yes
dir /mydata/redis/6380/dumpfiles
pidfile /var/run/redis_6380.pid
logfile "/mydata/redis-cluster/6380/redis.log"
requirepass 111111
#从机需要配置，主机不用
masterauth "111111"
replicaof 192.168.10.131 6380
#移除高危操作键
rename-command keys ""
rename-command flushdb ""
rename-command flushall ""

1.2.2 启动服务器

#主机先启动， 再启动从机
redis-server /mydata/redis-cluster/6380/redis.conf
redis-server /mydata/redis-cluster/6381/redis.conf
redis-server /mydata/redis-cluster/6382/redis.conf

1.2.3 检查结果

# 进入客户端
redis-cli -h 127.0.0.1 -p 6380 -a 111111
redis-cli -h 127.0.0.1 -p 6381 -a 111111
redis-cli -h 127.0.0.1 -p 6382 -a 111111

1.3 哨兵模式

1.3.1 sentinel 配置

bind 0.0.0.0
#是否以后台daemon方式运行
daemonize yes
#安全保护模式
protected-mode no
# 端口
port 26379
#日志文件
logfile "/mydata/redis-cluster/26379/sentinel.log"
#pid文件路径
pidfile /var/run/redis-sentinel26379.pid
#工作目录
dir /mydata/redis-cluster/26379
# sentinel monitor <master-name> <ip> <redis-port> <quorum> 
#设置要监控的master服务器，quorum 表示最少要有几个哨兵认可下线，同意故障迁移的票数
sentinel monitor mymaster 192.168.10.131 6380 2
#连接master服务的密码
sentinel auth-pass mymaster 111111

1.3.2 启动哨兵

redis-sentinel /mydata/redis-cluster/26379/sentinel.conf  --sentinel
redis-sentinel /mydata/redis-cluster/26380/sentinel.conf  --sentinel
redis-sentinel /mydata/redis-cluster/26381/sentinel.conf  --sentinel

1.3.3 检查状态

#查看进程情况
ps -ef | grep redis
#查看单机情况
#登录客户端
redis-cli -p 6380 -a 111111
#查看详情
info replication

1.4 集群模式

1.4.1 集群模式配置

#87行
#bind 127.0.0.1
#309行
daemonize yes
#111行
protected-mode no
#138行
port 6381
#341行
pidfile /mydata/redis-cluster/6381/redis.pid
#355行
logfile "/mydata/redis-cluster/6381/cluster.log"
#510行
dir /mydata/redis-cluster/6381/dumpfiles
#1387行
appendonly yes
#539 540行
requirepass 111111
masterauth 111111
# 1584 1592 1598 行  
cluster-enabled yes
cluster-config-file /mydata/redis-cluster/6379/nodes.conf
cluster-node-timeout 5000
#移除高危操作键
rename-command keys ""
rename-command flushdb ""
rename-command flushall ""

1.4.2 启动服务器

# 各自启动主机
redis-server /mydata/redis-cluster/6580/redis.conf
...
#构建集群关系
redis-cli -a 111111 --cluster create --cluster-replicas 1 192.168.10.131:6580 192.168.10.131:6581 192.168.10.131:6582 192.168.10.131:6583 192.168.10.131:6584 192.168.10.131:6585

1.4.3 集群使用

#连接客户端 后面添加 -c 用来自动确认对应slot
#不加 -c 异常
# (error) MOVED 12706 192.168.10.131:6582
redis-cli -h 192.168.10.131 -p 6580 -a 111111 -c 
# 查看某个Key 所在的slot
cluster keyslot k1
#master节点下线后，slave 会切换为master ，原master 会以 slave的方式回归
#手动切换从属关系
cluster failover
# 检查集群状态
redis-cli -a 111111 --cluster check 192.168.10.131:6580

2、整合

2.1 主从模式

与哨兵模式一致

2.2 哨兵模式

2.2.1 POM.XML

<!--redis-->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId>
</dependency>

2.2.2 application.yml

spring:data:redis:lettuce:pool:enabled: truemax-active: 8max-idle: 8min-idle: 0max-wait: -1mssentinel:master: mymasternodes:- 192.168.10.131:26379- 192.168.10.131:26380- 192.168.10.131:26381database: 0password: 111111

2.2.3 添加RedisConfig类

@Configuration
public class RedisConfig {@Bean@ConditionalOnMissingBeanpublic RedisTemplate<String, Object> redisTemplate(LettuceConnectionFactory redisConnectionFactory) {RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();redisTemplate.setConnectionFactory(redisConnectionFactory);//设置key序列化方式stringredisTemplate.setKeySerializer(new StringRedisSerializer());//设置value的序列化方式json，使用GenericJackson2JsonRedisSerializer替换默认序列化redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());redisTemplate.setHashKeySerializer(new StringRedisSerializer());redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());redisTemplate.afterPropertiesSet();return redisTemplate;}/*** 增加部分* 读写分离* @return*/@Beanpublic LettuceClientConfigurationBuilderCustomizer clientConfigurationBuilderCustomizer() {return clientConfigurationBuilder -> clientConfigurationBuilder.readFrom(ReadFrom.REPLICA);}}

业务类查阅集群模式2.3.4

2.3 集群模式

2.3.1 POM.XML

<!--redis-->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId>
</dependency>

2.3.2 application.yml

server:port: 7777
spring:application:name: redis-demodata:redis:cluster:nodes:- 192.168.10.131:6580- 192.168.10.131:6581- 192.168.10.131:6582- 192.168.10.131:6583- 192.168.10.131:6584- 192.168.10.131:6585max-redirects: 3password: 111111database: 0lettuce:pool:max-active: 8max-wait: -1msmax-idle: 8min-idle: 0cluster:refresh:#支持集群拓扑动态感应刷新,自适应拓扑刷新是否使用所有可用的更新，默认false关闭adaptive: true#定时刷新period: 2000ms

2.3.3 添加Redis.config 类

@Configuration
public class RedisConfig {@Beanpublic RedisTemplate<String, Object> redisTemplate(LettuceConnectionFactory redisConnectionFactory) {RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();redisTemplate.setConnectionFactory(redisConnectionFactory);//设置key序列化方式stringredisTemplate.setKeySerializer(new StringRedisSerializer());//设置value的序列化方式json，使用GenericJackson2JsonRedisSerializer替换默认序列化redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());redisTemplate.setHashKeySerializer(new StringRedisSerializer());redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());redisTemplate.afterPropertiesSet();return redisTemplate;}
}

2.3.4 业务类

2.3.4.1 service

#service
public interface OrderService {/***  创建订单 key* @param key* @return*/void createOrder(String key);public String getOrder(String key);
}#serviceImpl
@Service
@Slf4j
public class OrderServiceImpl implements OrderService {public static final String ORDER_KEY = "order:";@Resourceprivate RedisTemplate<String, Object> redisTemplate;@Overridepublic void createOrder(String key) {String orderNo = UUID.randomUUID().toString();redisTemplate.opsForValue().set(ORDER_KEY + key, orderNo);log.info("=====>编号" + key + "的订单流水生成:{}", orderNo);}@Overridepublic String getOrder(String key) {return Objects.requireNonNull(redisTemplate.opsForValue().get(ORDER_KEY + key)).toString();}
}

2.3.4.2 controller

@RestController
@RequestMapping("/lettuce")
@Slf4j
public class Demo {@Resourceprivate OrderService orderService;@GetMapping("/create")public String createOrder() {String key = UUID.randomUUID().toString();orderService.createOrder(key);return key;}@GetMapping("/get/{key}")public String getOrder(@PathVariable("key") String key) {return orderService.getOrder(key);}}

2.3.5故障

Redis Cluster集群部署采用了3主3从拓扑结构，数据读写访问master节点， slave节点负责备份。

当master宕机主从切换成功，redis手动OK，but 2个经典故障

问题的解决方案为：

添加定时刷新参数

spring:data:redis:lettuce:cluster:refresh:#支持集群拓扑动态感应刷新,自适应拓扑刷新是否使用所有可用的更新，默认false关闭adaptive: true#定时刷新period: 2000ms