Springboot 集成 Redis集群配置公网IP连接报私网IP连接失败问题

1、问题：在Springboot 集成 Redis集群配置公网IP连接报私网IP连接失败，一直报私有IP连接失败

14 14:57:49.180  WARN 22012 --- [ioEventLoop-6-4] i.l.c.c.topology.ClusterTopologyRefresh  : Unable to connect to [192.168.0.19:6384]: connection timed out: /192.168.0.19:6384
2020-08-14 14:57:49.180  WARN 22012 --- [ioEventLoop-6-3] i.l.c.c.topology.ClusterTopologyRefresh  : Unable to connect to [192.168.0.19:6383]: connection timed out: /192.168.0.19:6383
2020-08-14 14:57:49.182  WARN 22012 --- [ioEventLoop-6-2] i.l.c.c.topology.ClusterTopologyRefresh  : Unable to connect to [192.168.0.19:6382]: connection timed out: /192.168.0.19:6382
2020-08-14 14:57:49.182  WARN 22012 --- [ioEventLoop-6-1] i.l.c.c.topology.ClusterTopologyRefresh  : Unable to connect to [192.168.0.19:6381]: connection timed out: /192.168.0.19:6381
2020-08-14 14:57:49.190  WARN 22012 --- [ioEventLoop-6-1] i.l.c.c.topology.ClusterTopologyRefresh  : Unable to connect to [192.168.0.19:6385]: connection timed out: /192.168.0.19:6385
2020-08-14 14:57:49.191  WARN 22012 --- [ioEventLoop-6-2] i.l.c.c.topology.ClusterTopologyRefresh  : Unable to connect to [192.168.0.19:6386]: connection timed out: /192.168.0.19:6386
2020-08-14 14:57:59.389  WARN 22012 --- [ioEventLoop-6-3] i.l.core.cluster.RedisClusterClient      : connection timed out: /192.168.0.19:6382
2020-08-14 14:58:09.391  WARN 22012 --- [ioEventLoop-6-4] i.l.core.cluster.RedisClusterClient      : connection timed out: /192.168.0.19:6381
2020-08-14 14:58:19.393  WARN 22012 --- [ioEventLoop-6-1] i.l.core.cluster.RedisClusterClient      : connection timed out: /192.168.0.19:6383
2020-08-14 14:58:29.396  WARN 22012 --- [ioEventLoop-6-2] i.l.core.cluster.RedisClusterClient      : connection timed out: /192.168.0.19:6384
2020-08-14 14:58:39.399  WARN 22012 --- [ioEventLoop-6-3] i.l.core.cluster.RedisClusterClient      : connection timed out: /192.168.0.19:6386
2020-08-14 14:58:49.402  WARN 22012 --- [ioEventLoop-6-4] i.l.core.cluster.RedisClusterClient      : connection timed out: /192.168.0.19:6385

2、配置文件

创建6个配置文件：redis-6381.conf,redis-6382.conf,redis-6383.conf,redis-6384.conf,redis-6385.conf,
redis-6386.conf。配置文件内容如下：

# 配置文件进行了精简，完整配置可自行和官方提供的完整conf文件进行对照。端口号自行对应修改#默认是 protected-mode yes，即开启保护模式， no=关闭
#在redis的配置文件中会遇到protected-mode，它直译为保护模式。
#如果设置为yes，那么只允许我们在本机的回环连接，其他机器无法连接。
#线上Redis服务，为了安全，我们建议将protected-mode设置为yes。
#protected-mode设置为yes的情况下，为了我们的应用服务可以正常访问Redis，我们需要设置Redis的bind参数或者密码参数#requirepass。
protected-mode yes
#端口号
port 6381
# IP绑定，redis不建议对公网开放，这里绑定了服务器私网IP及环回地址
bind 192.168.0.19 127.0.0.1
requirepass 123456
# redis数据文件存放的目录
dir /redis/workdata
# 日志文件
logfile "/redis/logs/cluster-node-6381.log"
# 开启AOF
appendonly yes
#后台启动
daemonize yes # 开启集群
cluster-enabled yes
# 集群持久化配置文件，内容包含其它节点的状态，持久化变量等，会自动生成在上面配置的dir目录下
cluster-config-file cluster-node-6381.conf
# 集群节点不可用的最大时间(毫秒)，如果主节点在指定时间内不可达，那么会进行故障转移
cluster-node-timeout 5000

