From f17032b1b484a76a11f665d114c22d61459019dc Mon Sep 17 00:00:00 2001 From: "zhenghaiyang@ele-cloud.com" Date: Tue, 5 Dec 2023 13:35:02 +0800 Subject: [PATCH] =?UTF-8?q?feature=201.=E6=9B=B4=E6=8D=A2redis=E9=94=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../order/invoice/config/RedissonConfig.java | 80 +++++++++---------- 1 file changed, 40 insertions(+), 40 deletions(-) diff --git a/order-management-invoice/src/main/java/com/dxhy/order/invoice/config/RedissonConfig.java b/order-management-invoice/src/main/java/com/dxhy/order/invoice/config/RedissonConfig.java index d0252f2e..806bb0f8 100644 --- a/order-management-invoice/src/main/java/com/dxhy/order/invoice/config/RedissonConfig.java +++ b/order-management-invoice/src/main/java/com/dxhy/order/invoice/config/RedissonConfig.java @@ -1,40 +1,40 @@ -//package com.dxhy.order.invoice.config; -// -//import org.apache.commons.lang3.StringUtils; -//import org.redisson.Redisson; -//import org.redisson.api.RedissonClient; -//import org.redisson.config.Config; -//import org.redisson.config.ReadMode; -//import org.redisson.config.SentinelServersConfig; -//import org.springframework.boot.autoconfigure.data.redis.RedisProperties; -//import org.springframework.context.annotation.Bean; -// -//import javax.annotation.Resource; -//import java.util.List; -// -//public class RedissonConfig { -// -// @Resource -// private RedisProperties redisProperties; -// -// //哨兵模式配置 -// @Bean -// RedissonClient redissonSentinel() { -// Config config = new Config(); -// RedisProperties.Sentinel sentinel = redisProperties.getSentinel(); -// List newNodes = sentinel.getNodes(); -// newNodes.stream().forEach((index) -> newNodes.add( -// index.startsWith("redis://") ? index : "redis://" + index)); -// -// SentinelServersConfig serverConfig = config.useSentinelServers() -// .addSentinelAddress(newNodes.toArray(new String[0])) -// .setMasterName(sentinel.getMaster()) -// .setReadMode(ReadMode.SLAVE); -// -// if (StringUtils.isNotBlank(redisProperties.getPassword())) { -// serverConfig.setPassword(redisProperties.getPassword()); -// } -// return Redisson.create(config); -// } -// -//} +package com.dxhy.order.invoice.config; + +import org.apache.commons.lang3.StringUtils; +import org.redisson.Redisson; +import org.redisson.api.RedissonClient; +import org.redisson.config.Config; +import org.redisson.config.ReadMode; +import org.redisson.config.SentinelServersConfig; +import org.springframework.boot.autoconfigure.data.redis.RedisProperties; +import org.springframework.context.annotation.Bean; + +import javax.annotation.Resource; +import java.util.List; + +public class RedissonConfig { + + @Resource + private RedisProperties redisProperties; + + //哨兵模式配置 + @Bean + RedissonClient redissonSentinel() { + Config config = new Config(); + RedisProperties.Sentinel sentinel = redisProperties.getSentinel(); + List newNodes = sentinel.getNodes(); + newNodes.stream().forEach((index) -> newNodes.add( + index.startsWith("redis://") ? index : "redis://" + index)); + + SentinelServersConfig serverConfig = config.useSentinelServers() + .addSentinelAddress(newNodes.toArray(new String[0])) + .setMasterName(sentinel.getMaster()) + .setReadMode(ReadMode.SLAVE); + + if (StringUtils.isNotBlank(redisProperties.getPassword())) { + serverConfig.setPassword(redisProperties.getPassword()); + } + return Redisson.create(config); + } + +}