springboot配置Redis主从服务

淡淡的烟草味﹌ 2022-05-27 13:15 500阅读 0赞

今天学了一下springboot配置redis的主从服务器。根据一主二从三哨兵的原则来搭建一个分布式的缓存服务。主要还是针对redis的一些配置。下面与大家分享一下！

附上对redis的官方介绍  
[http://redis.majunwei.com/topics/sentinel.html][http_redis.majunwei.com_topics_sentinel.html]  
要想通过springboot搭建redis主从服务，就要先使用redis配置一个主从服务。

# 测试redis的主从配置 #

主服务器用于数据的读写，当发生写入操作时，主服务器会自动将数据同步给从服务器。

从服务器只负责读取，不能写入。如果主服务器宕机，哨兵（sentinel）会在从服务器中选举产生一个主服务器。此时该服务器具有读写权限。  
下面我们分步骤来配置主从服务器，依照一主二从三哨兵的原则，我们需要三个redis实例，分别配置如下信息

redis实例

文件夹名称如下

redis_master_s
    redis_slaver1_s
    redis_slaver2_s

redis.conf文件

master的redis.conf文件(其余是默认设置)

port 6379
    daemonize yes
    # 这个文件夹要改成自己的目录
    dir "/Users/vobile_lzl/redis_master_s"

slaver1的redis.conf文件

port 6378
    # 主服务器端口为6379
    slaveof 127.0.0.1 6379
    dir "/Users/vobile_lzl/redis_slaver1_s"

slaver2的redis.conf文件

port 6377
    # 主服务器端口为6379
    slaveof 127.0.0.1 6379
    dir "/Users/vobile_lzl/redis_slaver2_s"

这个主从服务器就配置好了。

启动服务(命令大致如此)

./redis-server redis.conf

测试一下主从复制的功能

**1. 主服务器写入，从服务器可以读取到  
2. 从服务器不能写入**

注意端口，6379表示主服务器，6377、6378是从服务器

127.0.0.1:6379> set name lzl
    OK
    127.0.0.1:6377> get name
    "lzl"
    127.0.0.1:6378> get name
    "lzl"
    # 从服务器不能写入
    127.0.0.1:6378> set name lzl
    (error) READONLY You can't write against a read only slave.
    127.0.0.1:6377> set nam fdk
    (error) READONLY You can't write against a read only slave.

sentinel.conf文件

sentinel是哨兵，用于监视主从服务器的运行状况，如果主服务器挂掉，会在从服务器中选举一个作为主服务器。  
配置文件如下  
master的sentinel.conf

port 26379
    # 初次配置时的状态，这个sentinel会自动更新
    sentinel monitor mymaster 127.0.0.1 6379 2
    daemonize yes
    logfile "./sentinel_log.log"

slaver1的sentinel.conf

port 26378
    # 初次配置时的状态，这个sentinel会自动更新
    sentinel monitor mymaster 127.0.0.1 6379 2
    daemonize yes
    logfile "./sentinel_log.log"

slaver2的sentinel.conf

port 26377
    # 初次配置时的状态，这个sentinel会自动更新
    sentinel monitor mymaster 127.0.0.1 6379 2
    daemonize yes
    logfile "./sentinel_log.log"

再次启动redis所有的服务端

./redis-server redis.conf
    ./redis-server sentinel.conf --sentinel

分别开启redis的客户端

./redis-cli
    ./redis-cli -h 127.0.0.1 -p 6378
    ./redis-cli -h 127.0.0.1 -p 6377

使用一下命令查看三个redis服务的状态

info replication

master

role:master

127.0.0.1:6379> info replication
    # Replication
    role:master
    connected_slaves:2
    slave0:ip=127.0.0.1,port=6378,state=online,offset=4102,lag=1
    slave1:ip=127.0.0.1,port=6377,state=online,offset=4102,lag=1
    master_repl_offset:4102
    repl_backlog_active:1
    repl_backlog_size:1048576
    repl_backlog_first_byte_offset:2
    repl_backlog_histlen:4101

slaver1

127.0.0.1:6378> info replication
    # Replication
    role:slave
    master_host:127.0.0.1
    master_port:6379
    master_link_status:up
    master_last_io_seconds_ago:0
    master_sync_in_progress:0
    slave_repl_offset:15931
    slave_priority:100
    slave_read_only:1
    connected_slaves:0
    master_repl_offset:0
    repl_backlog_active:0
    repl_backlog_size:1048576
    repl_backlog_first_byte_offset:0
    repl_backlog_histlen:0

slaver2

127.0.0.1:6377> info replication
    # Replication
    role:slave
    master_host:127.0.0.1
    master_port:6379
    master_link_status:up
    master_last_io_seconds_ago:1
    master_sync_in_progress:0
    slave_repl_offset:21629
    slave_priority:100
    slave_read_only:1
    connected_slaves:0
    master_repl_offset:0
    repl_backlog_active:0
    repl_backlog_size:1048576
    repl_backlog_first_byte_offset:0
    repl_backlog_histlen:0

将master服务杀死

vobile-lzldeMacBook-Pro:~ vobile_lzl$ ps -ef | grep redis
      501 13258     1   0  9:52下午 ??         0:00.37 ./redis-server *:6379 
    
      kill -9 13258

再次查看master的状态

说明master已经宕机

127.0.0.1:6379> info replication
    Could not connect to Redis at 127.0.0.1:6379: Connection refused

再观察一段时间，6377的从服务器成为主服务器

127.0.0.1:6377> info replication
    # Replication
    role:master
    connected_slaves:0
    master_repl_offset:0
    repl_backlog_active:0
    repl_backlog_size:1048576
    repl_backlog_first_byte_offset:0
    repl_backlog_histlen:0

恢复主服务器，并设置为master

// TODO

springboot中配置主从redis

依旧接着上个项目的内容进行设置。  
不清楚内容的可以查看  
[http://blog.csdn.net/u011521890/article/details/78070773][http_blog.csdn.net_u011521890_article_details_78070773]  
或者github上面的内容  
[https://github.com/hpulzl/book\_recommend][https_github.com_hpulzl_book_recommend]

application.properties文件

新增node配置

// 主从配置
    // name of Redis server  哨兵监听的Redis server的名称
    spring.redis.sentinel.master=mymaster
    // comma-separated list of host:port pairs  哨兵的配置列表
    spring.redis.sentinel.nodes=127.0.0.1:26379,127.0.0.1:26378,127.0.0.1:26377

RedisCacheConfig配置

新增RedisSentinelConfiguration代码

/**
         * redis哨兵配置
         * @return
         */
        @Bean
        public RedisSentinelConfiguration redisSentinelConfiguration(){
            RedisSentinelConfiguration configuration = new RedisSentinelConfiguration();
            String[] host = redisNodes.split(",");
            for(String redisHost : host){
                String[] item = redisHost.split(":");
                String ip = item[0];
                String port = item[1];
                configuration.addSentinel(new RedisNode(ip, Integer.parseInt(port)));
            }
            configuration.setMaster(master);
            return configuration;
        }
    
        /**
         * 连接redis的工厂类
         *
         * @return
         */
        @Bean
        public JedisConnectionFactory jedisConnectionFactory() {
        //构造方法中注入RedisSentinelConfiguration对象
            JedisConnectionFactory factory = new JedisConnectionFactory(redisSentinelConfiguration());
            factory.setHostName(host);
            factory.setPort(port);
            factory.setTimeout(timeout);
            factory.setPassword(password);
            factory.setDatabase(database);
            return factory;
        }

以上就是redis的主从配置。十分简单！

接下来就要验证一把在springboot中是否配置成功！  
**验证思路**  
\* 写一个controller方法，用来往redis中新增数据  
\* 此时关闭redis主服务器，再次调用contoller方法、  
\* 如果接口依旧可以写入信息，说明配置成功。此时查看redis的其他从服务器，会发现有一个从服务器变成了主服务器。  
测试代码:

@RestController
    @RequestMapping("sample")
    public class SampleController {
    
        @Autowired
        private UseRedisDao useRedisDao;
    
        @RequestMapping("hi")
        public String sayHello(String key,String value){
            useRedisDao.setValue(key,value);
            return useRedisDao.getValue(key);
        }
    }

先查看redis主服务器发现，6377是master服务器

127.0.0.1:6377> info replication
    # Replication
    role:master
    connected_slaves:2
    slave0:ip=127.0.0.1,port=6378,state=online,offset=378547,lag=1
    slave1:ip=127.0.0.1,port=6379,state=online,offset=378547,lag=1
    master_repl_offset:378682
    repl_backlog_active:1
    repl_backlog_size:1048576
    repl_backlog_first_byte_offset:2
    repl_backlog_histlen:378681

调用本地服务

[http://localhost:8080/sample/hi?key=code&value=good][http_localhost_8080_sample_hi_key_code_value_good]  
从redis中查询写入信息

127.0.0.1:6379> keys *
    1) "code"
    2) "name"
    127.0.0.1:6379> get code 
    "\"good\""

我们看到三个redis服务都存在这样的信息

![这里写图片描述][SouthEast]  
这时kill掉6377的进程

vobile-lzldeMacBook-Pro:redis_slaver2_s vobile_lzl$ ./redis-cli -p 6377 shutdown
    vobile-lzldeMacBook-Pro:redis_slaver2_s vobile_lzl$ ./redis-cli -p 6377
    Could not connect to Redis at 127.0.0.1:6377: Connection refused

再次请求服务器

[http://localhost:8080/sample/hi?key=today&value=iscoding][http_localhost_8080_sample_hi_key_today_value_iscoding]  
我们发现数据照样写入了redis中

127.0.0.1:6378> keys *
    1) "code"
    2) "name"
    3) "today"

