ホームページ  >  記事  >  データベース  >  Spring Boot が Redis マスター/スレーブセンチネルメソッドを統合する方法

Spring Boot が Redis マスター/スレーブセンチネルメソッドを統合する方法

WBOY
WBOY転載
2023-06-02 09:22:211716ブラウズ

springboot は Redis のマスター/スレーブ センチネルを統合します。

マスター 1 つ、スレーブ 2 つ、センチネル 3 つの構成

  • 1、マスター:127.0.0.1:6379

  • 2、スレーブ1:127.0.0.1:6380

  • ##3、スレーブ2:127.0.0.1:6381

  • 4 、センチネル 1 :127.0.0.1:26379

  • 5、センチネル 2:127.0.0.1:26479

  • 6、センチネル 3:127.0.0.1:26579

  • 7. 監視ホスト名: mymaster

  • 8. Sentinel1

  • port 26379
    sentinel monitor mymaster 127.0.0.1 6379 2
    sentinel down-after-milliseconds mymaster 5000
    sentinel parallel-syncs mymaster 1
    sentinel failover-timeout mymaster 15000
    # の構成を添付します。 ## 新しい Spring Boot プロジェクトを作成し、Redis の依存関係を追加します

Spring Boot が Redis マスター/スレーブセンチネルメソッドを統合する方法プロジェクトの構造

は次のとおりです:

Spring Boot が Redis マスター/スレーブセンチネルメソッドを統合する方法pom ファイルは次のとおりです:

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
 
	<groupId>com.chhliu.springboot.redis</groupId>
	<artifactId>springboot-redis</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>jar</packaging>
 
	<name>springboot-redis</name>
	<description>Demo project for Spring Boot redis</description>
 
	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>1.4.3.RELEASE</version>
		<relativePath/> <!-- lookup parent from repository -->
	</parent>
 
	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
		<java.version>1.7</java.version>
	</properties>
 
	<dependencies>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-data-redis</artifactId>
		</dependency>
 
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
		</dependency>
	</dependencies>
 
	<build>
		<plugins>
			<plugin>
				<groupId>org.springframework.boot</groupId>
				<artifactId>spring-boot-maven-plugin</artifactId>
			</plugin>
		</plugins>
	</build>
</project>

application.properties 構成ファイルを変更します

次の内容を構成ファイルに追加します:

########################################################
###REDIS (RedisProperties) redis基本配置;
########################################################
# database name
spring.redis.database=0
# server host1 单机使用,对应服务器ip
#spring.redis.host=127.0.0.1  
# server password 密码,如果没有设置可不配
#spring.redis.password=
#connection port  单机使用,对应端口号
#spring.redis.port=6379
# pool settings ...池配置
spring.redis.pool.max-idle=8
spring.redis.pool.min-idle=0
spring.redis.pool.max-active=8
spring.redis.pool.max-wait=-1
# 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:26479,127.0.0.1:26579

Create新しい Redis サービス

package com.chhliu.springboot.redis; 
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;
 
@Service("redisService")
public class RedisService {
	@Autowired //操作字符串的template,StringRedisTemplate是RedisTemplate的一个子集
	private StringRedisTemplate stringRedisTemplate;
	
	@Autowired  // RedisTemplate,可以进行所有的操作
        private RedisTemplate<Object,Object> redisTemplate;  
	
	public void set(String key, String value){
		stringRedisTemplate.opsForValue().set(key, value);
	}
	
	public void set(Student s){
		redisTemplate.opsForValue().set(s.getId(), s);
	}
	
	public String get(String key){
		return stringRedisTemplate.opsForValue().get(key);
	}
	
	public Student getStudent(String key){
		return (Student) redisTemplate.opsForValue().get(key);
	}
}

依存する vo は次のとおりです:

