【Redis】Redis 非关系型数据库 安装、配置、使用(全集)

目录

Redis

第一章

1、什么是redis

2、安装redis

1-7

8

3、redis使用

第二章

1、redis的使用

1、使用方式

2、使用Java代码使用redis

3、优化连接redis

2、五种数据类型

常用命令

string

hash

list

set

zset

不同数据类型存、取、遍历的方法

3、redis在项目中使用

示例

1

2

3

4

5

6-7

第三章

1、redis的作用

存在问题

1、高并发

2、缓存击穿

3、缓存雪崩

4、缓存穿透

总结

2、redis数据持久化策略

数据持久化策略有两种

方式1

方式2

区别

3、redis中的主从复制

配置步骤

第四章

1、redis的集群配置

1、配置要求

2、判断失败标准

3、配置原理

4、配置完成数据如何存储

2、准备工作

3、构建redis集群

1-5

6-11

4、测试集群

5、Java代码访问集群

示例1:与spring无关,单独访问集群

示例2:在spring中使用集群


Redis

第一章

1、理解redis的基本概念 2、安装、配置redis 3、redis的使用

1、什么是redis

redis是一种非关系型数据库,它用于存储数据提供给程序使用(c语言编写)
​
    非关系型数据(NoSql)
        它的特点:它没有数据表的概念了,它存放的数据是存放在内存中的
典型的非关系型数据库,主要有:redis,mongodb redis它是采用键、值对的方式,将数据存放在内存中
​
    关系型数据库:   sqlserver,mysql,oracle这些都是关系型数据库
    它们的特点:数据是以数据表的形式进行存储,数据是存放在数据库系统中

image-20230818105340889

非关系型数据库从内存中加载数据,速度会更快
​
关系型数据库的数据是存放在数据库系统中的,它们会更安全
​
@@@@@@在实际应用中,项目一般会将关系型数据库与非关系型数据库结合使用
​
    redis这种非关系型数据库,主要是作为缓存使用,这样可以避免频繁查询数据库,导致数据库压力过大
​

2、安装redis

步骤

1-7
@@@@@redis可以在windows中使用,也可以在linux下使用。但一般都会配置到linux下
​
1、下载redis
​
2、将它发布到linux下的 d113
​
3、安装C语言运行环境(REDIS是采用c语言编写的)
    yum install gcc-c++
​
4、将/d113目录下的redis解压缩 
​
     tar -xvPf /d113/redis-3.0.0.tar.gz  -C /usr/local/d113/
​
5、进入/usr/local/d113/redis-3.0.0目录
    
    cd /usr/local/d113/redis-3.0.0
​
6、构建redis
    make
​
7、安装redis
    make install PREFIX=/usr/local/d113/redis
​

image-20230818110507517

8
8、启动redis的服务端
    
    1、进入 /usr/local/d113/redis/bin目录 
​
        cd  /usr/local/d113/redis/bin
​
    2、准备启动redis服务器(启动有两种方式)
​
        @@@@@@@@@@前台启动
            (这种方式启动后,控制台界面就不能再编写其他代码了,需要再打开一个新的控制台窗口写代码)
​
            ./redis-server
​
​
        @@@@@@@@@后台启动(启动后,界面不会被占用,还可以继续写代码 )-------推荐使用
​
            1、进入/usr/local/d113/redis-3.0.0将redis.conf文件复制到/usr/local/d113/redis/bin目录中
                
                cp /usr/local/d113/redis-3.0.0/redis.conf  /usr/local/d113/redis/bin
​
            2、进入usr/local/d113/redis/bin目录,修改redis.conf配置,指定后台启动redis
                    
                找到配置文件  daemonize no
                修改为  daemonize yes
​
            3、进入usr/local/d113/redis/bin执行
                
                ./redis-server redis.conf
    
    3、启动客户端连接redis服务器
        1、进入目录 /usr/local/d113/redis/bin
        2、执行  ./redis-cli
​
    
    4、退出redis的客户端: exit
       
       停止redis的服务器:
        1、查看redis进程
            ps -ef | grep redis
​
        2、杀死进程
            kill -9 进程号
​
​

3、redis使用

@@@@@@redis在编辑文件时,查找指定内容的快捷键:
​
    1、vi 文件
​
    2、按下/输入要查找的内容,回车
​
    3、按字母i,开始编辑
​
    4、如果还要查找其他内容,可以先按esc 退出编辑模式,再按下/输入要查找的内容,回车
​
    5、保存退出

第二章

1、redis中的五种数据类型 2、redis的使用 3、redis的持久化策略 4、redis中的主从复制

前情摘要

@@@@@@@@@@@@@@@@@@@启动redis分为前台启动与后台启动
​
后台启动redis的步骤:
​
1、进入/usr/local/d113/redis/bin
​
2、后台启动redis
    ./redis-server redis.conf
​
3、查看redis是否启动成功
    ps -ef | grep redis
​
4、如果要停止redis
    kill -9 进程号
    
    
    
@@@@@@@@在编辑文件时,要快速查找指定内容 
​
1、vi 文件名
2、输入/要查询的内容,然后回车
3、找到内容后按字母i进行编辑
4、如果编辑完了,要再查找其他内容,只需要按esc退出编辑模式,再继续输入/内容

1、redis的使用

1、使用方式
@@@@@@@@@@@操作redis的方式主要有三种:
​
方式1、通过redis的客户端访问redis服务器
    
    1、在/usr/local/d113/redis/bin目录下输入下列命令即可连接redis客户端
        ./redis-cli
​
    2、退出redis客户端
        exit
​
​
方式2:用一个桌面管理工具,在windows中可以直接访问linux下的redis
    @@@@如果要用桌面管理工具体或者java连接redis都必须将redis的6379端口号在linux的防火墙中注册