3、springboot集成redis集群有以下配置，二选一：

1：代码配置

@Configuration
public class RedisClusterConfig {@Beanpublic RedisConnectionFactory redisConnectionFactory() {// 客户端读写分离配置LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder().readFrom(ReadFrom.REPLICA_PREFERRED).build();RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration(Arrays.asList("42.192.119.238:6381","42.192.119.238:6382","42.192.119.238:6383","42.192.119.238:6384","42.192.119.238:6385","42.192.119.238:6386"));return new LettuceConnectionFactory(redisClusterConfiguration, clientConfig);}
}

2：yml 配置

#集群模式
spring:redis:cluster:max-redirects: 3nodes:- 42.192.119.238:6381- 42.192.119.238:6382- 42.192.119.238:6383- 42.192.119.238:6384- 42.192.119.238:6385- 42.192.119.238:6386database: 0
#    host: 42.192.119.238
#    port: 6380password: timeout: 5000s #连接超时时长# 连接池最大连接数（使用负值表示没有限制）jedis:pool:max-active: 8 #连接池最大连接数量，负数表示无限，默认为8max-idle: 8 #连接池最大空闲数量，默认8min-idle: 0 #连接池最小空闲数量，默认0

4、解决链接报错问题

让Redis暴露公网IP其实在redis.conf配置文件里是能找到的，这里我们可以手动指定Redis的公网IP、端口以及总线端口(默认服务端口加10000)。
手动指定了公网ip后，Redis集群中的节点会通过公网IP进行通信，也就是外网访问。因此相关的总线端口，如下面的16381等总线端口必须在云服务器中的安全组中放开

# 配置文件进行了精简，完整配置可自行和官方提供的完整conf文件进行对照。端口号自行对应修改#默认是 protected-mode yes，即开启保护模式， no=关闭
#在redis的配置文件中会遇到protected-mode，它直译为保护模式。
#如果设置为yes，那么只允许我们在本机的回环连接，其他机器无法连接。
#线上Redis服务，为了安全，我们建议将protected-mode设置为yes。
#protected-mode设置为yes的情况下，为了我们的应用服务可以正常访问Redis，我们需要设置Redis的bind参数或者密码参数#requirepass。
protected-mode yes
#端口号
port 6381
# IP绑定，redis不建议对公网开放，这里绑定了服务器私网IP及环回地址
bind 192.168.0.19 127.0.0.1
requirepass 123456
# redis数据文件存放的目录
dir /redis/workdata
# 日志文件
logfile "/redis/logs/cluster-node-6381.log"
# 开启AOF
appendonly yes
#后台启动
daemonize yes # 开启集群
cluster-enabled yes
# 集群持久化配置文件，内容包含其它节点的状态，持久化变量等，会自动生成在上面配置的dir目录下
cluster-config-file cluster-node-6381.conf
# 集群节点不可用的最大时间(毫秒)，如果主节点在指定时间内不可达，那么会进行故障转移
cluster-node-timeout 5000# 云服务器上部署需指定公网ip
cluster-announce-ip 42.192.119.238
# Redis总线端口，用于与其它节点通信
cluster-announce-bus-port 16381

根据以上配置修改每一个redis节点的配置，注意端口不能相同

在src 目录下执行命令：

./redis-cli -c -p 6381 -h 192.168.0.19 -a 123456 cluster nodes

Warning: Using a password with '-a' or '-u' option on the command line interface may not be safe.
6297ab04ff4bbfcad778b80315619defc2f6e513 42.192.119.238:6382@16382 master - 0 1696924087000 2 connected 5461-10922
19d3955d4bacd04892c13e7a05e13c7744085896 42.192.119.238:6381@16381 myself,master - 0 1696924087000 1 connected 0-5460
3a21d6c05255229741593340a781affbdcad6236 42.192.119.238:6385@16385 slave df0858e942b03f5b3c848d1acb2a4fde1f70e290 0 1696924088000 3 connected
546c8528a07abee29a1e383a3130d4f306447f0e 42.192.119.238:6386@16386 slave 19d3955d4bacd04892c13e7a05e13c7744085896 0 1696924086000 1 connected
56b730c5631515b2359bbf9b6d4306460da8502c 42.192.119.238:6384@16384 slave 6297ab04ff4bbfcad778b80315619defc2f6e513 0 1696924088460 2 connected
df0858e942b03f5b3c848d1acb2a4fde1f70e290 42.192.119.238:6383@16383 master - 0 1696924089469 3 connected 10923-16383

可以发现，各节点暴露的IP全是公网IP了。

5、故障转移期间Lettuce客户端连接问题

解决方式：
1、yml指定使用jedis

2、代码配置
1）、更换Redis客户端

@Configuration
public class RedisClusterConfig {@Beanpublic RedisConnectionFactory redisConnectionFactory() {RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration(Arrays.asList("42.192.119.238:6381","42.192.119.238:6382","42.192.119.238:6383","42.192.119.238:6384","42.192.119.238:6385","42.192.119.238:6386"));return new JedisConnectionFactory(redisClusterConfiguration);}
}

参考链接：

https://github.com/lettuce-io/lettuce-core/wiki/Redis-Cluster
https://github.com/lettuce-io/lettuce-core/wiki/Client-options#cluster-specific-options

2）、更改实现配置

@Configuration
public class RedisClusterConfig {@Beanpublic RedisConnectionFactory redisConnectionFactory() {// 开启自适应集群拓扑刷新和周期拓扑刷新，不开启相应槽位主节点挂掉会出现服务不可用，直到挂掉节点重新恢复ClusterTopologyRefreshOptions clusterTopologyRefreshOptions =  ClusterTopologyRefreshOptions.builder().enableAllAdaptiveRefreshTriggers() // 开启自适应刷新,自适应刷新不开启,Redis集群变更时将会导致连接异常.adaptiveRefreshTriggersTimeout(Duration.ofSeconds(30)) //自适应刷新超时时间(默认30秒)，默认关闭开启后时间为30秒.enablePeriodicRefresh(Duration.ofSeconds(20))  // 默认关闭开启后时间为60秒 .build();ClientOptions clientOptions = ClusterClientOptions.builder().topologyRefreshOptions(clusterTopologyRefreshOptions).build();// 客户端读写分离配置LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder().clientOptions(clientOptions).build();RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration(Arrays.asList("42.192.119.238:6381","42.192.119.238:6382","42.192.119.238:6383","42.192.119.238:6384","42.192.119.238:6385","42.192.119.238:6386"));return new LettuceConnectionFactory(redisClusterConfiguration, clientConfig);}
}

参考文档：https://developer.aliyun.com/article/1167633

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/101518.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

vue、uniapp实现组件动态切换

vue、uniapp实现组件动态切换

在Vue中，通过使用动态组件，我们可以实现组件的动态切换，从而达到页面的动态展示效果。 vue 中 component组件 is属性 功能描述 例如：有多个tabs标签，如：推荐、热点、视频等。用户点击标签就会切换到对应组…
阅读更多...
docker应用记录总结

docker应用记录总结

一、前言 docker这类部署工具，久而久之不使用非常容易忘记，甚至连操作命令都容易忘记。网上也有比较全的docker使用教程。这里做一个记录总结，纯属是温故知新。 二、docker部署应用 1、docker印象 docker首先让我想到的是是虚拟化技术&…
阅读更多...
使用Python构造VARIMA模型

使用Python构造VARIMA模型

简介 VARMA(p,q)结合了VAR和VMA模型，其中p是向量自回归(VAR)模型的滞后期数，q是VMA模型的移动平均的阶数。 VARMA是ARMA的推广，它将ARMA模型扩展到多个时间序列变量的情况，通过VAR和VMA的线性组合来描述多个时间序列变量之间的联…
阅读更多...
踩雷react-useRef钩子函数

踩雷react-useRef钩子函数

今天测试提了一个bug，之前做的有个需求，在触发事件发起请求后，成功响应返回的新的数据没有第一时间渲染到网页上。 方法也都成功更新了数据，就是渲染会慢1-2分钟，排错排了老半天，最后找到了原因。 一般情…
阅读更多...
系统架构设计：18 论基于DSSA的软件架构设计与应用

系统架构设计：18 论基于DSSA的软件架构设计与应用

目录 一 特定领域软件架构DSSA 1 DSSA 2 DSSA的基本活动和产物 （1）DSSA的基本活动和产物
阅读更多...
node.js知识系列（4）-每天了解一点

node.js知识系列（4）-每天了解一点

目录 11. 异步文件操作文件读取文件写入 12. 包管理器（npm）13. 子进程14. 事件发射器（EventEmitter）15. 异步编程和回调16. Node.js 集成测试工具和框架17. Express.js 中间件的 HTTP 请求流程18. 文件上传和验证19. Express.js 中…
阅读更多...
SpringBoot和Hibernate——如何提高数据库性能

SpringBoot和Hibernate——如何提高数据库性能

摘要：本文由葡萄城技术团队发布。转载请注明出处：葡萄城官网，葡萄城为开发者提供专业的开发工具、解决方案和服务，赋能开发者。 前言 在软件开发领域，性能是重中之重。无论您是构建小型 Web 应用程序还是大型企业系统…
阅读更多...
单目标应用：遗传算法（Genetic Algorithm，GA）求解微电网优化MATLAB

单目标应用：遗传算法（Genetic Algorithm，GA）求解微电网优化MATLAB

一、微网系统运行优化模型 微电网优化模型介绍： 微电网多目标优化调度模型简介_IT猿手的博客-CSDN博客 二、遗传算法GA 遗传算法（Genetic Algorithm，GA）起源于对生物系统所进行的计算机模拟研究，是一种随机全局搜索…
阅读更多...
【Java 进阶篇】JavaScript 数据类型详解

【Java 进阶篇】JavaScript 数据类型详解

JavaScript是一种弱类型脚本语言，具有动态类型。这意味着JavaScript中的变量可以容纳不同类型的数据，并且它们的类型可以在运行时更改。在本文中，我们将深入探讨JavaScript中的数据类型，包括原始数据类型和引用数据类型&#xff0…
阅读更多...
安科瑞ARB5系列弧光保护装置，智能电弧光保护，保障用电安全

安科瑞ARB5系列弧光保护装置，智能电弧光保护，保障用电安全

安科瑞虞佳豪壹捌柒陆壹伍玖玖零玖叁 什么是弧光 电弧是放电过程中发生的一种现象，当两点之间的电压超过其工频绝缘强度极限时就会发生。当适当的条件出现时，一个携带着电流的等离子产生，直到电源侧的保护设备断开才会消失。空气在通常条件…
阅读更多...
【ARM CoreLink 系列 6 -- DMC-400控制器简介】

【ARM CoreLink 系列 6 -- DMC-400控制器简介】

文章目录 1.1 DMC-400 简介1.1.1 DFI（DDR PHY Interface）1.1.2 DFI 接口组1.1.3 DMC-400 兼容协议1.1.4 DMC-400 特性1.1.5 DMC-400 Interface 1.1 DMC-400 简介 DMC-400是一个由ARM开发、测试和授权的动态内存控制器，同时 DMC-400也是一个符…
阅读更多...
git 回滚到指定版本

git 回滚到指定版本

第一步：找到指定的需要回滚的版本的版本号 项目终端输入命令git log --oneline 第二步：使用git命令回滚到指定的版本 git reset --hard 版本号 第三步：此时再推到远程仓库用git push 会报错，需要用git push -f强推上去才可以哦
阅读更多...
Swagger-go学习笔记

Swagger-go学习笔记

目录 Swagger的作用背景Swagger介绍 Swagger的基本使用1. 使用步骤2. 添加注释3. 生成接口文档数据4. 引入gin-swagger5. 测试结果6. 使用Token Swagger-go的中文文档通用API信息API操作MIME类型参数类型数据类型 Swagger的作用 背景 在传统的前后端分离的项目中，…
阅读更多...
vue3组件的通信方式

vue3组件的通信方式

一、vue3组件通信方式 通信仓库地址:vue3_communication: 当前仓库为贾成豪老师使用组件通信案例 不管是vue2还是vue3,组件通信方式很重要,不管是项目还是面试都是经常用到的知识点。 比如:vue2组件通信方式 props:可以实现父子组件、子父组件、甚至兄弟组件通信 自定义事件:可…
阅读更多...
C语言自定义类型_枚举联合（3）

C语言自定义类型_枚举联合（3）

目录 枚举 什么是枚举类型？ 枚举的声明 枚举的定义 枚举的优点 枚举的使用 联合（共用体） 什么是联合呢？ 联合类型的定义 联合的特点 联合使用 联合大小的计算 联合的应用 今天接着我们来结束自定义类型。&#x1f19…
阅读更多...
Flink之Watermark源码解析

Flink之Watermark源码解析

1. WaterMark源码分析 在Flink官网中介绍watermark和数据是异步处理的,通过分析源码得知这个说法不够准确或者说不够详细,这个异步处理要分为两种情况: watermark源头watermark下游 这两种情况的处理方式并不相同,在watermark的源头确实是异步处理的,但是在下游只是做的判断,这…
阅读更多...
TensorFlow学习：在web前端如何使用Keras 模型

TensorFlow学习：在web前端如何使用Keras 模型

前言 在上篇文章 TensorFlow学习：使用官方模型进行图像分类、使用自己的数据对模型进行微调中我们学习了如何使用官方模型，以及使用自己的数据微调模型。 但是吧，代码一直是跑在Python里，而我本身是做前端开发的。我是很想让它在…
阅读更多...
es elasticsearch 基础

es elasticsearch 基础

es https://www.elastic.co/guide/en/elasticsearch/reference/6.8/getting-started.html 倒排索引： 正排–>从目录到文章内容 倒排–>内容到目录文章标题 if we dont need full text search ,we dont need to create 倒排 using text type 分词&#xff1a…
阅读更多...
C语言-贪吃蛇 1.输入控制ncurse

C语言-贪吃蛇 1.输入控制ncurse

一、为什么要用nurse C语言中的gets()、scanf()、getchar()等函数是在用户输入后需要按下Enter键才能执行代码，而贪吃蛇要求按下按键后立即对蛇的方向进行操作，所以根据贪吃蛇功能的需求引入ncurse，让用户输入后就能让蛇进行对应的行动。 二、…
阅读更多...
10.本项目的简单介绍及所用工具

10.本项目的简单介绍及所用工具

本项目的简单介绍及所用工具 本项目的层次架构适合初学者或者有一些基础的同学，项目整体简单明了，有着非常严谨的逻辑思维，并且在前面文章中也讲了一些项目中所需要的软件安装配置以及一些前置的在本项目中所需要的java基础知识。 项目名称 …
阅读更多...
最新文章

Copyright @ 2022~2023