package com.chhliu.springboot.redis; 
import java.io.Serializable; 
public class Student implements Serializable{ 
	/**
	 * 
	 */
	private static final long serialVersionUID = 1L;
	private String id;	
	private String name;	
	private String age;	
	private String grade; 
       // 省略getter,setter
	/**
	 * attention:
	 * Details:TODO
	 * @author chhliu
	 * 创建时间:2017-1-18 下午2:24:39
	 * @return
	 */
	@Override
	public String toString() {
		return "Student [id=" + id + ", name=" + name + ", age=" + age
				+ ", grade=" + grade + "]";
	}
}

Test class

package com.chhliu.springboot.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.test.context.junit4.SpringRunner;
 
@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringbootRedisApplicationTests {	
	@Autowired
	private RedisService service;
 
	@Test
	public void contextLoads() {
		service.set("myname", "chhliu");
		Student s = new Student();
		s.setId("001");
		s.setName("chhliu");
		s.setGrade("一年级");
		s.setAge("28");
		service.set(s);
		
		String name = service.get("myname");
		System.out.println("name:"+name);
		
		Student stu = service.getStudent("001");
		System.out.println(stu);
	} 
}

Test result

name:chhliu

Student [id=001、name=chhliu、age=28、grade=1 年生]

redis センチネル モードセンチネルとスプリングブートの統合

Redis のセンチネル モードは次のとおりです。公式の高可用性ソリューションであり、構成は非常に簡単です。

Redis クラスターのインストール

この記事では redis-5.0.5 を使用します。Redis は /soft/redis ディレクトリにインストールされます。新しい /soft/redis/data ディレクトリを作成する必要があります

マスター ノードの構成

vim config/redis-6379.conf

# bind 127.0.0.1 
port 6379
protected-mode no
daemonize yes
pidfile "/var/run/redis_6379.pid"
dir "/soft/redis/data"
dbfilename "dump-6379.rdb"
logfile "log-6379.log"

スレーブ ノード 1 の構成

vim config/redis-6380 .conf

# bind 127.0.0.1
port 6380
protected-mode no
daemonize yes
pidfile "/var/run/redis_6380.pid"
dir "/soft/redis/data"
dbfilename "dump-6380.rdb"
logfile "log-6380.log"
 
replicaof 192.168.4.176 6379

ノード 2 からの構成

vim config/redis-6381.conf

# bind 127.0.0.1
port 6381
protected-mode no
daemonize yes
pidfile "/var/run/redis_6381.pid"
dir "/soft/redis/data"
dbfilename "dump-6381.rdb"
logfile "log-6381.log"
 
replicaof 192.168.4.176 6379

構成指示

# binding 127.0.0.1 他のマシンが redis に接続できるようにこの設定をコメントアウトします

protected-mode no 他のマシンが redis に接続できるように保護モードをオフにします

バックグラウンド モードの起動をデーモン化する

redis-v5 バージョンでは、古いslaveof ディレクティブを置き換えるためにreplicaofを使用します。

これら 3 つのノードを起動し、/soft/redis ディレクトリで実行します

redis-server config/redis-6379.conf
redis-server config/redis-6380.conf
redis-server config/redis-6381.conf

マスター ノード クライアントを開いて構成が成功したかどうかを確認します

redis-cli -p 6379
info replication

Spring Boot が Redis マスター/スレーブセンチネルメソッドを統合する方法クラスターを監視するためにさらに 3 つのセンチネルを構成します

センチネル ノード 1

vim config/redis-sentinel-26379.conf

port 26379
daemonize yes
pidfile "/var/run/redis-sentinel-26379.pid"
dir /tmp
logfile "log-sentinel-26379.log"
sentinel monitor mymaster 192.168.4.176 6379 2
sentinel down-after-milliseconds mymaster 30000
sentinel parallel-syncs mymaster 1
sentinel failover-timeout mymaster 180000
sentinel deny-scripts-reconfig yes

Sentinel ノード 2

vim config/redis-sentinel-26380.conf

