redis spring 哨兵配置

程序员文章站 2022-07-01 09:26:30

...

Sentinel的工作方式:

1)：每个Sentinel以每秒钟一次的频率向它所知的Master，Slave以及其他 Sentinel 实例发送一个 PING 命令 
2)：如果一个实例（instance）距离最后一次有效回复 PING 命令的时间超过 down-after-milliseconds 选项所指定的值， 则这个实例会被 Sentinel 标记为主观下线。 
3)：如果一个Master被标记为主观下线，则正在监视这个Master的所有 Sentinel 要以每秒一次的频率确认Master的确进入了主观下线状态。 
4)：当有足够数量的 Sentinel（大于等于配置文件指定的值）在指定的时间范围内确认Master的确进入了主观下线状态， 则Master会被标记为客观下线 
5)：在一般情况下， 每个 Sentinel 会以每 10 秒一次的频率向它已知的所有Master，Slave发送 INFO 命令 
6)：当Master被 Sentinel 标记为客观下线时，Sentinel 向下线的 Master 的所有 Slave 发送 INFO 命令的频率会从 10 秒一次改为每秒一次 
7)：若没有足够数量的 Sentinel 同意 Master 已经下线， Master 的客观下线状态就会被移除。 
若 Master 重新向 Sentinel 的 PING 命令返回有效回复， Master 的主观下线状态就会被移除。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:jee="http://www.springframework.org/schema/jee"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xsi:schemaLocation="
        http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
		http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd
		http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-4.0.xsd
		http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd">
	
	<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
		<!-- redis最大连接数最好设置为200，不然会出现很多报错 -->
		<property name="maxTotal" value="200"></property>
		<property name="maxIdle" value="200"></property>
		<property name="minIdle" value="6"></property>
		<!-- 在抛出异常之前，调用的线程将会阻塞maxWaitMillis时长。默认值为true。推荐在生产环境下设置为true；测试环境下设置为false。 -->
		<property name="blockWhenExhausted" value="false"></property>
		<property name="maxWaitMillis" value="1000"></property>
	</bean>
	<bean id="sentinelConfiguration" class="org.springframework.data.redis.connection.RedisSentinelConfiguration">
		<property name="master">
			<bean class="org.springframework.data.redis.connection.RedisNode">
				<property name="name" value="mymaster"></property>
			</bean>
		</property>
		<property name="sentinels">
			<set>
				<bean class="org.springframework.data.redis.connection.RedisNode">
					<constructor-arg name="host" value="10.153.29.54"></constructor-arg>
					<constructor-arg name="port" value="16379"></constructor-arg>
				</bean>
				<bean class="org.springframework.data.redis.connection.RedisNode">
					<constructor-arg name="host" value="10.153.29.54"></constructor-arg>
					<constructor-arg name="port" value="26379"></constructor-arg>
				</bean>
				<bean class="org.springframework.data.redis.connection.RedisNode">
					<constructor-arg name="host" value="10.153.29.55"></constructor-arg>
					<constructor-arg name="port" value="16379"></constructor-arg>
				</bean>
			</set>
		</property>
	</bean>
	
	<bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"
		destroy-method="destroy">
		<property name="timeout" value="15000" />
		<property name="database" value="0" />
		<property name="password" value="" />
		<property name="usePool" value="true" />
		<property name="poolConfig" ref="jedisPoolConfig" />
		<constructor-arg name="sentinelConfig" ref="sentinelConfiguration"></constructor-arg>
	</bean>

	<!-- redis template definition p表示对该bean里面的属性进行注入，格式为p:属性名=注入的对象 效果与在bean里面使用<property>标签一样 -->
	<bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate" p:connection-factory-ref="jedisConnectionFactory">
		<property name="defaultSerializer">
			<bean class="org.springframework.data.redis.serializer.StringRedisSerializer" />
		</property>
	</bean>
	<!-- 对string操作的封装 -->
	<bean id="stringRedisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate"
		p:connection-factory-ref="jedisConnectionFactory" >
		<property name="defaultSerializer">
			<bean class="org.springframework.data.redis.serializer.StringRedisSerializer" />
		</property>
	</bean>
	
	
</beans>

import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.hash.HashMapper;
import org.springframework.stereotype.Service;
/**
 * 
 * @author baoy
 *
 */