​
    firewall-cmd --zone=public --add-port=6379/tcp --permanent
    firewall-cmd --reload
​
​
方式3:在java代码中通过jedis与redis建立连接
        @@@@@@@@@jedis:用java代码连接redis的技术
2、使用Java代码使用redis

步骤

    1、创建工程
    2、导入下列依赖
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>2.7.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-pool2</artifactId>
            <version>2.7.0</version>
        </dependency>
​
    3、编写代码 
           //创建jedis
        Jedis jedis = new Jedis("192.168.47.128",6379);
        //存数据
        //jedis.set("msg2","abc");
        //关闭jedis
        jedis.close();
​
    @@@@@@这种方式连接redis性能不好,它在连接redis的时候需要自己创建连接,用完后,连接又会被销毁,这样会导致频繁创建、销毁连接,会消耗更多资源降低程序的性能
​
    为了解决该问题,在连接redis时,我们都需要配置连接池,配置jedis连接池以后,当需要使用连接时,不需要自己创建,只需要从连接池中获得连接,用完以后,关闭资源,连接并不会真的释放。它会回到连接池,其他用户可以继续使用,这样可以避免频繁创建、销毁连接
3、优化连接redis
@@@@@@@@@@@@@采用连接池的方式操作redis

        //创建连接池的配置对象,用于设置连接池配置信息
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        //指定连接池的最小闲置连接数--------连接池最少要保证有多个闲置连接,如果没有就会马上自动创建
        jedisPoolConfig.setMinIdle(50);
        //指大最大闲置连接数
        jedisPoolConfig.setMaxIdle(100);
        //设置最大连接数
        jedisPoolConfig.setMaxTotal(200);
        //由于用完的连接并不会释放,会回到连接池,设置多余闲置连接的销毁时间
        jedisPoolConfig.setEvictorShutdownTimeoutMillis(3000);
        //设置等待连接的超时时间
        jedisPoolConfig.setMaxWaitMillis(3000);

        //创建jedis连接池
        JedisPool jedisPool = new JedisPool(jedisPoolConfig,"192.168.47.128",6379);

        //通过连接池获得jedis
        Jedis jedis = jedisPool.getResource();

        //操作redis
        jedis.set("msg3","china");

        //关闭jedis(不是真的关闭,只是让用完的连接回到连接池中)
        jedis.close();

2、五种数据类型

redis中的数据类型有五种:

	1、string-----------------字符串类型

	2、hash-------------------散列类型

	3、list-------------------列表类型

	4、set--------------------无序集合类型

	5、zset-------------------有序集合类型
常用命令
查看当有redis中有哪些键       
	keys *

清空redis中的所有数据
	flushall

删除键 
	del 键

判断当前键对应的数据类型
	type 键

给键设置过期时间(秒)
	如果不设置,键将永远存在
	expire 键  10

	注意:键必须要先存在,才能设置。键默认是永不过期

查看键的过期时间
	ttl 键 

	-1:永不过期
	-2:键已经过期
	18:当前键还可以存活18秒
string
@@@@@@@@@@string-----------------字符串类型

1、存数据
	set 键  值
	set msg hello

2、通过键取值 
	get 键
	get msg

3、一次存放多键值对
	mset 键1 值1 键2 值2
	mset k1 aa k2 bb

4、一次通过多个键取值
	mget 键1 键2
	mget k1 k2

5、判断是否存在某一个键(存在返回1,不存在返回0)
	exists 键

6、删除某一个键(成功返回1,失败返回0)
	del 键

@@@@@@@@@@@如果当前键对应的值是一个数值,则可以使用下列这一组命令

	incr 键---------------------让当前的数值加1
	decr 键---------------------让当前的数值减1
	incrby 键  5--------------- 当前值上加5
	decrby 键  5--------------- 当前值上减5

 字符串类型的数据在存放数据时,如果键已经存在,值将会被覆盖

image-20230818175654607

hash
@@@@@@@@@@@@@hash散列类型
	它存放的值是一个map类型

1、存数据:
	hset 键 字段 值
	hset stu id   1
	hset stu name jack
	hset stu score 100

	@@@@@散列结构在存放数据时,只有键与字段名都相同的时候,值才会被覆盖。如果仅仅是键相同字段名不同,它执行追加

2、取数据
	hget 键  字段
	hget stu id
	hget stu name
	hget stu score

3、一次性存放多个字段
	hmset 键  字段1 值1 字段2 值2
	hmset s2 id 1 name jack score 99

4、一次性取多个字段
	hmget 键 字段1 字段2
	hmget s2 id name score

5、获得键里面包含的所有字段名
	hkeys 键

6、获得键中包含所有的字段值
	kvals 键

7、判断键中是否包含某一个字段
	hexists 键 字段名

8、删除某一个字段
	hdel  键 字段名
list
@@@@@@@@@@list列表类型
	
	它是一种双向链表结构,它存放数据时,可以从两头进存放
	特点:
		1、有顺序
		2、可以有重复元素

1、存放数据(从左向右存放)left
	lpush 键  值1 值2 值3
	lpush list1  a  b  c

	输出:c b a

2、从右向左存放 right
	rpush 键  值1 值2 值3
	rpush list1  111  222  333

	@@@@键存在,也不会覆盖,只是追加数据
	输出:c b a 111 222 333

3、取列表中最左侧的数据(取一次,列表中就会少一个数据)
	lpop 键

4、取列表中最右侧的数据(取一次,列表中就会少一个数据)
	rpop 键

5、遍历列表的所有数据
	lrange 键  0 -1
	lrange list1 0 -1
set
@@@@@@@@set无序集合类型
	特点:1、没有顺序
	      2、不能有重复元素

1、存数据
	sadd 键 值1 值2 值3
	sadd set1 aaa bbb ccc