port 26380
daemonize yes
pidfile "/var/run/redis-sentinel-26380.pid"
dir /tmp
logfile "log-sentinel-26380.log"
sentinel monitor mymaster 192.168.4.176 6379 2
sentinel down-after-milliseconds mymaster 30000
sentinel parallel-syncs mymaster 1
sentinel failover-timeout mymaster 180000
sentinel deny-scripts-reconfig yes

Sentinel ノード 3

vim config /redis -sentinel-26381.conf

port 26381
daemonize yes
pidfile "/var/run/redis-sentinel-26381.pid"
dir /tmp
logfile "log-sentinel-26381.log"
sentinel monitor mymaster 192.168.4.176 6379 2
sentinel down-after-milliseconds mymaster 30000
sentinel parallel-syncs mymaster 1
sentinel failover-timeout mymaster 180000
sentinel deny-scripts-reconfig yes

構成手順

monitor mymaster 192.168.4.176 6379 2
マスター ホストの名前は mymaster、IP アドレスは 192.168.4.176 です。次の 2 は、2 つのセンチネルがマスターがオフラインであると認識していることを意味するため、マスターはオフラインです。センチネル ノードの数/2 に設定することをお勧めします 1

down-after-milliseconds

Redis ノードに ping リクエストを送信します、指定された時間内に応答が受信されません。 、ノードをオフラインにする必要があると考えられます

parallel-syncs

フェイルオーバーを実行する場合、最大数のスレーブ ノードが同時に新しいマスター サーバーを同期できます。

Sentinel の開始

redis-sentinel config/redis-sentinel-26379.conf
redis-sentinel config/redis-sentinel-26380.conf
redis-sentinel config/redis-sentinel-26381.conf
spring-boot の構成

依存関係を pom.xml にインポート

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

アプリケーションに 2 行を追加します。プロパティの構成

# 使用哨兵模式不能加以下两行配置,其他配置可以加
# spring.redis.host=192.168.4.176
# spring.redis.port=6379
 
spring.redis.sentinel.master=mymaster
spring.redis.sentinel.nodes=192.168.4.176:26379, 192.168.4.176:26380, 192.168.4.176:26381

実行するテスト クラスを作成します

@RunWith(SpringRunner.class)
@SpringBootTest
public class Sentinel001 { 
    @Autowired
    RedisTemplate redisTemplate;
 
    @Test
    public void test001() throws Exception{
        while (true){
            String key = "time:" + new Date().getTime();
            redisTemplate.opsForValue().set(key, new Date().getTime());
            TimeUnit.MILLISECONDS.sleep(100L);
            System.out.println(redisTemplate.opsForValue().get(key));
        } 
    } 
}

次に、マスター インスタンスのプロセス (ポート番号 6379 の Redis)を強制終了します

ps -ef|grep redis
kill -9 11110

コード エディターのコンソール出力を確認します。 , 短時間 (約 50 秒) 後、プログラムは再び正常に実行されました。

ノード 6380 と 6381 で情報レプリケーションを実行し、6381 がマスター ノードになったことがわかりました。

Spring Boot が Redis マスター/スレーブセンチネルメソッドを統合する方法6380 と 6381 の設定ファイルを確認します

cat config/redis-6380.conf
replicaof 192.168.4.176 6381
replicaof 变成了192.168.4.176 6381,而不是刚开始配置时的192.168.4.176 6379
cat config/redis-6381.conf 
replicaof 的配置被删除了

Redis インスタンスを再起動します6379

redis-server config/redis-6379.conf

6379 は 6381 のスレーブ ノードになります

RedisTemplate は現在サポートしていません読み取りと書き込みが分離されているため、読み取り操作と書き込み操作の両方が処理のためにマスター ノードに送信されることになりますが、これは非常に不快です。上記のコードを実行し、3 つの Redis クライアントでモニターを実行すると、マスターのみが get および set コマンドを実行し、スレーブ ノードは set コマンドのみを実行することがわかります。

以上がSpring Boot が Redis マスター/スレーブセンチネルメソッドを統合する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

声明:
この記事はyisu.comで複製されています。侵害がある場合は、admin@php.cn までご連絡ください。