Spring Boot Redis Cluster 实战干货

转载自  Spring Boot Redis Cluster 实战干货

添加配置信息

spring.redis:database: 0 # Redis数据库索引(默认为0)#host: 192.168.1.8#port: 6379password: 123456timeout: 10000 # 连接超时时间(毫秒)  pool: max-active: 8 # 连接池最大连接数(使用负值表示没有限制)max-idle: 8 # 连接池中的最大空闲连接max-wait: -1 # 连接池最大阻塞等待时间(使用负值表示没有限制)min-idle: 0 # 连接池中的最小空闲连接cluster:nodes:- 192.168.1.8:9001- 192.168.1.8:9002- 192.168.1.8:9003

只需要添加3个master节点,3个slave节点不需要添加。

你要做的也只有这些配置了,其他的spring boot都自动配置好了。

现在就可以像使用单机一样使用集群,redis会自动按key分片到不同的集群实例。

遇到的问题

Caused by: redis.clients.jedis.exceptions.JedisConnectionException: Could not get a resource from the poolat redis.clients.util.Pool.getResource(Pool.java:53)at redis.clients.jedis.JedisPool.getResource(JedisPool.java:226)at redis.clients.jedis.JedisSlotBasedConnectionHandler.getConnectionFromSlot(JedisSlotBasedConnectionHandler.java:66)at redis.clients.jedis.JedisClusterCommand.runWithRetries(JedisClusterCommand.java:116)at redis.clients.jedis.JedisClusterCommand.runWithRetries(JedisClusterCommand.java:141)at redis.clients.jedis.JedisClusterCommand.runWithRetries(JedisClusterCommand.java:141)at redis.clients.jedis.JedisClusterCommand.runWithRetries(JedisClusterCommand.java:141)at redis.clients.jedis.JedisClusterCommand.runWithRetries(JedisClusterCommand.java:141)at redis.clients.jedis.JedisClusterCommand.runBinary(JedisClusterCommand.java:60)at redis.clients.jedis.BinaryJedisCluster.set(BinaryJedisCluster.java:77)at org.springframework.data.redis.connection.jedis.JedisClusterConnection.set(JedisClusterConnection.java:618)... 36 more
Caused by: redis.clients.jedis.exceptions.JedisConnectionException: java.net.ConnectException: Connection refused: connectat redis.clients.jedis.Connection.connect(Connection.java:207)at redis.clients.jedis.BinaryClient.connect(BinaryClient.java:93)at redis.clients.jedis.BinaryJedis.connect(BinaryJedis.java:1767)at redis.clients.jedis.JedisFactory.makeObject(JedisFactory.java:106)at org.apache.commons.pool2.impl.GenericObjectPool.create(GenericObjectPool.java:868)at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:435)at org.apache.commons.pool2.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:363)at redis.clients.util.Pool.getResource(Pool.java:49)... 46 more
Caused by: java.net.ConnectException: Connection refused: connectat java.net.DualStackPlainSocketImpl.waitForConnect(Native Method)at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:85)at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172)at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)at java.net.Socket.connect(Socket.java:589)at redis.clients.jedis.Connection.connect(Connection.java:184)... 53 more

尝试往redis写数据的时候,报不能获取连接异常,跟踪了半天代码,发现连接的是127.0.0.1,而不是配置的192.168.1.8,这就奇怪了,继续跟踪代码发现是往redis服务器获取的返回的集群实例列表,真是坑!

源码:

redis.clients.jedis.Jedis#clusterSlots

@Override
public List<Object> clusterSlots() {checkIsInMultiOrPipeline();client.clusterSlots();return client.getObjectMultiBulkReply();
}

就是这里获取返回的集群列表,返回的就是127.0.0.1,而不是配置的192.168.1.8。

最后修改各个集群节点的配置文件redis.conf,添加:

bind 192.168.1.8

重启集群节点之后,读写正常。

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

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

相关文章

《四世同堂》金句摘抄(八)

