Spring boot 整合redis集群

一、环境搭建

Redis集群环境搭建：https://blog.csdn.net/qq497811258/article/details/108124697

二、创建Spring boot项目

1.创建boot项目

2.创建配置文件

spring:redis:database: 0 # Redis数据库索引（默认为0）timeout: 100000 # 连接超时时间（毫秒）#    jedis:#      pool:#        max-active: 8 # 连接池最大连接数（使用负值表示没有限制）#        max-idle: 8 # 连接池中的最大空闲连接#        max-wait: -1 # 连接池最大阻塞等待时间（使用负值表示没有限制）#        min-idle: 0 # 连接池中的最小空闲连接cluster:nodes:- 10.1.194.193:6379- 10.1.194.193:6380- 10.1.194.193:6381- 10.1.194.193:6382- 10.1.194.193:6383- 10.1.194.193:6384connectionTimeout: 6000soTimeout: 6000maxAttempts: 5# password:

、

3.初始化RedisTemplate

package com.lagou.demo.config;import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.boot.autoconfigure.AutoConfigureAfter;
import org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration;
import org.springframework.cache.annotation.CachingConfigurerSupport;
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.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;@Configuration
@AutoConfigureAfter(RedisAutoConfiguration.class)
public class RedisConfig extends CachingConfigurerSupport {@Beanpublic RedisTemplate<String,Object> redisTemplate(LettuceConnectionFactory factory){RedisTemplate<String,Object> template=new RedisTemplate<>();template.setConnectionFactory(factory);Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);ObjectMapper objectMapper = new ObjectMapper();objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);jackson2JsonRedisSerializer.setObjectMapper(objectMapper);StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();//key采用String的序列化方式template.setKeySerializer(stringRedisSerializer);//value采用jackson序列化方式template.setValueSerializer(jackson2JsonRedisSerializer);//hash的key采用String的序列化方式template.setHashKeySerializer(stringRedisSerializer);//hash的value采用String的序列化方式template.setHashValueSerializer(jackson2JsonRedisSerializer);template.afterPropertiesSet();return template;}}

4.编写测试代码

我这边使用了2种方式调用

package com.lagou.demo;import org.junit.jupiter.api.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.test.context.junit4.SpringRunner;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPoolConfig;import java.util.HashSet;
import java.util.Set;@SpringBootTest
@RunWith(SpringRunner.class)
class DemoApplicationTests {@Autowiredprivate RedisTemplate redisTemplate;@Testvoid get() {redisTemplate.opsForValue().set("sex","nan");System.out.println(redisTemplate.opsForValue().get("name"));System.out.println("------------------------------------------------------");JedisCluster jcd = null;try {JedisPoolConfig config = new JedisPoolConfig();Set<HostAndPort> jedisClusterNode = new HashSet<>();jedisClusterNode.add(new HostAndPort("10.1.194.193", 6379));jedisClusterNode.add(new HostAndPort("10.1.194.193", 6380));jedisClusterNode.add(new HostAndPort("10.1.194.193", 6381));jedisClusterNode.add(new HostAndPort("10.1.194.193", 6382));jedisClusterNode.add(new HostAndPort("10.1.194.193", 6383));jedisClusterNode.add(new HostAndPort("10.1.194.193", 6384));jedisClusterNode.add(new HostAndPort("10.1.194.193", 6385));jedisClusterNode.add(new HostAndPort("10.1.194.193", 6386));jcd = new JedisCluster(jedisClusterNode, config);//jcd.set("name", "zhang3");String value = jcd.get("sex");System.out.println("get val from redis cluster: " + value);} finally {if (jcd != null){jcd.close();}}}}

5.验证

[由零开始]Spring boot 整合redis集群相关推荐

超完整！Springboot整合redis集群（Sentine），spring boot自动配置集成redis集群（Sentine）
1.添加maven依赖注意maven版本依赖,版本要相互匹配,如不知道如何查看相对应的版本时,可进入博主主页查看博主上一篇博文. <parent><groupId>org.s ...
Spring Boot基础学习笔记08：Spring Boot整合Redis
文章目录零.学习目标 1.熟悉Redis相关概念 2.掌握使用Spring Boot整合Redis 一.Redis概述 1.Redis简介 2.Redis优点 (1)存取速度快 (2)数据类型丰富 ...
猿创征文 | 微服务 Spring Boot 整合Redis 实战开发解决高并发数据缓存
文章目录一.什么是缓存? ⛅为什么用缓存? ⚡如何使用缓存二.实现一个商家缓存 ⌛环境搭建 ♨️核心源码 ✅测试接口三.采用微服务 Spring Boot 注解开启缓存 ✂️@CacheEn ...
Spring boot - 整合 Redis缓存（上）
一.配置Pom文件在使用spring boot 2.0整合redis时遇到了好多问题,网上很多例子都是1.x版本的.故2.0没有折腾好所以将2.0降到了1.5.降级后由于thymeleaf版本也会从 ...
十一、Spring Boot整合Redis(一)
Spring Boot整合Redis 1. SpringBoot+单例Redis 1)引入依赖 <dependency> <groupId>org.springf ...
Spring boot整合Redis（入门教程）
目录源码分析 jedis VS lettuce 整合测试导入依赖配置连接测试存入字符串存入对象五大数据类型操作自定义RedisConfig 存入对象 Redis工具类(常用API) 以 ...
大聪明教你学Java | Spring Boot 整合 Redis 实现访问量统计
前言之前开发系统的时候客户提到了一个需求:需要统计某些页面的访问量,记得当时还纠结了一阵子,不知道怎么去实现这个功能,后来还是在大佬的带领下借助 Redis 实现了这个功能.今天又回想起了这件事,正 ...
Spring Boot 整合Redis 包含Java操作Redis哨兵作者：哇塞大嘴好帥（哇塞大嘴好帅）
Spring Boot 整合Redis 包含Java操作Redis哨兵作者:哇塞大嘴好帥(哇塞大嘴好帅) 1. 配置环境在SpringBoot2.0版本以后,原来使用的jedis被替换成为了let ...
Spring boot整合Redis实现发布订阅（超详细）
Redis发布订阅基础知识相关命令订阅者/等待接收消息发布者/发送消息订阅者/成功接收消息常用命令汇总原理 Spring boot整合redis 导入依赖 Redis配置消息封装类(M ...

[由零开始]Spring boot 整合redis集群

Spring boot 整合redis集群

一、环境搭建

二、创建Spring boot项目

1.创建boot项目

2.创建配置文件

3.初始化RedisTemplate

4.编写测试代码

5.验证

[由零开始]Spring boot 整合redis集群相关推荐

最新文章

热门文章