2、获得所有数据
	smembers 键
	smembers set1

3、判断是否包含某一个值
	sismember 键 值
	sismember set1 aaa

4、从无序集合中随机获得一个值(获得该值后,这个值就会从集合中移除)
	spop set1(适合用于抽奖)
zset
@@@@@@@@zset有序集合类型
	特点:
		1、有顺序
		2、不能有重复元素

1、存数据
	zadd 键  分数1 值1   分数2 值2 -------------它在添加数据时必须给每一个值设置一个分数,排序时按分数升序排序
	zadd zset1  100 andy 80 bruce 90 tom

2、查看所有数据(不包含分数),默认是按分数升序排序
	zrange 键 0 -1
	zrange zset1 0 -1

3、查看所有数据(包含分数),默认是按分数升序排序
	zrange 键 0 -1 withscores
	zrange zset1 0 -1 withscores

4、查看所有数据(包含分数),按分数降序排序
	zrevrange 键 0 -1 withscores                
	zrevrange zset1 0 -1 withscores
不同数据类型存、取、遍历的方法
string
	set key value
	get key

hash
	hset key 字段 值
	hget key 字段

list
	lpush 键 aa bb cc
	rpush 键 aa bb cc
	lrange 键 0 -1

set
	sadd 键  aaa bbb  ccc
	smembers  键
	spop 键

zset  
	zadd 键 分数  值1  分数 值2
	zrange 键  0 -1
	zrange 键  0 -1 withscores
	zrevrange 键  0 -1 withscores

3、redis在项目中使用

@@@@@@@@redis在项目中的使用
	redis在项目中主要是作为缓存使用,这样可以在高并发环境下,环境数据库的压力
	项目中配置了redis后的执行过程:
	
		1、当请求到达服务器,查询某一条数据时,系统会首先查询redis缓存中有没有需要数据
		2、如果缓存中没有需要的数据,系统就会查询数据库,并且把查询到结果放入缓存,然后将查询结果返回给客户端
		3、下一次当客户端再一次查询该数据时,由于缓存中已存在该数据,系统就会直接返回缓存中的数据,不再查询数据库
示例

<!--具体详情请看:redis_j54_singleton项目 -->

1、导入素材与redis无关
2、@@@加入redis实现功能
1
1、在pom.xml导入下列依赖


        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>2.7.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-pool2</artifactId>
            <version>2.7.0</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>2.7.0</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-annotations</artifactId>
            <version>2.7.0</version>
        </dependency>
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-core</artifactId>
            <version>2.7.0</version>
        </dependency>
2
2、添加配置文件 applicationContext-redis.xml

    <!--1、指定redis配置对象-->
    <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
        <!--指定连接池的最小闲置连接数连接池最少要保证有多个闲置连接,如果没有就会马上自动创建-->
        <property name="minIdle" value="50"/>
        <!--最大闲置连接数-->
        <property name="maxIdle" value="100"/>
        <!-- 设置最大连接数-->
        <property name="maxTotal" value="200"/>
        <!--由于用完的连接并不会释放,会回到连接池,设置多余闲置连接的销毁时间-->
        <property name="evictorShutdownTimeoutMillis" value="3000"/>
        <!--设置等待连接的超时时间-->
        <property name="maxWaitMillis" value="3000"/>
    </bean>

    <!--    2、配置连接池-->
    <bean id="jedisPool" class="redis.clients.jedis.JedisPool">
        <constructor-arg name="poolConfig" ref="jedisPoolConfig"/>
        <constructor-arg name="host" value="192.168.47.128"/>
        <constructor-arg name="port" value="6379"/>
    </bean>
3
3、修改web.xml加载redis的配置文件
	  <servlet>
	    <servlet-name>mvc</servlet-name>
	    <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
	    <init-param>
	      <param-name>contextConfigLocation</param-name>
	      <param-value>classpath:applicationContext*.xml</param-value>
	    </init-param>
	  </servlet>
	  <servlet-mapping>
	    <servlet-name>mvc</servlet-name>
	    <url-pattern>*.do</url-pattern>
	  </servlet-mapping>
4
4、编写redis的接口

	public interface JedisClient {
    
	    public void set(String key,String value);
	    
	    public String get(String key);
	    
	    public void hset(String key,String field,String value);
	    
	    public String hget(String key,String field );
	    
	    public void hdel(String key, String filed);
	}
5
5、编写Jedis的实现类(单机版)

	@Component
	public class JedisClientSingleImpl implements JedisClient {
	    //注入连接池
	    @Autowired
	    private JedisPool jedisPool;

	    @Override
	    public void set(String key, String value) {
		Jedis jedis = jedisPool.getResource();
		jedis.set(key,value);
		jedis.close();
	    }

	    @Override
	    public String get(String key) {
		Jedis jedis = jedisPool.getResource();
		String value = jedis.get(key);
		jedis.close();
		return value;
	    }

	    @Override
	    public void hset(String key, String field, String value) {
		Jedis jedis = jedisPool.getResource();
		jedis.hset(key,field,value);
		jedis.close();
	    }

	    @Override
	    public String hget(String key, String field) {
		Jedis jedis = jedisPool.getResource();
		String value = jedis.hget(key, field);
		jedis.close();
		return value;
	    }

	    @Override
	    public void hdel(String key, String filed) {
		Jedis jedis = jedisPool.getResource();
		jedis.hdel(key,filed);
		jedis.close();

	    }
	}
6-7
6、导入jsonUtil工具类,用于转换Json数据


7、修改Service的代码 
		
	在查询数据之前,先查询redis,如果有需要的数据,就不再查询数据库


	@Service
public class PrdServiceImpl implements PrdService {
    @Autowired
    private PrdMapper mapper;