127.0.0.1:6379> keys *
    1) "code"
    2) "name"
    3) "today"

此时看到6379变成了master

127.0.0.1:6379> info replication
    # Replication
    role:master
    connected_slaves:1
    slave0:ip=127.0.0.1,port=6378,state=online,offset=32419,lag=1
    master_repl_offset:32419
    repl_backlog_active:1
    repl_backlog_size:1048576
    repl_backlog_first_byte_offset:2
    repl_backlog_histlen:32418

以上就是配置的过程，如有疑问可以参看github

[https://github.com/hpulzl/book\_recommend][https_github.com_hpulzl_book_recommend]

[http_redis.majunwei.com_topics_sentinel.html]: http://redis.majunwei.com/topics/sentinel.html
[http_blog.csdn.net_u011521890_article_details_78070773]: http://blog.csdn.net/u011521890/article/details/78070773
[https_github.com_hpulzl_book_recommend]: https://github.com/hpulzl/book_recommend
[http_localhost_8080_sample_hi_key_code_value_good]: http://localhost:8080/sample/hi?key=code&value=good
[SouthEast]: /images/20220527/08d9392ac7284d3288cdc89037fef493.png
[http_localhost_8080_sample_hi_key_today_value_iscoding]: http://localhost:8080/sample/hi?key=today&value=iscoding