@Service
public class RedisRepositoryImpl implements RedisRepository {
	//private static final Logger logger = LoggerFactory.getLogger(RedisRepositoryImpl.class);
	@Autowired
	private StringRedisTemplate stringRedisTemplate;
	//@Autowired
	//private RedisTemplate redisTemplate;
	
	private String keyPrefix = "";
	public void setKeyPrefix(String keyPrefix) {
		if (keyPrefix == null || "".equals(keyPrefix)) {
			this.keyPrefix = "";
		} else {
			this.keyPrefix = keyPrefix;
		}
	}

	/**
	 * <pre>
	 * 命令：ttl key
	 * 说明：以秒为单位，返回给定 key的剩余生存时间(TTL, time to live)。
	 * </pre>
	 * @param key
	 * @return
	 */
	public long ttl(String key) {
		return stringRedisTemplate.getExpire(keyPrefix+key);
	}

	/**
	 * <pre>
	 * 命令：keys pattern
	 * 说明：查找所有符合给定模式 pattern的 key
	 * </pre>
	 */
	public Set<String> keys(String pattern) {
		return stringRedisTemplate.keys(pattern);
	}

	/**
	 * <pre>
	 * 命令：del key
	 * 说明：删除一个key
	 * </pre>
	 * @param key
	 */
	public void del(String key) {
		stringRedisTemplate.delete(keyPrefix+key);
	}

	//****************String

	/**
	 * <pre>
	 * 命令：set key value
	 * 说明：将key的值设置为value
	 * </pre>
	 * @param key
	 * @param value
	 */
	public void set(String key, String value) {
		stringRedisTemplate.opsForValue().set(keyPrefix+key, value);
	}
	/**
	 * <pre>
	 * 命令：SET key value EX seconds
	 * 说明：设置key值的同时，为该key设置超时时间（秒）
	 * </pre>
	 * @param key
	 * @param value
	 * @param timeout
	 */
	public void set(String key, String value, long timeout) {
		stringRedisTemplate.opsForValue().set(keyPrefix+key, value, timeout, TimeUnit.SECONDS);
	}
	/**
	 * <pre>
	 * 命令：setNx key value
	 * 含义：与set的区别是，如果不存在时，写入；存在时，不覆盖
	 * </pre>
	 * @param key
	 * @param value
	 */
	public boolean setNx(String key, String value) {
		return stringRedisTemplate.opsForValue().setIfAbsent(keyPrefix+key, value);
	}
	/**
	 * <pre>
	 * 命令：GET key
	 * 说明：获取key值
	 * </pre>
	 * @param key
	 * @return value
	 */
	public String get(String key) {
		return stringRedisTemplate.opsForValue().get(keyPrefix+key);
	}

	//****************Hash
	/**
	 * <pre>
	 * 命令：hSet key field value
	 * 含义：
	 * 1、将哈希表 key中的域 field的值设为 value
	 * 2、覆盖旧有field的value
	 * </pre>
	 * @param key
	 * @param field
	 * @param value
	 */
	public void hSet(String key, String field, Object value) {
		stringRedisTemplate.opsForHash().put(keyPrefix+key, field, value);
	}
	/**
	 * <pre>
	 * 命令：hSetNx key field value
	 * 含义：与hSet的区别是，如果不存在时，写入；存在时，不覆盖
	 * </pre>
	 * @param key
	 * @param field
	 * @param value
	 */
	public boolean hSetNx(String key, String field, Object value) {
		return stringRedisTemplate.opsForHash().putIfAbsent(keyPrefix+key, field, value);
	}
	/**
	 * <pre>
	 * 命令：HGET key field
	 * 说明：返回哈希表 key中给定域 field的值
	 * </pre>
	 * @param key
	 * @param field
	 * @return
	 */
	public String hGet(String key, String field) {
		return (String) stringRedisTemplate.opsForHash().get(keyPrefix+key, field);
	}
	/**
	 * <pre>
	 * 命令：hGetAll key
	 * 说明：获取指定key先所有的key/value的键值对
	 * </pre>
	 * @param key
	 * @return
	 */
	public Map hGetAll(String key) {
		return (Map) stringRedisTemplate.opsForHash().entries(keyPrefix+key);
	}
	/**
	 * <pre>
	 * 命令：hDel key field [field ...]
	 * 说明：删除哈希表 key 中的一个或多个指定域，不存在的域将被忽略。
	 * </pre>
	 * @param key
	 * @param fields
	 */
	public void hDel(String key, Object... fields) {
		stringRedisTemplate.opsForHash().delete(keyPrefix+key, fields);
	}