    //注入jedis接口
    @Autowired
    private JedisClient jedisClient;
    @Override
    public List<Prd> getList() {
        return mapper.getList();
    }

    @Override
    public Prd findById(String pid) {
       //首先查询redis中有没有需要的数据
        String json = jedisClient.hget("redis_j54_singleton", pid);
        
        //判断数据是否为null,如果为空,表示缓存中还没有需要的数据,需要到数据库加载
        if(StringUtils.isEmpty(json)){
            //为空,表示缓存中还没有需要的数据,需要到数据库加载
            System.out.println("到数据库加载编号为:"+pid+"的数据");
           
            //准备查询数据库
            Prd prd = mapper.findById(pid);
           
            //在返回之前要把它转换成json存放到redis
            json = JsonUtils.objectToJson(prd);
            jedisClient.hset("redis_j54_singleton",pid,json);
           
            return prd;
        }else{
            
            //缓存中有需要的数据.需要将Json还原成对象返回
            System.out.println("到缓存中加载编号为:"+pid+"的数据");
            Prd prd = JsonUtils.jsonToPojo(json, Prd.class);
           
            return prd;
        }
    }
}

第三章

1、缓存击穿(缓存穿透、缓存雪崩) 2、redis数据持久化策略 3、redis中的主从复制 4、redis集群的使用

Linux常用命令

编辑文件:vi redis.conf

搜索内容:/内容 

进入编辑模式: i

退出编辑: esc

保存:    :wq

不保存:   q!



查看正在运行的某一个程序(进程)
	ps -ef | grep 程序名


杀死进程 kill -9 进程号


解压缩:  tar -xvPf 压缩包名称  -C /usr/local/d113

复制文件  cp  文件名 指定路径 

复制文件夹  cp  文件名 -r 指定路径 

删除文件  rm -rf  文件名

重命名   mv 原文件名 新文件名

查看ip   ifconfig 

新建文件夹   mkdir 文件夹名称

查看文件内容  cat    less

查看当前文件夹中的所有文件 ls

查看当前文件夹中的所有文件(包含隐藏文件) ls -a

联网安装软件   yum install  软件名

返回上一级  cd ..

返回根目录  cd /

1、redis的作用

redis在项目中的主要作用是:作为缓存使用

	在客户端请求到达服务器后,系统会首先判断缓存中有没有需要的数据,如果没有,系统就会查询数据库,并且把查询到的数据放入到缓存中,然后再返回。
	当下一次请求,再次到达到服务器,如果检测到缓存中有需要的数据,就会直接返回缓存中的数据,不再走数据库加载,这样可以缓解数据压力。


在项目中配置redis缓存后,假设某一个条数据被请求了10000次
	
	第1次应该从数据库加载数据

	剩余的9999次都应该从缓存中加载
存在问题
    问题:当缓存中有数据,请求就会直接返回缓存中的数据,不再走数据库,假设,此时后台的数据被修改了,但由于缓存中有数据,
    将会导致最新修改的数据无法加载

    答:当后台某一台数据被修改后,我们可以找到它对应的缓存数据,将该数据从缓存中移除掉
1、高并发
高并发:大量请求同时访问


条件:在高并发环境下,有1000个请求访问同一条数据,线程池每次可以并发执行100个线程

        1、第1批的100个线程,它们一开始并发执行到redis中访问数据,由于redis中没有数据,所有它们得到的结果就是redis中没有需要的数据,这100个线程都要到数据库查询

        2、这100个线程查询数据库后,每一个线程都会将查询到的对象,存放到redis中

        3、后面900个请求对应的线程,由于redis中已经有数据了,就直接返回缓存中的数据,不再查询数据库
2、缓存击穿
缓存击穿:
     大量请求访问同一条数据(热点数据),如果该数据在redis中不存在,但是在数据库中存在,导致大量请求同时访问数据库,这种情况我们称为:“缓存击穿”

 解决方案:
 	1、设置热点数据永不过期
	2、设置互斥锁(双重检测锁)

双层检测锁

双重检测锁

	假设有100个线程并发执行

	1、在方法中首先查询缓存中有没需要的数据(100个线程会同时查询)

	2、如果这100个线程没有找到需要数据,它们都要准备查询数据库

	3、在这100个线程准备查询数据库之前,编写一个同步锁synchronized,在同步锁中每一次只能执行1个线程

	4、在synchronized中,再查询一次缓存,这100个准备查询数据库的线程,只能一个一个查询

	5、如果在synchronized中如果能够从缓存中查询到需要的数据,就表示已经有线程查询过数据库,当前线不需要再次查询,直接返回缓存中的数据即可

	6、如果synchronized中的线程,从缓存中依然查询不到数据,表示这100个线程都还没有查询过数据库,当前线程就要到数据库查询,并且将查询结果放入到缓存,其他线程就返回缓存中的数据即可
3、缓存雪崩
缓存雪崩:

    缓存中的大量热数据同时到期,导致缓存中的大量数据同时失效,这样大量请求会同时访问数据库,导致数据库压力过大

	解决方案:
		1、均匀的给热点数据设置过期时间,不要让它们同时失效
4、缓存穿透
缓存穿透

	当用户访问的数据,既不在缓存中,也不在数据库中,导致请求在访问缓存时,发现缓存缺失,再去访问数据库时,发现数据库中也没有要访问的数据,没办法构建缓存数据,来服务后续的请求。那么当有大量这样的请求到来时,数据库的压力骤增,这就是缓存穿透的问题。
  
  解决方案:
  	缓存穿透的方案,常见的方案有三种。

	第一种方案,非法请求的限制;
	第二种方案,缓存空值或者默认值;
	第三种方案,使用布隆过滤器快速判断数据是否存在,避免通过查询数据库来判断数据是否存在;
