目录

一、springboot整合单节点redis

1、添加依赖

2、添加配置application.yml配置

3、添加配置类

4、工具类

5、发布与订阅

5.1 添加配置对象

5.2 定义消息接收类

5.3 使用：在redisUtils工具类中添加发布消息的方法

5.4 发布消息

二、哨兵-主备读写分离

1.添加依赖

2、配置yml

3、添加配置文件

4、工具类同上

三、集群

1、添加Spring Boot和Redis依赖

2、修改配置文件

3、配置类(创建RedisTemplate实例)

4、工具类同上

5、使用postman调接口测试Redis集群

一、springboot整合单节点redis

1、添加依赖

    org.springframework.boot    spring-boot-starter-data-redis    2.7.0

2、添加配置application.yml配置

spring:  redis:    database: 0    host: 127.0.0.1    port: 6379    password:     lettuce:      pool:         # 连接池中的最大空闲连接 默认8              max-idle: 8        # 连接池中的最小空闲连接 默认0        min-idle: 0        # 连接池最大连接数 默认8 ，负数表示没有限制        max-active: 8        # 连接池最大阻塞等待时间（使用负值表示没有限制） 默认-1        max-wait: -1    timeout: 30000

3、添加配置类

import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.data.redis.connection.RedisConnectionFactory;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;import org.springframework.data.redis.serializer.StringRedisSerializer;import javax.annotation.Resource;@Configurationpublic class RedisConfiguration {    @Resource    private RedisConnectionFactory redisConnectionFactory;    @Bean    public RedisTemplate redisTemplate() {        RedisTemplate redisTemplate= new RedisTemplate<>();        // 可根据需要添加序列化器        // template.setDefaultSerializer(new Jackson2JsonRedisSerializer<>(Object.class));        // key采用String的序列化方式        redisTemplate.setKeySerializer(new StringRedisSerializer());        redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());        redisTemplate.setHashKeySerializer(new StringRedisSerializer());        redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());        redisTemplate.setConnectionFactory(redisConnectionFactory);        return redisTemplate;    }}

4、工具类

import com.fasterxml.jackson.core.type.TypeReference;import com.fasterxml.jackson.databind.ObjectMapper;import lombok.extern.log4j.Log4j2;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.data.redis.core.ZSetOperations;import org.springframework.stereotype.Component;import org.springframework.util.CollectionUtils;import org.springframework.util.StringUtils;import java.io.IOException;import java.util.Collection;import java.util.List;import java.util.Map;import java.util.Set;import java.util.concurrent.TimeUnit;@Component@Log4j2public final class RedisUtil {    @Autowired    private RedisTemplate redisTemplate;    public Map obtainMap(String jsonString) {        ObjectMapper mapper = new ObjectMapper();        Map map = null;        try {            map = mapper.readValue(jsonString, new TypeReference>() {});        } catch (IOException e) {            e.printStackTrace();        }        return map;    }    // =============================common============================        public boolean expire(String key, long time) {        try {            if (time > 0) {                redisTemplate.expire(key, time, TimeUnit.SECONDS);            }            return true;        } catch (Exception e) {            e.printStackTrace();            return false;        }    }        public long getExpire(String key) {        return redisTemplate.getExpire(key, TimeUnit.SECONDS);    }        public boolean hasKey(String key) {        try {            return Boolean.TRUE.equals(redisTemplate.hasKey(key));        } catch (Exception e) {            e.printStackTrace();            return false;        }    }        @SuppressWarnings("unchecked")    public void del(String... key) {        if (key != null && key.length > 0) {            if (key.length == 1) {                redisTemplate.delete(key[0]);            } else {                redisTemplate.delete((Collection) CollectionUtils.arrayToList(key));            }        }    }    // ============================String=============================        public Object get(String key) {        return key == null ? null : redisTemplate.opsForValue().get(key);    }        public boolean set(String key, Object value) {        try {            redisTemplate.opsForValue().set(key, value);            return true;        } catch (Exception e) {            e.printStackTrace();            return false;        }    }        public boolean set(String key, Object value, long time) {        try {            if (time > 0) {                redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);            } else {                set(key, value);            }            return true;        } catch (Exception e) {            e.printStackTrace();            return false;        }    }        public long incr(String key, long delta) {        if (delta < 0) {            throw new RuntimeException("递增因子必须大于0");        }        return redisTemplate.opsForValue().increment(key, delta);    }        public long decr(String key, long delta) {        if (delta < 0) {            throw new RuntimeException("递减因子必须大于0");        }        return redisTemplate.opsForValue().increment(key, -delta);    }    // ================================Map=================================        public Object hget(String key, String item) {        return redisTemplate.opsForHash().get(key, item);    }        public Map hmget(String key) {        return redisTemplate.opsForHash().entries(key);    }        public boolean hmset(String key, Map map) {        try {            redisTemplate.opsForHash().putAll(key, map);            return true;        } catch (Exception e) {            e.printStackTrace();            return false;        }    }        public boolean hmset(String key, Map map, long time) {        try {            redisTemplate.opsForHash().putAll(key, map);            if (time > 0) {                expire(key, time);            }            return true;        } catch (Exception e) {            e.printStackTrace();            return false;        }    }        public boolean hset(String key, String item, Object value) {        try {            redisTemplate.opsForHash().put(key, item, value);            return true;        } catch (Exception e) {            e.printStackTrace();            return false;        }    }        public boolean hset(String key, String item, Object value, long time) {        try {            redisTemplate.opsForHash().put(key, item, value);            if (time > 0) {                expire(key, time);            }            return true;        } catch (Exception e) {            e.printStackTrace();            return false;        }    }        public void hdel(String key, Object... item) {        redisTemplate.opsForHash().delete(key, item);    }        public boolean hHasKey(String key, String item) {        return redisTemplate.opsForHash().hasKey(key, item);    }        public double hincr(String key, String item, double by) {        return redisTemplate.opsForHash().increment(key, item, by);    }        public double hdecr(String key, String item, double by) {        return redisTemplate.opsForHash().increment(key, item, -by);    }    // ============================set=============================        public Set