redis实战第十三篇 jedis连接redis cluster

2024-06-22 19:18

本文主要是介绍redis实战第十三篇 jedis连接redis cluster,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

redis cluster客户端有两种;
Dummy:又称为傀儡客户端,redis的重定向机制会返回当前键所在的槽和对应的节点,dummy客户端根据这一机制随机连接任一redis获取键所在的节点,这种客户端实现代码简单,每次只需要根据重定向的信息再次发送请求即可,但是这样弊端也和明显,根据重定向再次发送请求额外增加了开销。
smart:它会在内部维护一个slot→node的映射关系,本地就可以实现键到节点的查找,从而保证IO效率的莪最大化。
jedisCluster就是一种smart客户端,它的构造方法如下:

public JedisCluster(Set<HostAndPort> jedisClusterNode, int connectionTimeout, int soTimeout,int maxAttempts, String password, final GenericObjectPoolConfig poolConfig) {super(jedisClusterNode, connectionTimeout, soTimeout, maxAttempts, password, poolConfig);
}

参数说明:
Set jedisClusterNode:所有redis cluster节点信息,也可以只填写部分,应为客户端可以通过cluster slots发现
int connectionTimeout:连接超时
soTimeout:读写超时
maxAttempts:重试次数,JedisCluster在连接的时候,如果出现连接错误,则会尝试随机连接一个节点,如果当期尝试的节点返回Moved重定向,jedis cluster会重新更新clots缓存。如果重试依然返回连接错误,会接着再次重试,当重试次数大于maxAttempts会报出Jedis ClusterMaxRedirectionsException(“to many Cluster redireciotns?”)异常
password:集群密码
poolConfig:连接池参数

JedisCluster有以下特点、
1)它会为所有节点都维护一个连接池JedisPool,建议JedisCluster使用单例
2)JedisCluster每次操作完不需要管理连接池的借还,它在内部已经完成
3)JedisCluster一般不需要执行close操作,它会将所有的JedisPool执行destroy操作

pom依赖

		<dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>3.0.0</version></dependency>

JedisCluster实例

package com.gildata.duplicateandtagtest.redis;import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPoolConfig;import java.util.HashSet;
import java.util.Set;/*** Created by LiChao on 2019/2/16*/
public class RedisClusterUtil {private static JedisCluster jedis = null;//可用连接实例的最大数目,默认为8;//如果赋值为-1,则表示不限制,如果pool已经分配了maxActive个jedis实例,则此时pool的状态为exhausted(耗尽)private static Integer MAX_TOTAL = 1024;//控制一个pool最多有多少个状态为idle(空闲)的jedis实例,默认值是8private static Integer MAX_IDLE = 200;//等待可用连接的最大时间,单位是毫秒,默认值为-1,表示永不超时。//如果超过等待时间,则直接抛出JedisConnectionExceptionprivate static Integer MAX_WAIT_MILLIS = 10000;//在borrow(用)一个jedis实例时,是否提前进行validate(验证)操作;//如果为true,则得到的jedis实例均是可用的private static Boolean TEST_ON_BORROW = true;//在空闲时检查有效性, 默认falseprivate static Boolean TEST_WHILE_IDLE = true;//是否进行有效性检查private static Boolean TEST_ON_RETURN = true;//访问密码private static String AUTH = "1234@abcd";/*** 静态块,初始化Redis连接池*/static {try {JedisPoolConfig config = new JedisPoolConfig();/*注意:在高版本的jedis jar包,比如本版本2.9.0,JedisPoolConfig没有setMaxActive和setMaxWait属性了这是因为高版本中官方废弃了此方法,用以下两个属性替换。maxActive  ==>  maxTotalmaxWait==>  maxWaitMillis*/config.setMaxTotal(MAX_TOTAL);config.setMaxIdle(MAX_IDLE);config.setMaxWaitMillis(MAX_WAIT_MILLIS);config.setTestOnBorrow(TEST_ON_BORROW);config.setTestWhileIdle(TEST_WHILE_IDLE);config.setTestOnReturn(TEST_ON_RETURN);Set<HostAndPort> jedisClusterNode = new HashSet<HostAndPort>();jedisClusterNode.add(new HostAndPort("192.168.0.31", 6380));jedisClusterNode.add(new HostAndPort("192.168.0.32", 6380));jedisClusterNode.add(new HostAndPort("192.168.0.33", 6380));jedisClusterNode.add(new HostAndPort("192.168.0.34", 6380));jedisClusterNode.add(new HostAndPort("192.168.0.35", 6380));jedisClusterNode.add(new HostAndPort("192.168.0.36", 6380));jedis = new JedisCluster(jedisClusterNode,1000,1000,5,AUTH,config);} catch (Exception e) {e.printStackTrace();}}public static JedisCluster getJedis(){return jedis;}
}

