Java가 Lettuce 클라이언트를 사용하여 Redis 마스터-슬레이브 모드에서 명령을 실행하는 방법-Redis-php.cn

1 Redis 마스터-슬레이브 복제의 개념

다중 머신 환경에서 Redis 서비스는 자체 데이터 및 상태가 변경될 때 쓰기 명령을 수신하고 이를 하나 이상의 Redis에 복사합니다. 이 모드를 마스터-슬레이브 복제라고 합니다. 슬레이브of 명령을 통해 하나의 Redis 서버는 Redis에 있는 다른 Redis 서버의 데이터와 상태를 복사할 수 있습니다. 메인 서버를 마스터, 슬레이브 서버를 슬레이브라고 부릅니다.

마스터-슬레이브 복제는 네트워크가 비정상적이거나 연결이 끊어졌을 때 데이터가 복제되도록 보장합니다. 네트워크가 정상이면 마스터는 명령을 전송하여 슬레이브를 계속 업데이트합니다. 업데이트에는 클라이언트 쓰기, 키 만료 또는 기타 네트워크 이상 현상이 포함됩니다. 슬레이브는 일정 기간 동안 슬레이브와의 연결을 끊습니다. 마스터에 다시 연결한 후 부분적으로 다시 연결합니다. 동기화, 연결 해제 중에 손실된 명령을 다시 가져옵니다. 부분 재동기화를 수행할 수 없는 경우 전체 재동기화를 수행합니다.

2 마스터-슬레이브 복제가 필요한 이유

데이터가 손실되지 않도록 하기 위해 지속성 기능을 사용하는 경우도 있습니다. 그러나 이로 인해 디스크 IO 작업이 증가합니다. 마스터-슬레이브 복제 기술을 사용하면 지속성을 대체하고 IO 작업을 줄여 대기 시간을 줄이고 성능을 향상시킬 수 있습니다.

마스터-슬레이브 모드에서는 마스터가 쓰기를 담당하고 슬레이브가 읽기를 담당합니다. 마스터-슬레이브 동기화로 인해 데이터 불일치가 발생할 수 있지만 읽기 작업의 처리량을 향상시킬 수 있습니다. 마스터-슬레이브 모델은 Redis 단일 지점 위험을 방지합니다. 복제본을 통해 시스템 가용성을 향상합니다. 마스터 노드에 장애가 발생하면 슬레이브 노드는 시스템 가용성을 보장하기 위해 새 노드를 마스터 노드로 선택합니다.

3 마스터-슬레이브 복제 구성 및 원리

마스터-슬레이브 복제는 초기화, 동기화, 명령 전파의 세 단계로 나눌 수 있습니다.

서버가 슬레이브of 명령을 실행한 후 슬레이브 서버는 마스터 서버와 소켓 연결을 설정하고 초기화를 완료합니다. 주 서버가 정상이라면 연결이 이루어진 후 ping 명령을 통해 하트비트 감지를 수행하고 응답을 반환합니다. 장애가 발생하고 응답이 수신되지 않으면 슬레이브 노드는 마스터 노드에 연결을 다시 시도합니다. 마스터가 인증 정보를 설정하면 인증 데이터가 올바른지 확인합니다. 인증에 실패하면 오류가 보고됩니다.

초기화가 완료된 후 마스터는 슬레이브로부터 데이터 동기화 명령을 받으면 상황에 따라 전체 동기화를 수행할지 부분 동기화를 수행할지 결정해야 합니다.

동기화 완료 후 마스터 서버와 슬레이브 서버는 명령 전송을 위한 하트비트 감지를 통해 서로의 온라인 상태를 확인합니다. 슬레이브는 또한 자체 복사 버퍼의 오프셋을 마스터로 보냅니다. 이러한 요청을 기반으로 마스터는 새로 생성된 명령을 슬레이브에 동기화해야 하는지 여부를 결정합니다. 슬레이브는 동기화 명령을 수신한 후 실행하고 최종적으로 마스터와 동기화합니다.

4 Lettuce를 사용하여 마스터-슬레이브 모드에서 명령 실행

Jedis, Redission 및 Lettuce는 일반적인 Java Redis 클라이언트입니다. Lettuce는 마스터-슬레이브 모드에서 읽기-쓰기 분리 명령 실행을 시연하는 데 사용됩니다.

        <dependency>
            <groupId>io.lettuce</groupId>
            <artifactId>lettuce-core</artifactId>
            <version>5.1.8.RELEASE</version>
        </dependency>