System.out.println("这两天还是读的《四世同堂》"); System.out.println("这本书好长啊"); System.out.println("不断的听&#xff0c;不断的看&#xff0c;才到1000多页"); System.out.println("这几天没有好好的读&#xff0c;追求了速度…

编写高性能 .NET 代码 第一章:工具介绍 -- Performance Counters(性能计数器)

Performance Counters&#xff08;性能计数器&#xff09; 性能计数器是监视应用程序和系统性能的最简单的方法之一。它有几十个类别数百个计数器在&#xff0c;包括一些.net特有的计数器。要访问这些可以通过系统自带的 性能监控程序&#xff08;perfmon.exe&#xff09;来实…

java后台手动分页

单个实体类 Integer pageNumber po.getPageNumber();Integer pageSize po.getPageSize();Integer last pageNumber * pageSize;if ((pageNumber * pageSize)>weekResultInfoVOS.size()){lastweekResultInfoVOS.size();}int size weekResultInfoVOS.size();List<Week…

超详细的 Redis Cluster 官方集群搭建指南

转载自 超详细的 Redis Cluster 官方集群搭建指南 今天从 0 开始搭建 Redis Cluster 官方集群&#xff0c;解决搭建过程中遇到的问题&#xff0c;超详细。 安装ruby环境 因为官方提供的创建集群的工具是用ruby写的&#xff0c;需要ruby2.2.2版本支持&#xff0c;ruby安装需…

《四世同堂》金句摘抄(九)

System.out.println("这两天还是读的《四世同堂》"); System.out.println("这本书好长啊"); System.out.println("不断的听&#xff0c;不断的看&#xff0c;才到1000多页"); System.out.println("这几天没有好好的读&#xff0c;追求了速度…

EF通用数据层封装类(支持读写分离,一主多从)

浅谈orm 记得四年前在学校第一次接触到 Ling to Sql&#xff0c;那时候瞬间发现不用手写sql语句是多么的方便&#xff0c;后面慢慢的接触了许多orm框架&#xff0c;像 EF&#xff0c;Dapper,Hibernate,ServiceStack.OrmLite 等。当然每种orm都有各自的优势&#xff0c;也有不足…

前端进行时间段筛选

传给后端参数时进行格式化 weekResultTimeStart:params.insertTime!null?moment(params.insertTime[0]).format(YYYY-MM-DD HH:mm:ss):null,weekResultTimeEnd:params.insertTime!null?moment(params.insertTime[1]).format(YYYY-MM-DD HH:mm:ss):null,注意点&#xff1a; 前…

Java中的常量池(字符串常量池、class常量池和运行时常量池)

转载自 Java中的常量池(字符串常量池、class常量池和运行时常量池) 简介&#xff1a; 这几天在看Java虚拟机方面的知识时&#xff0c;看到了有几种不同常量池的说法&#xff0c;然后我就去CSDN、博客园等上找资料&#xff0c;里面说的内容真是百花齐放&#xff0c;各自争艳&…

《四世同堂》金句摘抄(十)

System.out.println("这两天还是读的《四世同堂》"); System.out.println("这本书好长啊"); System.out.println("不断的听&#xff0c;不断的看&#xff0c;才到1000多页"); System.out.println("这几天没有好好的读&#xff0c;追求了速度…

IdentityServer4(OAuth2.0服务)折腾笔记

以下&#xff0c;称这个使用了IdentityServer4的OAuth2.0服务的项目称为Passport项目。 组件说明&#xff08;Nuget&#xff09; Passport项目所需组件 项目以Asp.net Core Identity项目模板初始化&#xff0c;集成IdentityServer4中间件&#xff1b;集成IdentityServer4.AspN…

map遍历进行展示

{userList.map((item,index)> <Option key{index} value{item.userId}>{item.realName||null}</Option>)||null}

Vue.js基础体验(一)

今天开始学习Vue.js啦&#xff0c;刚开始看起来&#xff0c;确实很难很难&#xff0c;但是经过一番“周折”&#xff0c;发现也就那样&#xff0c;没有想象的那么难。 下面是今天记录的代码&#xff1a; <!DOCTYPE html> <html><head><meta charset"…

青蛙跳台阶的问题——Fibonacci

转载自 青蛙跳台阶的问题——Fibonacci 这几天正在复习算法&#xff0c;今天在看一篇文章时偶然看到这个题目&#xff0c;想了一下居然没什么思路……&#xff08;抱歉&#xff0c;实在太菜。)&#xff0c;文章中提示了一个关键词&#xff1a;Fibonacci 数列。然后我又小百度…

Javase基础

Javase基础1.XML文档作用 保存和传输数据 类如&#xff1a; <标题> 标题 </标题> 2.Java的特性优势&#xff08;编译型语言和解释性语言&#xff09; 1.安全 2.面向对象 3.简单性&#xff08;C&#xff09; 4.高性能 5.分布式 6.多线程 7.高并发 8.跨平台 可移植性…

LocalDateTime与LocalDate之间的相互转换

LocalDateTime转换为LocalDate和LocalTime LocalDate转为LocalDateTime

DDD领域驱动之干货 (一)

说道DDD不得不说传统的架构与DDD的架构区别。 传统的架构不外乎就是三层&#xff0c;而在这三层里面又不断的细分&#xff0c;始终没有达到想要的效果&#xff0c;那么为什么当时还是采用三层。 当然在DDD没有提出的时候三层是大多数人的选择。 那么当领域驱动被提出来的时候…

《四世同堂》金句摘抄(十一)

System.out.println("这两天还是读的《四世同堂》"); System.out.println("这本书好长啊"); System.out.println("不断的听&#xff0c;不断的看&#xff0c;才到1000多页"); System.out.println("这几天没有好好的读&#xff0c;追求了速度…

今日头条大佬十年面试了 2000 人,总结了这 5 点

转载自 今日头条大佬十年面试了 2000 人&#xff0c;总结了这 5 点 文章整理自今日头条张一鸣在“2016今日头条Bootcamp”上对研发&产品部门应届毕业生的寄语。 大家好&#xff01; 各位都非常年轻&#xff0c;我今天来的时候挺有压力。因为我毕业快11年了&#xff0c;…

第十三章 常用类(Math 类、Arrays 类、System类、Biglnteger 和BigDecimal 类、日期类)

一、Math 类&#xff08;P481&#xff09; Math 类包含&#xff0c;用于执行基本数学运算的方法&#xff0c;如初等指数、对数、平方根和三角函数。 &#xff08;1&#xff09;abs&#xff1a;绝对值 &#xff08;2&#xff09;pow&#xff1a;求幂 &#xff08;3&#xff09;c…

栈队列

//栈 //public class Stack extends Vector 已经过时 Stack stack new Stack(); //双端队列 可以作为栈来使用 push() 入栈 pop() 出栈 peek() 获取栈顶元素 Deque deque ; //ArrayDeque 底层是数组 LinkedList 底层是链表 //队列 Queue queue; //ArrayDeque 底层是数组 Link…