	//****************List
	/**
	 * <pre>
	 * 命令：lPush key value
	 * 说明：
	 * 1.将一个值 value插入到列表 key的最左边
	 * 2.当该列表key不存在时，则创建
	 * </pre>
	 * @param key
	 * @param value
	 * @return 执行 lPush命令后，列表的长度
	 */
	public long lPush(String key, String value) { 
		return stringRedisTemplate.opsForList().leftPush(keyPrefix+key, value);
	}

	/**
	 * <pre>
	 * 命令：lPop key
	 * 说明：移除该列表key最左边的元素
	 * </pre>
	 * @param key
	 * @return 列表key的最左边元素。
	 */
	public String lPop(String key) {
		return stringRedisTemplate.opsForList().leftPop(keyPrefix+key);
	}
	
	public List<String> range(String key,int start,int end){
		return stringRedisTemplate.opsForList().range(keyPrefix+key, start, end);
	}
	
	public long llen(String key){
		return stringRedisTemplate.opsForList().size(keyPrefix+key);
	}

	/**
	 * <pre>
	 * 命令：rPush key value
	 * 说明：向list最右边插入元素value
	 * </pre>
	 * @param key
	 * @param value
	 * @return 执行 rPush命令后，列表的长度
	 */
	public long rPush(String key, String value) { 
		return stringRedisTemplate.opsForList().rightPush(keyPrefix+key, value);
	}

	/**
	 * <pre>
	 * 命令：rPop key
	 * 说明：移除并返回列表 key的最右边元素
	 * </pre>
	 * @param key
	 * @return 列表key的最右边元素。
	 */
	public String rPop(String key) {
		return stringRedisTemplate.opsForList().rightPop(keyPrefix+key);
	}

	//****************Set
	/**
	 * <pre>
	 * 命令：sAdd key value
	 * 说明：
	 * 1.将一个 value元素加入到集合 key当中
	 * 2.已经存在于集合的 value元素将被忽略。
	 * </pre>
	 * @param key
	 * @param value
	 */
	public Long sAdd(String key, String value) {
		return stringRedisTemplate.opsForSet().add(keyPrefix+key, value);
	}
	/**
	 * <pre>
	 * 命令：sMembers key
	 * 说明：返回集合 key 中的所有成员。
	 * </pre>
	 * @param key
	 * @return
	 */
	public Set<String> sMembers(String key) {
		return stringRedisTemplate.opsForSet().members(keyPrefix+key);
	}
	/**
	 * <pre>
	 * 命令：sRem key v1[v2 v3…]。
	 * 说明：删除key中指定的values
	 * </pre>
	 * @param key
	 * @param values
	 * @return 返回被删除的元素的数量，如果没有被删除的元素，则返回0
	 */
	public Long sRem(String key, Object... values) {
		return stringRedisTemplate.opsForSet().remove(keyPrefix+key, values);
	}
	//****************SortedSet
	/**
	 * <pre>
	 * 命令：zAdd key score member
	 * 说明：将一个 member元素及其 score值加入到有序集 key当中。
	 * <pre>
	 * @param key
	 * @param score
	 * @param value
	 */
	public void zAdd(String key, double score, String value) {
		stringRedisTemplate.opsForZSet().add(keyPrefix+key, value, score);
	}
	/**
	 * <pre>
	 * 命令：zRange key start stop
	 * 说明：返回有序集 key中，指定区间内的成员。
	 * </pre>
	 * @param key
	 * @param start
	 * @param stop
	 * @return
	 */
	public Set<String> zRange(String key, double start, double stop) {
		return stringRedisTemplate.opsForZSet().rangeByScore(keyPrefix+key, start, stop);
	}
	//=====obj2map map2obj
	/**
	 * 对象转map。可应用于多个对象（一个类中的属性是另外一个类）
	 * @param t
	 * @param mapper
	 * @return
	 */
	public <T> Map obj2map(T t, HashMapper<T, String, String> mapper) {
		return mapper.toHash(t);
	}
	/**
	 * map转对象。只应用于单个对象
	 * @param map
	 * @param mapper
	 * @return
	 */
	public <T> T map2obj(Map map, HashMapper<T, String, String> mapper) {
		return mapper.fromHash(map);
	}
}