总结
缓存击穿:一个热点数据过期,它在缓存不存在,在数据库存在,会导致并发环境下,大量请求同时访问数据库

缓存雪崩:大量热点数据同一时间过期,会导致大量请求同时访问数据库

缓存穿透:请求的数据在缓存中不存在,在数据库也不存在,导致无法构建缓存结构,所有请求会频繁访问数据库

2、redis数据持久化策略

redis的持久化策略
问题:redis的数据是存放在缓存中的,但当程序关闭时,缓存会被释放掉,为什么redis的数据不会丢失?

答:因为redis有自己的持久化策略。
    当用户向redis存放数据时,数据是存在内存中的,当程序关闭时,redis默认会将内存中的数据保存到一个名为dump.rdb文件中,此时即使内存被释放,但数据已经存放在dump.rdb文件,当起动redis时,系统又会将dump.rdb中的数据加载到内存中
数据持久化策略有两种
方式1
   方式1:采用一种快照的方式,定时将内存中的数据存放到rdb文件

   		如果修改了redis中的1条数据,系统会在900秒以后,自动存放到dump.rdb文件

		如果修改了redis中的10条数据,系统会在300秒以后,自动存放到dump.rdb文件

		如果修改了redis中的10000条数据,系统会在60秒以后,自动存放到dump.rdb文件


		save 900 1
		save 300 10
		save 60 10000


	问题:如果修改了1条数据,如果关闭redis它会不会马上保存
		不会保存,会丢失掉
	
	希望数据后马上保存,可以执行 save命令即可

	@@@@@默认情况下redis是采用rdb快照的方式定时存储数据
		这种方式的缺点时,由于它是定时存储,如果存储时间没有到程序意外终止,将会导致未保存的数据丢失。为了解决这个问题,redis提供了另一种持久化策略
方式2
方式2:采用一种日志的方式即时存储(一般用的也是aof)
  	
	这种方式会生成一个aof文件,对redis做的任何修改都会马上保存到这个文件中,即使程序意外终止,数据也不会丢失

	配置方式:
		1、修改/usr/local/d113/redis/bin/redis.conf
			vi  /usr/local/d113/redis/bin/redis.conf
 
		2、修改文件中的一行代码 
			将  appendonly no 修改为 appendonly yes

		3、重启redis服务
区别
@@@@@@@Redis持久化策略中的rdb方式与aof方式的区别?

答:rdb是采用快照的方式定时存储,它比较节省资源,但可能会导致未保存的数据意外丢失
    
    aof是采用日志的方式即时存储,它消耗的资源会比rdb方式更多,但它可以防止数据意外丢失

3、redis中的主从复制

@@@@@@@@@@@如何解决redis的单点故障?

单点故障:某一台redis服务无法使用,导致数据无法读取

解决方案:
    配置redis服务器的主从复制(给主机配置从机),主机上的数据,会自动备份到从机。主机如果发生故障,从机可以提供数据
配置步骤
	1、将/usr/local/d113/redis/bin目录复制一份名为bin2

		bin-----主机
		bin2----从机
		
		cp  /usr/local/d113/redis/bin -r /usr/local/d113/redis/bin2

	2、删除bin2目录下的 rdb与aof文件
		
		rm -rf *.rdb    *.aof

	3、主机不需要进行任何配置
	
	4、修改从机的 redis.conf
		
		1、进入bin2

		slaveof 主机的Ip地址  主机的端口号
		slaveof 192.168.47.128  6379

		由于在同一台电脑中,多个端口不能冲突,所以要将从机的端口改为6380
		port 6380
	5、启动从机服务器
		
		1、进入bin2

		2、执行命令 
			./redis-server redis.conf

	6、在主机上进行的任何操作,数据都会反映到从机
		
			bin是主机
			bin2是从机

	7、登录从机的客户端查看数据
		
		1、进入bin2

		2、执行命令 
			./redis-cli -p 6380


@@@@@@@@@@@@@@注意:从机只能读数据,不能写数据

第四章

redis集群的配置及使用

1、redis的集群配置

@@@@我们之前配置的redis是单机版,所有请求需要由一台redis服务器进行处理,当请求的数据量比较大时,该服务器的压力也会比较大
为了解决这个问题,我们可以配置redis集群

配置redis服务器集群的好处:

	1、将原本应该由一台redis主机承受的压力,分散到多台redis主机共同分担,这样可以减少单台redis主机的压力

	2、配置redis集群,可以让多台redis主机共同处理请求,性能会更快

	3、配置redis集群后,redis的主机会自动配置从机。当redis主机挂了,它的从机会自动升级成主机可读可写
1、配置要求
@@@@配置redis集群的要求:

1、redis的主机数量必须是单数,至少需要配置3台redis主机
2、redis的主机需要配置从机
       @@@@@@配置redis集群至少需要6台redis服务器,其中3台主机,3台从机
2、判断失败标准
@@@@@@判断redis集群是否失败的标准是什么

	1、如果集群中主机挂了,它如果没有配置从机。该节点无法访问,集群失败无法使用

	2、如果集群中有一半以上的主机挂了,即使它们配置了从机,集群也是失败的
3、配置原理
@@@@配置redis集群的原理:
	通过网络将多台redis服务器连接在一起,共同处理请求,这样可以提升处理请求的效率,减少单台服务的压力
4、配置完成数据如何存储
@@@@配置redis服务器集群后,数据是如何存储的?
	当配置redis集群中,集群中会产生16384个哈希槽(哈希槽用于具体存储数据),这些哈希槽会均分到每一台主机上,当向redis集群存储数据时,redis存放数据是采用:键值对方式存储的。系统会对键采用一种CRC16算法,将键转换成一个数值,然后系统用这个数值取模16384,会得到一个介于0~16383之间的值,系统会判断这个值对应的哈希槽在哪一台主机上,就会自动切换到主机
	
		
		这些哈希槽范围是:  0~16383
		假设有三台主机:
			第一台主机:  0 ~ 5000
			第二台主机:  5001 ~ 10000
			第三台主机:  10001~16383

