Spring Boot+Redis主备模式源码教程 - vinsguru

20-11-29 banq

在本教程中,我想使用docker compose演示Redis Master Slave(只读副本),以用于Spring Boot应用程序的本地开发目的。

 

Redis主从站

Redis是一个非常快的内存数据库,非常适合为应用程序缓存经常访问的数据。大多数应用程序读取繁重的操作,其中涉及具有多个表联接的复杂查询。因此,在每次都不会更改时将信息缓存在redis中是非常有意义的。尽管它有助于提高应用程序性能,但当所有应用服务器实例继续向Redis发送读写请求时,它可能会增加单个Redis实例的负载。

我们可以水平缩放Redis。我们可以使用主从架构 运行Redis的多个实例,其中master是写节点,而slave充当只读节点。对主服务器的任何更新将自动与从属节点异步同步。对从节点的任何写尝试都将被拒绝。

 

Redis主从站–设置

  • 设置redis master slave非常容易!首先从这里下载这个redis conf文件
  • 在文件中查找“ REPLICATION”部分。

################################# REPLICATION #################################

# Master-Replica replication. Use replicaof to make a Redis instance a copy of
# another Redis server. A few things to understand ASAP about Redis replication.
#
#   +------------------+      +---------------+
#   |      Master      | ---> |    Replica    |
#   | (receive writes) |      |  (exact copy) |
#   +------------------+      +---------------+
#
# 1) Redis replication is asynchronous, but you can configure a master to
#    stop accepting writes if it appears to be not connected with at least
#    a given number of replicas.
# 2) Redis replicas are able to perform a partial resynchronization with the
#    master if the replication link is lost for a relatively small amount of
#    time. You may want to configure the replication backlog size (see the next
#    sections of this file) with a sensible value depending on your needs.
# 3) Replication is automatic and does not need user intervention. After a
#    network partition replicas automatically try to reconnect to masters
#    and resynchronize with them.
#
# replicaof <masterip> <masterport>

  • 取消注释,更新为主节点ip和端口。
  • 假设我们在网络中使用以下名称运行3个Redis实例

    • 备1
    • 备2
  • 然后应使用如下所示的配置更新slave-1和slave-2。

    replicaof master 6379
    
  • 我们可以使用下面的docker-compose文件,它将启动Redis实例的1个主服务器和2个从属服务器。在下面的docker-compose文件中,我们将卷映射到redis从属实例以共享conf文件;我已经将上面的redis.conf文件放置在本地conf目录中。相应地更新您的docker-compose文件。
  • Redis备站启动时将自动连接到主站。
  • 使用下面文件启动并运行docker-compose服务后,访问localhost:8081时,您应该可以访问redis-commander工具。您还应该能够看到主节点和从节点。

version: '3'
services:
  master:
    container_name: master
    image: redis
    ports:
      - 6379:6379
  slave-1:
    container_name: slave-1
    image: redis
    ports:
      - 16379:6379
    volumes:
      - ./conf:/usr/local/etc/redis/
    command: redis-server /usr/local/etc/redis/redis.conf
  slave-2:
    container_name: slave-2
    image: redis
    ports:
      - 26379:6379
    volumes:
      - ./conf:/usr/local/etc/redis/
    command: redis-server /usr/local/etc/redis/redis.conf    
  redis-commander:
    container_name: redis-commander
    hostname: redis-commander
    image: rediscommander/redis-commander:latest
    restart: always
    environment:
    - REDIS_HOSTS=master:master,slave-1:slave-1,slave-2:slave-2
    ports:
    - "8081:8081"

 

Spring Boot应用

让我们创建一个简单的Spring Boot应用程序,以了解如何将Redis集群与主从一起使用。

  • 创建具有以下依赖项的spring boot项目

    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    
  • application.yaml

    redis:
      master:
        host: localhost
        port: 6379
      slaves:
        - host: localhost
          port: 16379
        - host: localhost
          port: 26379
    
  • 配置Bean

    @Configuration
    @ConfigurationProperties(prefix = "redis")
    public class RedisConfiguration {
    
        private RedisInstance master;
        private List<RedisInstance> slaves;
    
        RedisInstance getMaster() {
            return master;
        }
    
        void setMaster(RedisInstance master) {
            this.master = master;
        }
    
        List<RedisInstance> getSlaves() {
            return slaves;
        }
    
        void setSlaves(List<RedisInstance> slaves) {
            this.slaves = slaves;
        }
    
        @Bean
        public LettuceConnectionFactory redisConnectionFactory() {
            LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder()
                    .readFrom(ReadFrom.REPLICA_PREFERRED)
                    .build();
            RedisStaticMasterReplicaConfiguration staticMasterReplicaConfiguration = new RedisStaticMasterReplicaConfiguration(this.getMaster().getHost(), this.getMaster().getPort());
            this.getSlaves().forEach(slave -> staticMasterReplicaConfiguration.addNode(slave.getHost(), slave.getPort()));
            return new LettuceConnectionFactory(staticMasterReplicaConfiguration, clientConfig);
        }
    
        private static class RedisInstance {
    
            private String host;
            private int port;
    
            String getHost() {
                return host;
            }
    
            void setHost(String host) {
                this.host = host;
            }
    
            int getPort() {
                return port;
            }
    
            void setPort(int port) {
                this.port = port;
            }
        }
    
    }
    
  • REST控制器

    @RestController
    public class RedisController {
    
        private static final String KEY = "VINSGURU";
    
        @Autowired
        private StringRedisTemplate template;
    
        @GetMapping("/{name}")
        public void addToSet(@PathVariable String name) {
            this.template.opsForSet().add(KEY, name);
        }
    
        @GetMapping("/get")
        public Set<String> getKeyValues() {
            return this.template.opsForSet().members(KEY);
        }
    
    }
    

 

Redis Master Slave的设置非常简单。Redis复制也非常快。我进行了性能测试,使用JMeter将10000个密钥添加到具有10个并发用户的Redis master中。我几乎可以立即看到从属节点中的所有10000键。

此项目可在此处获得

猜你喜欢