Redis03

一、主从复制

一主二从

主机：master 读写

从机：slave 只读

redis.conf配置文件
requirepass 123456
masterauth 123456
​
​
​
docker run -id -p 6379:6379 --name redis7.2 -v  /opt/redis/redis.conf:/usr/local/bin/redis.conf -v  /usr/local/docker/data:/data  redis:7.0.2  redis-server /usr/local/bin/redis.conf
​
docker run -id -p 6380:6379 --name redis7.22 -v  /opt/redis/redis2.conf:/usr/local/bin/redis.conf -v  /usr/local/docker/data2:/data  redis:7.0.2  redis-server /usr/local/bin/redis.conf
​
docker run -id -p 6381:6379 --name redis7.23 -v  /opt/redis/redis3.conf:/usr/local/bin/redis.conf -v  /usr/local/docker/data3:/data  redis:7.0.2  redis-server /usr/local/bin/redis.conf

默认情况下，直接启动，三台服务，三台服务都是master主机。

实现主从复制、读写分离

选6379为master，

在6380 和 6381上，分别执行slaveof ip 6379 ，让当前主机为slave从机，让6379为master主机。

测试：

1、防火墙开放端口

firewall-cmd --zone=public --add-port=6379-6381/tcp --permanent

2、云服务器网络安全组放行（腾讯防火墙放行）

6379 6380 5381

3、重启docker容器

systemctl restart docker

4、依次启动三个容器，在从机上守护主机

docker start redis7.2

docker start redis7.22

docker start redis7.23

客户端连接：

redis-cli -h ip -p 6380 -a 123456
slaveof  ip 6379
info replication

主从切换（反客为主）

主机故障，从机变主机的过程。

手动切换

在从机上执行

slaveof no one   让自己变为master
其他服务器守护新的主机
slaveof ip port

哨兵模式

可以实现自动故障切换。

二、springboot整合redis

1、添加依赖

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

2、添加配置

spring:redis:host: 1.94.230.82port: 6381password: 123456database: 0

3、使用模版工具类完成redis的增删改查

package com.hl.mybatis03.web;
​
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;
​
@RestController
@RequestMapping("/redis")
public class RedisTest {@Autowiredprivate RedisTemplate redisTemplate;
​@RequestMapping("/test1")public Object test1(){//新增redisTemplate.opsForValue().set("name", "zhangsan");//查询return redisTemplate.opsForValue().get("name");}
​
}

4、测试

5、redis 序列化及常用方法

@SpringBootApplication
public class Mybatis03Application {
​@Beanpublic RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory) {RedisTemplate<String, String> template = new RedisTemplate<>();template.setConnectionFactory(factory);template.setKeySerializer(new StringRedisSerializer());template.setValueSerializer(new GenericJackson2JsonRedisSerializer()); // 必须为 String 序列化return template;}

package com.hl.mybatis03.web;
​
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
​
import java.util.ArrayList;
import java.util.List;
​
@RestController
@RequestMapping("/redis")
public class RedisTest {@Autowiredprivate RedisTemplate redisTemplate;@Autowiredprivate StringRedisTemplate stringRedisTemplate;
​@RequestMapping("/test1")public Object test1(){//新增 修改redisTemplate.opsForValue().set("name", "zhangsan");redisTemplate.opsForValue().set("age",20);List list = new ArrayList();list.add("beijing");list.add("nanjing");list.add("bianjing");redisTemplate.opsForValue().set("list",list);
​redisTemplate.opsForValue().increment("age");//自增加1redisTemplate.opsForValue().increment("age",10); //自增长度  自定义
​redisTemplate.opsForValue().append("name"," hello! "); //追加内容
​String name = (String)redisTemplate.opsForValue().get("name");System.out.println(name.length());
​redisTemplate.opsForValue().getAndDelete("list");
​
​return null;}
​
}

6、springboot+mysql+redis 业务整合

@Service
public class QueenServiceImpl implements QueenService{@Autowiredprivate RedisTemplate redisTemplate;@Autowiredprivate QueenMapper queenMapper;@Overridepublic List<Queen> getQueens() {Object obj = redisTemplate.opsForValue().get("queen");List<Queen> list = null;if(obj !=null ){list = (List<Queen>)obj;}else{list = queenMapper.getQueens();redisTemplate.opsForValue().set("queen",list);}
​return list;}
}