2、准备工作

@@@@@@@配置redis集群前的准备工作:

由于redis集群的管理工具是用ruby语言写出来的,所以我们要先配置ruby的环境

1、联网安装ruby的环境
	
	yum install ruby

	yum install rubygems

2、下载redis集群管理工具
	redis-3.0.0.gem

3、将工具发布到Linux下的/d113目录中

4、进入/d113目录执行下列命令安装工具

	gem install redis-3.0.0.gem

5、在/usr/local/d113目录下,创建一个名为:redis-cluster的目录,用于存放redis集群中的所有redis服务器
	mkdir /usr/local/d113/redis-cluster

6、将/usr/local/d113/redis/bin目录复制一份到/usr/local/d113/redis-cluster,同时命名为7001(它就是一台redis服务器)

	cp /usr/local/d113/redis/bin -r  /usr/local/d113/redis-cluster/7001

7、将/usr/local/d113/redis0-3.0.0/src目录下的redis-trib.rb文件拷贝到/usr/local/d113/redis-cluster目录,用于构建集群

	cp /usr/local/d113/redis-3.0.0/src/redis-trib.rb   /usr/local/d113/redis-cluster

3、构建redis集群

步骤

1-5
@@@@@@@@@@@@@构建redis集群

1、将7001目录中的*.rdb,*.aof文件删除
	
	1、进入目录   cd  /usr/local/d113/redis-cluster/7001

	2、删除   rm -rf *.rdb *.aof

2、进入7001目录,修改redis.conf

	1、将端口改为: 7001
	
	2、启用集群
		# cluster-enabled yes
		
		将前面的#去掉即可 cluster-enabled yes

	3、保存退出

3、将7001复制5份,分别命名为:7002~7006  (它们就是6台redis服务器)

	1、进入 /usr/local/d113/cluster

	2、复制
		cp 7001 -r 7002
		cp 7001 -r 7003
		.....

4、分别进入 7002~7006修改redis.conf,将端口号分别改为7002~7006

5、分别启动 7001~7006这些服务器
	
	1、分别进入7001~7006

	2、分别执行 ./redis-server redis.conf
6-11
6、查看进程,看这些服务器是否启动好了 7001~7006
		ps -ef | grep redis

7、进入/usr/local/d113/redis-cluster用 redis-trib.rb文件构建redis集群

	./redis-trib.rb create --replicas 1 192.168.47.128:7001 192.168.47.128:7002 192.168.47.128:7003 192.168.47.128:7004 192.168.47.128:7005 192.168.47.128:7006
                
	在执行过程中,有一个地方要求要输入,我们输入yes确定即可

8、登录redis集群

	配置集群后,集群中的所有服务器是可以共享访问,登录其中的任意一台服务器都可以

	1、进入 7001目录
		
	2、通过客户端访问redis集群
		./redis-cli -h 192.168.47.128 -p 7001 -c

9、查看集群的状态 
		cluster info


10、查看集群中的主从机信息以及哈希槽的分配信息
		cluster nodes

11、将7001~7006在防火墙中注册

	firewall-cmd --zone=public --add-port=7001/tcp --permanent
	firewall-cmd --reload

4、测试集群

@@@@@@@@@@测试集群:

问题1:集群中的服务器是共享的,当存储数据时,系统对键采用CRC16算法得到数值取模16384得到一个哈希值,然后就会切换该值对应哈希槽的主机

	7001主机:0~5460
	(7004)

	7002主机:5461~10922
	(7005)

	7003主机:10923~16384
	(7006)

问题2:如果集群中的某一台主机如果挂了,它的从机会自动升级成主机可读可写

	键为stu的数据,是存放在7003这个主机中的

	将7003的进程关掉,7006就会升级成主机

	如果此时将7003启动,它将会成为7006的从机

5、Java代码访问集群

示例1:与spring无关,单独访问集群
示例1:与spring无关,单独访问集群

package org.java.demo;

import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPoolConfig;

import java.util.HashSet;
import java.util.Set;

/**
 * @author arjun
 * @title: clusterRedis
 * @description: 描述信息
 * @date 2023.08.20 10:15
 */