import java.util.List;
import java.util.Map;
import java.util.Set;

import org.springframework.data.redis.hash.HashMapper;
/**
 * 
 * @author baoy
 *
 */
public interface RedisRepository {
	/**
	 * <pre>
	 * 命令：ttl key
	 * 说明：以秒为单位，返回给定 key的剩余生存时间(TTL, time to live)。
	 * </pre>
	 * @param key
	 * @return
	 */
	long ttl(String key);

	/**
	 * <pre>
	 * 命令：keys pattern
	 * 说明：查找所有符合给定模式 pattern的 key
	 * </pre>
	 */
	Set<String> keys(String pattern);

	/**
	 * <pre>
	 * 命令：del key
	 * 说明：删除一个key
	 * </pre>
	 * @param key
	 */
	void del(String key);

	//****************String

	/**
	 * <pre>
	 * 命令：set key value
	 * 说明：将key的值设置为value
	 * </pre>
	 * @param key
	 * @param value
	 */
	void set(String key, String value);
	/**
	 * <pre>
	 * 命令：SET key value EX seconds
	 * 说明：设置key值的同时，为该key设置超时时间（秒）
	 * </pre>
	 * @param key
	 * @param value
	 * @param timeout
	 */
	void set(String key, String value, long timeout);
	/**
	 * <pre>
	 * 命令：setNx key value
	 * 含义：与set的区别是，如果不存在时，写入；存在时，不覆盖
	 * </pre>
	 * @param key
	 * @param value
	 */
	boolean setNx(String key, String  value); 
	/**
	 * <pre>
	 * 命令：GET key
	 * 说明：获取key值
	 * </pre>
	 * @param key
	 * @return value
	 */
	String get(String key);

	//****************Hash
	/**
	 * <pre>
	 * 命令：hSet key field value
	 * 含义：
	 * 1、将哈希表 key中的域 field的值设为 value
	 * 2、覆盖旧有field的value
	 * </pre>
	 * @param key
	 * @param field
	 * @param value
	 */
	void hSet(String key, String field, Object value);
	/**
	 * <pre>
	 * 命令：hSetNx key field value
	 * 含义：与hSet的区别是，如果不存在时，写入；存在时，不覆盖
	 * </pre>
	 * @param key
	 * @param field
	 * @param value
	 */
	boolean hSetNx(String key, String field, Object value);
	/**
	 * <pre>
	 * 命令：HGET key field
	 * 说明：返回哈希表 key中给定域 field的值
	 * </pre>
	 * @param key
	 * @param field
	 * @return
	 */
	String hGet(String key, String field);
	/**
	 * <pre>
	 * 命令：hGetAll key
	 * 说明：获取指定key先所有的key/value的键值对
	 * </pre>
	 * @param key
	 * @return
	 */
	Map hGetAll(String key);
	/**
	 * <pre>
	 * 命令：hDel key field [field ...]
	 * 说明：删除哈希表 key 中的一个或多个指定域，不存在的域将被忽略。
	 * </pre>
	 * @param key
	 * @param fields
	 */
	void hDel(String key, Object... fields);

	//****************List
	/**
	 * <pre>
	 * 命令：lPush key value
	 * 说明：
	 * 1.将一个值 value插入到列表 key的最左边
	 * 2.当该列表key不存在时，则创建
	 * </pre>
	 * @param key
	 * @param value
	 * @return 执行 lPush命令后，列表的长度
	 */
	long lPush(String key, String value);

	/**
	 * <pre>
	 * 命令：lPop key
	 * 说明：移除该列表key最左边的元素
	 * </pre>
	 * @param key
	 * @return 列表key的最左边元素。
	 */
	String lPop(String key);

	List<String> range(String key,int start,int end);
	
	long llen(String key);
	
