Home > Database > Redis > body text

How spring boot integrates redis master-slave sentinel method

WBOY
Release: 2023-06-02 09:22:21
forward
1712 people have browsed it

springboot integrates redis master-slave sentinel

One master, two slaves and three sentinel configuration

  • 1, master:127.0.0.1:6379

  • 2, slave1:127.0.0.1:6380

  • 3, slave2:127.0.0.1:6381

  • 4, sentinel1 :127.0.0.1:26379

  • 5, sentinel2:127.0.0.1:26479

  • 6, sentinel3:127.0.0.1:26579

  • 7. Monitoring host name: mymaster

  • 8. Attached is the configuration of 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
Copy after login

Create a new spring boot project and add Redis dependency

How spring boot integrates redis master-slave sentinel method

The project structure

is as follows:

How spring boot integrates redis master-slave sentinel method

pom The file is as follows:

<?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>
Copy after login

Modify the application.properties configuration file

Add the following content to the configuration file:

########################################################
###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
Copy after login

Create a new Redis service

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);
	}
}
Copy after login

The dependent vo is as follows:

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 + "]";
	}
}
Copy after login

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);
	} 
}
Copy after login

Test result

name:chhliu

Student [id=001, name=chhliu, age=28, grade=first grade]

redis sentinel mode sentinel and springboot integration

Redis’ sentinel mode is an official high-availability solution, and the configuration is very simple.

Install Redis cluster

This article uses redis-5.0.5. Redis is installed in the /soft/redis directory. You need to create a new /soft/redis/data directory

Master node configuration

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"
Copy after login

Slave node 1 configuration

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
Copy after login

Configuration from node 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
Copy after login

Configuration instructions

# bind 127.0.0.1 Comment out this configuration so that other machines can connect to redis

protected-mode no Turn off the protected mode so that other machines can connect to redis

daemonize background Mode startup

The redis-v5 version uses replicaof to replace the old slaveof directive.

Start these 3 nodes and run them in the /soft/redis directory

redis-server config/redis-6379.conf
redis-server config/redis-6380.conf
redis-server config/redis-6381.conf
Copy after login

Open the master node client to see if the configuration is successful

redis-cli -p 6379
info replication
Copy after login

How spring boot integrates redis master-slave sentinel method

Configure 3 more sentinels to monitor the cluster

Sentinel node 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
Copy after login

Sentinel Node 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
Copy after login

Sentinel Node 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
Copy after login

Configuration instructions

monitor mymaster 192.168.4.176 6379 2
Copy after login

The name of the Master host is mymaster, and the IP address is 192.168.4.176. The following 2 means that 2 sentinels think that the master is offline, so the master is offline. It is recommended to set it to the number of sentinel nodes/2 1

down-after-milliseconds
Copy after login

Send a ping request to the redis node, but no reply is received within the specified time. , it is considered that the node should be taken offline

parallel-syncs
Copy after login

When performing failover, the maximum number of slave nodes can synchronize the new master server at the same time.

Start Sentinel

redis-sentinel config/redis-sentinel-26379.conf
redis-sentinel config/redis-sentinel-26380.conf
redis-sentinel config/redis-sentinel-26381.conf
Copy after login

Configure spring-boot

Import dependencies in pom.xml

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

Add two lines to application.properties Configuration

# 使用哨兵模式不能加以下两行配置,其他配置可以加
# 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
Copy after login

Write a test class to run

@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));
        } 
    } 
}
Copy after login

Then kill the process of the master instance (redis with port number 6379)

ps -ef|grep redis
kill -9 11110
Copy after login

Observe the code editor console output, After a short period of time (about 50s), the program ran normally again

Executed info replication on nodes 6380 and 6381, and found that 6381 became the master node

How spring boot integrates redis master-slave sentinel method

Check the configuration files of 6380 and 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 的配置被删除了
Copy after login

Restart the redis instance 6379

redis-server config/redis-6379.conf
Copy after login

6379 becomes the slave node of 6381

RedisTemplate currently does not support reading Write separation, so both read and write operations will be sent to the master node for processing, which is quite unpleasant. Run the above code and run the monitor on three redis clients and find that only the master will run the get and set commands, and the slave node will only run the set command.

The above is the detailed content of How spring boot integrates redis master-slave sentinel method. For more information, please follow other related articles on the PHP Chinese website!

Related labels:
source:yisu.com
Statement of this Website
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
Popular Tutorials
More>
Latest Downloads
More>
Web Effects
Website Source Code
Website Materials
Front End Template
About us Disclaimer Sitemap
php.cn:Public welfare online PHP training,Help PHP learners grow quickly!