//redis集群测试
public class clusterRedis {
    public static void main(String[] args) {

       /*******************连接池****************************/
        //创建连接池的配置对象,用于设置连接池配置信息
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        //指定连接池的最小闲置连接数--------连接池最少要保证有多个闲置连接,如果没有就会马上自动创建
        jedisPoolConfig.setMinIdle(50);
        //指大最大闲置连接数
        jedisPoolConfig.setMaxIdle(100);
        //设置最大连接数
        jedisPoolConfig.setMaxTotal(200);
        //由于用完的连接并不会释放,会回到连接池,设置多余闲置连接的销毁时间
        jedisPoolConfig.setEvictorShutdownTimeoutMillis(3000);
        //设置等待连接的超时时间
        jedisPoolConfig.setMaxWaitMillis(3000);

        /******************redis集群****************************/
        //真实项目中,不是改端口号,而是修改ip,端口号都为6379
        Set<HostAndPort> set=new HashSet<>();
        set.add(new HostAndPort("192.168.18.128",7001));
        set.add(new HostAndPort("192.168.18.128",7002));
        set.add(new HostAndPort("192.168.18.128",7003));
        set.add(new HostAndPort("192.168.18.128",7004));
        set.add(new HostAndPort("192.168.18.128",7005));
        set.add(new HostAndPort("192.168.18.128",7006));


        /*****************测试集群****************************/
        JedisCluster jedisCluster=new JedisCluster(set,jedisPoolConfig);
        String score = jedisCluster.get("id");

        System.out.println(score);
    }
}
示例2:在spring中使用集群
1、修改applicationContext-redis.xml配置集群

    <!--1、指定redis配置对象-->
    <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
        <!--指定连接池的最小闲置连接数连接池最少要保证有多个闲置连接,如果没有就会马上自动创建-->
        <property name="minIdle" value="50"/>
        <!--最大闲置连接数-->
        <property name="maxIdle" value="100"/>
        <!-- 设置最大连接数-->
        <property name="maxTotal" value="200"/>
        <!--由于用完的连接并不会释放,会回到连接池,设置多余闲置连接的销毁时间-->
        <property name="evictorShutdownTimeoutMillis" value="3000"/>
        <!--设置等待连接的超时时间-->
        <property name="maxWaitMillis" value="3000"/>
    </bean>



    <!--    配置redis集群-->
    <bean id="cluster" class="redis.clients.jedis.JedisCluster">
        <!--指定构造参数1:redis服务器的集合-->
        <constructor-arg index="0">
            <set>
                <!--所有的redis服务器都要放在set集合-->
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.47.128"/>
                    <constructor-arg name="port" value="7001"/>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.47.128"/>
                    <constructor-arg name="port" value="7002"/>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.47.128"/>
                    <constructor-arg name="port" value="7003"/>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.47.128"/>
                    <constructor-arg name="port" value="7004"/>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.47.128"/>
                    <constructor-arg name="port" value="7005"/>
                </bean>
                <bean class="redis.clients.jedis.HostAndPort">
                    <constructor-arg name="host" value="192.168.47.128"/>
                    <constructor-arg name="port" value="7006"/>
                </bean>
            </set>
        </constructor-arg>
        <!--指定构造参数2:连接池的配置对象-->
        <constructor-arg index="1" ref="jedisPoolConfig"/>
    </bean>
2、编写JedisClient接口的实现类(采用集群的方式实现)

	@Component("myCluster")
	public class JedisClientClusterImpl implements JedisClient {
	    @Autowired
	    private JedisCluster jedisCluster;

	    @Override
	    public void set(String key, String value) {
		jedisCluster.set(key,value);
	    }

	    @Override
	    public String get(String key) {
		return jedisCluster.get(key);
	    }

	    @Override
	    public void hset(String key, String field, String value) {
		jedisCluster.hset(key,field,value);
	    }

	    @Override
	    public String hget(String key, String field) {
		return jedisCluster.hget(key,field);
	    }

	    @Override
	    public void hdel(String key, String filed) {
		jedisCluster.hdel(key,filed);
	    }
	}
3、在PrdService注入JedisClient的实例 



    //注入jedis接口
    @Autowired//这种方式是按类型自动注入,它注入的接口的实现类,这种方式注入要求:只允许出现一个匹配类型(接口只有一个实现类才可以这样使用) //如果有多个匹配类型,就不能按类型注入,只能按名称注入
    @Qualifier("myCluster")
    private JedisClient jedisClient;


@@@@@@@@@@Redis集群中的数据是共享访问的,但如果使用REDIS的管理工具查看集群的数据,当前主机只能看到当前主机的数据

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/575941.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

JCE cannot authenticate the provider BC

前言&#xff1a; 公司项目有用AES加密的&#xff0c;报错原因是BC&#xff08;Bouncy Castle&#xff09;提供的加密服务时&#xff0c;JCE&#xff08;Java Cryptography Extension&#xff09;无法进行验证。这通常是由于 JCE 的默认策略文件不支持所需的加密算法&#xff…

Windows下Golang初学乍到

安装 没啥说的&#xff0c;官网下载即可&#xff0c;地址&#xff1a;All releases - The Go Programming Language 根据系统类型下载即可&#xff01; 配置 Windows下安装完后&#xff0c;发现path中已经有了&#xff0c;但为了避免可能的问题&#xff0c;还是建议配置GOPA…

不得不说,在很多业务中,这种设计模式用得真的很香

故事 “不能在写if else来拓展当前系统了&#xff0c;现在已经有三个支付场景了…”工位上&#xff0c;小猫看着电脑&#xff0c;挠着头。 就在刚刚&#xff0c;小猫接到了一个新需求&#xff0c;需要和客户公司打通资产&#xff0c;形成资产联动。说白了就是需要定制化对接客…

Linux下基本指令-掌握

目录 为什么要学命令行 Linux下基本指令-掌握 ls 指令 pwd命令 cd 指令 touch指令 mkdir指令&#xff08;重要&#xff09;&#xff1a; rmdir指令 && rm 指令&#xff08;重要&#xff09;&#xff1a; man指令&#xff08;重要&#xff09;&#xff1a; cp指…

微信黑名单怎么恢复?一招迅速搞定

“求助&#xff01;微信拉黑后&#xff0c;怎样找到并解除黑名单&#xff1f;我不知道具体的操作&#xff0c;希望可以分析给我详细的图文解说&#xff0c;感谢&#xff01;” 微信的黑名单功能允许用户将某人加入黑名单&#xff0c;从而屏蔽其发送消息、查看朋友圈等行为。然…

7天入门Android开发之第1天——初识Android

一、Android系统 1.Linux内核层&#xff1a; 这是安卓系统的底层&#xff0c;它提供了基本的系统功能&#xff0c;如内存管理、进程管理、驱动程序模型等。安卓系统构建在Linux内核之上&#xff0c;借助于Linux的稳定性和安全性。 2.系统运行库层&#xff1a; 这一层包括了安卓…

最新windows版本erlang26.0和rabbitmq3.13下载