	/**
	 * <pre>
	 * 命令：rPush key value
	 * 说明：向list最右边插入元素value
	 * </pre>
	 * @param key
	 * @param value
	 * @return 执行 rPush命令后，列表的长度
	 */
	long rPush(String key, String value);

	/**
	 * <pre>
	 * 命令：rPop key
	 * 说明：移除并返回列表 key的最右边元素
	 * </pre>
	 * @param key
	 * @return 列表key的最右边元素。
	 */
	String rPop(String key);

	//****************Set
	/**
	 * <pre>
	 * 命令：sAdd key value
	 * 说明：
	 * 1.将一个 value元素加入到集合 key当中
	 * 2.已经存在于集合的 value元素将被忽略。
	 * </pre>
	 * @param key
	 * @param value
	 */
	Long sAdd(String key, String value);
	/**
	 * <pre>
	 * 命令：sMembers key
	 * 说明：返回集合 key 中的所有成员。
	 * </pre>
	 * @param key
	 * @return
	 */
	Set<String> sMembers(String key);
	/**
	 * <pre>
	 * 命令：sRem key v1[v2 v3…]。
	 * 说明：删除key中指定的values
	 * </pre>
	 * @param key
	 * @param values
	 * @return 返回被删除的元素的数量，如果没有被删除的元素，则返回0
	 */
	Long sRem(String key, Object... values);
	//****************SortedSet
	/**
	 * <pre>
	 * 命令：zAdd key score member
	 * 说明：将一个 member元素及其 score值加入到有序集 key当中。
	 * <pre>
	 * @param key
	 * @param score
	 * @param value
	 */
	void zAdd(String key, double score, String value);
	/**
	 * <pre>
	 * 命令：zRange key start stop
	 * 说明：返回有序集 key中，指定区间内的成员。
	 * </pre>
	 * @param key
	 * @param start
	 * @param stop
	 * @return
	 */
	Set<String> zRange(String key, double start, double stop);
	//=====obj2map map2obj
	/**
	 * 对象转map。可应用于多个对象（一个类中的属性是另外一个类）
	 * @param t
	 * @param mapper
	 * @return
	 */
	<T> Map obj2map(T t, HashMapper<T, String, String> mapper);
	/**
	 * map转对象。只应用于单个对象
	 * @param map
	 * @param mapper
	 * @return
	 */
	<T> T map2obj(Map map, HashMapper<T, String, String> mapper);
}

捐助开发者

在兴趣的驱动下,写一个免费的东西，有欣喜，也还有汗水，希望你喜欢我的作品，同时也能支持一下。当然，有钱捧个钱场（支持支付宝和微信以及扣扣群），没钱捧个人场，谢谢各位。

个人主页：http://knight-black-bob.iteye.com/

redis spring 哨兵配置

博客分类： springredis redisspring哨兵配置

谢谢您的赞助，我会做的更好！

相关标签： redis spring 哨兵配置

上一篇：你开进来干嘛？

下一篇： Python连接gbase数据库

redis spring 哨兵配置

捐助开发者

Laravel 下配置 Redis 让缓存、Session 各自使用不同的 Redis 数据库

Spring Boot 配置元数据指南

三、解决Spring MVC拦截器导致静态资源访问失败（基于java注解配置）

spring boot从redis取缓存发生java.lang.ClassCastException异常

Spring MVC五大核心组件和配置

Spring+Spring MVC+Mybatis 框架整合开发（半注解半配置文件）

Spring Boot 2整合Redis做缓存

spring boot加载资源路径配置和classpath问题解决

详解Spring Boot配置使用Logback进行日志记录的实战

Spring jndi数据源配置方法详解

redis spring 哨兵 配置

捐助开发者

Laravel 下配置 Redis 让缓存、Session 各自使用不同的 Redis 数据库

Spring Boot 配置元数据指南

三、解决Spring MVC拦截器导致静态资源访问失败（基于java注解配置）

spring boot从redis取缓存发生java.lang.ClassCastException异常

Spring MVC五大核心组件和配置

Spring+Spring MVC+Mybatis 框架整合开发（半注解半配置文件）

Spring Boot 2整合Redis做缓存

spring boot加载资源路径配置和classpath问题解决

详解Spring Boot配置使用Logback进行日志记录的实战

Spring jndi数据源配置方法详解

redis spring 哨兵配置