测试


@Test
public void testCluster(){JedisCluster jedis = RedisClusterUtil.getJedis();jedis.set("cluster","hello world");System.out.println(jedis.get("cluster"));
}

这篇关于redis实战第十三篇 jedis连接redis cluster的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1085173

相关文章

Spring Boot + MyBatis Plus 高效开发实战从入门到进阶优化(推荐)

《SpringBoot+MyBatisPlus高效开发实战从入门到进阶优化(推荐)》本文将详细介绍SpringBoot+MyBatisPlus的完整开发流程,并深入剖析分页查询、批量操作、动... 目录Spring Boot + MyBATis Plus 高效开发实战:从入门到进阶优化1. MyBatis

MyBatis 动态 SQL 优化之标签的实战与技巧(常见用法)

《MyBatis动态SQL优化之标签的实战与技巧(常见用法)》本文通过详细的示例和实际应用场景,介绍了如何有效利用这些标签来优化MyBatis配置,提升开发效率,确保SQL的高效执行和安全性,感... 目录动态SQL详解一、动态SQL的核心概念1.1 什么是动态SQL?1.2 动态SQL的优点1.3 动态S

Pandas使用SQLite3实战

《Pandas使用SQLite3实战》本文主要介绍了Pandas使用SQLite3实战,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学... 目录1 环境准备2 从 SQLite3VlfrWQzgt 读取数据到 DataFrame基础用法:读

Redis 中的热点键和数据倾斜示例详解

《Redis中的热点键和数据倾斜示例详解》热点键是指在Redis中被频繁访问的特定键,这些键由于其高访问频率,可能导致Redis服务器的性能问题,尤其是在高并发场景下,本文给大家介绍Redis中的热... 目录Redis 中的热点键和数据倾斜热点键(Hot Key)定义特点应对策略示例数据倾斜(Data S

Spring Boot 整合 MyBatis 连接数据库及常见问题

《SpringBoot整合MyBatis连接数据库及常见问题》MyBatis是一个优秀的持久层框架,支持定制化SQL、存储过程以及高级映射,下面详细介绍如何在SpringBoot项目中整合My... 目录一、基本配置1. 添加依赖2. 配置数据库连接二、项目结构三、核心组件实现(示例)1. 实体类2. Ma

电脑win32spl.dll文件丢失咋办? win32spl.dll丢失无法连接打印机修复技巧

《电脑win32spl.dll文件丢失咋办?win32spl.dll丢失无法连接打印机修复技巧》电脑突然提示win32spl.dll文件丢失,打印机死活连不上,今天就来给大家详细讲解一下这个问题的解... 不知道大家在使用电脑的时候是否遇到过关于win32spl.dll文件丢失的问题,win32spl.dl

redis+lua实现分布式限流的示例

《redis+lua实现分布式限流的示例》本文主要介绍了redis+lua实现分布式限流的示例,可以实现复杂的限流逻辑,如滑动窗口限流,并且避免了多步操作导致的并发问题,具有一定的参考价值,感兴趣的可... 目录为什么使用Redis+Lua实现分布式限流使用ZSET也可以实现限流,为什么选择lua的方式实现

Redis中管道操作pipeline的实现

《Redis中管道操作pipeline的实现》RedisPipeline是一种优化客户端与服务器通信的技术,通过批量发送和接收命令减少网络往返次数,提高命令执行效率,本文就来介绍一下Redis中管道操... 目录什么是pipeline场景一:我要向Redis新增大批量的数据分批处理事务( MULTI/EXE

Python实战之屏幕录制功能的实现

《Python实战之屏幕录制功能的实现》屏幕录制,即屏幕捕获,是指将计算机屏幕上的活动记录下来,生成视频文件,本文主要为大家介绍了如何使用Python实现这一功能,希望对大家有所帮助... 目录屏幕录制原理图像捕获音频捕获编码压缩输出保存完整的屏幕录制工具高级功能实时预览增加水印多平台支持屏幕录制原理屏幕

Redis中高并发读写性能的深度解析与优化

《Redis中高并发读写性能的深度解析与优化》Redis作为一款高性能的内存数据库,广泛应用于缓存、消息队列、实时统计等场景,本文将深入探讨Redis的读写并发能力,感兴趣的小伙伴可以了解下... 目录引言一、Redis 并发能力概述1.1 Redis 的读写性能1.2 影响 Redis 并发能力的因素二、