Erlang下载 官网下载&#xff1a;https://www.erlang.org/patches/otp-26.0 百度网盘&#xff1a;https://pan.baidu.com/s/1xU4syn14Bh7QR-skjm_hOg 提取码&#xff1a;az1t RabbtitMQ下载 官网下载&#xff1a;https://www.rabbitmq.com/docs/install-windows 百度网盘…

一文解读:阿里云 AI 基础设施的演进与挑战

云布道师 2024 年 4 月 18-19 日&#xff0c;2024 中国生成式 AI 大会在北京 JW 万豪酒店举行&#xff0c;阿里云高级技术专家、阿里云异构计算 AI 推理团队负责人李鹏受邀在【AI Infra】专场发表题为《AI 基础设施的演进与挑战》的主题演讲。李鹏从 AIGC 对云基础设施的挑战、…

echarts利用graphic属性给饼图添加内圈图片及外圈图片(可自适应宽度位于饼图中心)

最终效果图&#xff1a; 目录 前言资源主要部分graphic介绍style介绍代码 加载饼图方法&#xff08;option所有的配置&#xff09; 前言 思路是看到这个博客启发的&#xff1a;点击跳转查看博客&#xff0c;然后在graphic属性里改了我的实际需求&#xff0c;譬如图片的宽高、…

【笔试强训】除2!

登录—专业IT笔试面试备考平台_牛客网牛客网是互联网求职神器&#xff0c;C、Java、前端、产品、运营技能学习/备考/求职题库&#xff0c;在线进行百度阿里腾讯网易等互联网名企笔试面试模拟考试练习,和牛人一起讨论经典试题,全面提升你的技术能力https://ac.nowcoder.com/acm/…

如何安装sbt(sbt在ubuntu上的安装与配置)(有详细安装网站和图解)

sbt下载官网 选择对应的版本和安装程序 Download | sbt (scala-sbt.org) 安装 解压 将sbt-1.9.0.tgz上传到xshell&#xff0c;并解压 解压&#xff1a; tar -zxvf sbt-1.9.0.tgz 配置 1、在/home/hadoop/sbt中创建sbt脚本 /home/hadoop/sbt 注意要改成自己的地址 cd …

16 JavaScript学习: 类型转换

JavaScript 类型转换 Number() 转换为数字&#xff0c; String() 转换为字符串&#xff0c; Boolean() 转换为布尔值。 JavaScript 数据类型 在 JavaScript 中有 6 种不同的数据类型&#xff1a; stringnumberbooleanobjectfunctionsymbol 3 种对象类型&#xff1a; Obje…

Springboot多数据源及事务实现方案

Springboot多数据源及事务实现方案 文章目录 Springboot多数据源及事务实现方案背景问题分析实现原理1. 数据源抽象与动态路由2. 线程本地存储&#xff08;ThreadLocal&#xff09;3. 面向切面编程&#xff08;AOP&#xff09;4. 自定义注解 实现流程1. 设置数据源标识2. 开始数…

Godot3D学习笔记1——界面布局简介

创建完成项目之后可以看到如下界面&#xff1a; Godot引擎也是场景式编程&#xff0c;这里的一个场景相当于一个关卡。 这里我们点击左侧“3D场景”按钮创建一个3D场景&#xff0c;现在在中间的画面中会出现一个球。在左侧节点视图中选中“Node3D”&#xff0c;右键创建子节点…

医院手术室麻醉信息管理系统源码 自动生成麻醉的各种医疗文书(手术风险评估表、手术安全核查表)

目录 手术风险评估表 一、患者基本信息 二、既往病史 三、手术相关信息 四、风险评估因素 五、风险评估结果 手术安全核查表 一、患者身份与手术信息核对 二、术前准备核查 三、手术团队与职责确认 四、手术物品与设备核查 五、术中关键步骤核查 六、术后核查 七…

STM32中断实现旋转编码器计数

系列文章目录 STM32单片机系列专栏 C语言理论和实践总结专栏 文章目录 1. 旋转编码器 2. 中断代码编写 2.1 Interrupt.c 2.2 Interrupt.h 2.3 完整工程文件 1. 旋转编码器 旋转编码器主要用于测量轴的旋转位置、速度或者是角度的变化&#xff0c;它能够将转动的角度或者…

新兴游戏引擎Godot vs. 主流游戏引擎Unity和虚幻引擎,以及版本控制工具Perforce Helix Core如何与其高效集成

游戏行业出现一个新生事物——Godot&#xff0c;一个免费且开源的2D和3D游戏引擎。曾经由Unity和虚幻引擎&#xff08;Unreal Engine&#xff09;等巨头主导的领域如今迎来了竞争对手。随着最近“独特”定价模式的变化&#xff0c;越来越多的独立开发者和小型开发团队倾向于选择…

【数据结构】反转链表

给你单链表的头节点 head &#xff0c;请你反转链表&#xff0c;并返回反转后的链表。 Definition for singly-linked list.struct ListNode {int val;struct ListNode *next;};typedef struct ListNode ListNode; struct ListNode* reverseList(struct ListNode* head) {i…

JavaEE初阶——文件操作和IO

T04BF &#x1f44b;专栏: 算法|JAVA|MySQL|C语言 &#x1faf5; 小比特 大梦想 此篇文章与大家分享文件操作及IO的内容 如果有不足的或者错误的请您指出! 目录 *1.解释IO**2.关于文件的基本知识*2.1路径2.1.1绝对路径2.1.2相对路径 2.2文件分类 *3.通过Java代码操作文件*3.1针…

Arcpy入门笔记(三):数据属性的读取

Arcpy入门笔记&#xff08;三&#xff09;&#xff1a;数据属性的获取 文章目录 Arcpy入门笔记&#xff08;三&#xff09;&#xff1a;数据属性的获取常用的属性Describe对象属性&#xff08;部分&#xff09;数据集属性&#xff08;部分&#xff09;表属性&#xff08;部分&a…