로그인 후 복사

아래

package redis;
import io.lettuce.core.ReadFrom;
import io.lettuce.core.RedisClient;
import io.lettuce.core.RedisURI;
import io.lettuce.core.api.sync.RedisCommands;
import io.lettuce.core.codec.Utf8StringCodec;
import io.lettuce.core.masterslave.MasterSlave;
import io.lettuce.core.masterslave.StatefulRedisMasterSlaveConnection;
import org.assertj.core.util.Lists;
 class MainLettuce {
    public static void main(String[] args) {
        List<RedisURI> nodes = Lists.newArrayList(
                RedisURI.create("redis://localhost:7000"),
                RedisURI.create("redis://localhost:7001")
        );
        RedisClient redisClient = RedisClient.create();
        StatefulRedisMasterSlaveConnection<String, String> connection = MasterSlave.connect(
                redisClient,
                new Utf8StringCodec(), nodes);
        connection.setReadFrom(ReadFrom.SLAVE);
        RedisCommands<String, String> redisCommand = connection.sync();
        redisCommand.set("master","master write test2");
        String value = redisCommand.get("master");
        System.out.println(value);
        connection.close();
        redisClient.shutdown();
    }
}

로그인 후 복사

에 의해 추가됨: Lettuce 구성 및 Redis 클라이언트 사용(Spring Boot 2.x 기반)

개발 환경: Intellij IDEA + Maven + Spring Boot 2.x + JDK 8

Spring 사용 Boot 버전 2.0부터 기본 Redis 클라이언트 Jedis가 Lettuce로 대체됩니다. Lettuce의 구성 및 사용 방법은 다음과 같습니다.

1. 프로젝트의 pom.xml 파일에서 Spring Boot

    <properties>
        <redisson.version>3.8.2</redisson.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <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>
    </dependencies>

로그인 후 복사

2에 있는 Redis의 관련 Jar 패키지 종속성을 도입합니다. 프로젝트의 resources 디렉터리에서 application.yml 파일에 lettuce의 구성 매개변수를 추가합니다.

#Redis配置
spring:
  redis:
    database: 6  #Redis索引0~15，默认为0
    host: 127.0.0.1
    port: 6379
    password:  #密码（默认为空）
    lettuce: # 这里标明使用lettuce配置
      pool:
        max-active: 8   #连接池最大连接数（使用负值表示没有限制）
        max-wait: -1ms  #连接池最大阻塞等待时间（使用负值表示没有限制）
        max-idle: 5     #连接池中的最大空闲连接
        min-idle: 0     #连接池中的最小空闲连接
    timeout: 10000ms    #连接超时时间（毫秒）

로그인 후 복사

3. RedisConfig

package com.dbfor.redis.config;
import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {
    /**
     * RedisTemplate配置
     * @param connectionFactory
     * @return
     */
    @Bean
    public RedisTemplate<String, Object> redisTemplate(LettuceConnectionFactory connectionFactory) {
        // 配置redisTemplate
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(connectionFactory);
        redisTemplate.setKeySerializer(new StringRedisSerializer());//key序列化
        redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());//value序列化
        redisTemplate.afterPropertiesSet();
        return redisTemplate;
    }
}

로그인 후 복사

클래스를 읽는 Redisson 구성 매개변수를 추가합니다. RedisApplication

package com.dbfor.redis;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class RedisApplication {
    public static void main(String[] args) {
        SpringApplication.run(RedisApplication.class);
    }
}

로그인 후 복사

5 테스트 클래스를 작성합니다. Redis

package com.dbfor.redis;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import org.springframework.test.context.junit4.SpringRunner;
@SpringBootTest
@RunWith(SpringRunner.class)
@Component
public class RedisTest {
    @Autowired
    private RedisTemplate redisTemplate;
    @Test
    public void set() {
        redisTemplate.opsForValue().set("test:set1", "testValue1");
        redisTemplate.opsForSet().add("test:set2", "asdf");
        redisTemplate.opsForHash().put("hash2", "name1", "lms1");
        redisTemplate.opsForHash().put("hash2", "name2", "lms2");
        redisTemplate.opsForHash().put("hash2", "name3", "lms3");
        System.out.println(redisTemplate.opsForValue().get("test:set"));
        System.out.println(redisTemplate.opsForHash().get("hash2", "name1"));
    }
}

로그인 후 복사