Redis连接测试代码及相关问题

2024-06-02 18:08

本文主要是介绍Redis连接测试代码及相关问题,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

pom.xml

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

简单测试

public static void main(String[] args) {Jedis jedis = new Jedis("192.168.1.213");jedis.set("foo", "bar");String value = jedis.get("foo");System.out.println(value);
}

如果用这种方法连集群,会看到如下的错误

Exception in thread "main" redis.clients.jedis.exceptions.JedisMovedDataException: MOVED 12182 192.168.1.214:6382

Redis集群测试

public static void main(String[] args) {Set<HostAndPort> jedisClusterNodes = new HashSet<HostAndPort>();// Jedis集群将尝试自动发现集群节点jedisClusterNodes.add(new HostAndPort("192.168.1.214", 6379));// jedisClusterNodes.add(new HostAndPort("192.168.1.214", 6380));// jedisClusterNodes.add(new HostAndPort("192.168.1.214", 6381));JedisCluster jc = new JedisCluster(jedisClusterNodes);jc.set("foo", "bar");jc.set("foo1", "bar1");jc.set("foo2", "bar2");jc.set("foo3", "bar3");jc.set("foo4", "bar4");jc.set("foo5", "bar5");jc.set("foo6", "bar6");System.out.println(jc.get("foo"));System.out.println(jc.get("foo1"));System.out.println(jc.get("foo2"));System.out.println(jc.get("foo3"));System.out.println(jc.get("foo4"));System.out.println(jc.get("foo5"));System.out.println(jc.get("foo6"));System.out.println("===================");Map<String, JedisPool> map = jc.getClusterNodes();for (Map.Entry<String, JedisPool> e : map.entrySet()) {System.out.println(e.getKey());System.out.println("===================");}}

运行时报错:

Exception in thread "main" 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)
...
...

因为在之前创建创建集群时使用的IP是127.0.0.1,当返回(error) MOVED 10439 127.0.0.1:6381时,系统尝试连接本地的端口,然后连不上失败了

修改Redis配置文件,绑定到正确的IP上,然后重新创建集群指定具体的IP地址:

./redis-trib.rb create --replicas 1 192.168.1.214:6379 192.168.1.214:6381 192.168.1.214:6382 192.168.1.214:6383 192.168.1.214:6384 192.168.1.214:6385

#杀掉redis进程
ps -ef | grep redis | awk '{print $2}' | xargs kill#删除
rm -f /data/redis/d63*/dump.rdb
rm -f /data/redis/d63*/nodes.conf#批量替换
sed -i 's/192.168.1.214/0.0.0.0/' */redis.conf

Jedis客户端分片测试

分片使用一种称为“一致哈希”的技术,并根据一些散列算法(md5和murmur,后者不太标准,但速度更快)在一组redis服务器上同等地分配key值。这样的节点被称为“分片”。优点是每个分片只会占总内存的 1/n(对于n是分片数量)。

先配置三个独立的redis服务

直连接方式

public static void main(String[] args) {List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>();JedisShardInfo si = new JedisShardInfo("192.168.1.213", 6380);shards.add(si);si = new JedisShardInfo("192.168.1.213", 6381);shards.add(si);si = new JedisShardInfo("192.168.1.213", 6382);shards.add(si);// 直接连接ShardedJedis jedis = new ShardedJedis(shards);jedis.set("a", "foo");jedis.set("a1", "foo1");jedis.set("a2", "foo2");jedis.set("a3", "foo3");jedis.set("a4", "foo4");System.out.println(jedis.get("a"));System.out.println(jedis.get("a1"));System.out.println(jedis.get("a2"));System.out.println(jedis.get("a3"));System.out.println(jedis.get("a4"));ShardInfo<?> sinfo = jedis.getShardInfo("a");System.out.println(sinfo);jedis.disconnect();jedis.close();
}

连接池方式

public static void main(String[] args) {List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>();JedisShardInfo si = new JedisShardInfo("192.168.1.213", 6380);shards.add(si);si = new JedisShardInfo("192.168.1.213", 6381);shards.add(si);si = new JedisShardInfo("192.168.1.213", 6382);shards.add(si);// 池连接JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();ShardedJedisPool pool = new ShardedJedisPool(jedisPoolConfig, shards);try (ShardedJedis jedis = pool.getResource()) {jedis.set("x", "foo");jedis.set("x1", "foo1");jedis.set("x2", "foo2");}try (ShardedJedis jedis2 = pool.getResource()) {jedis2.set("y", "bar");jedis2.set("y1", "bar1");jedis2.set("y2", "bar2");}try (ShardedJedis jedis = pool.getResource()) {System.out.println(jedis.get("x"));System.out.println(jedis.get("x1"));System.out.println(jedis.get("x2"));}try (ShardedJedis jedis2 = pool.getResource()) {System.out.println(jedis2.get("y"));System.out.println(jedis2.get("y1"));System.out.println(jedis2.get("y2"));}pool.close();
}

这篇关于Redis连接测试代码及相关问题的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

Knife4j+Axios+Redis前后端分离架构下的 API 管理与会话方案(最新推荐)

《Knife4j+Axios+Redis前后端分离架构下的API管理与会话方案(最新推荐)》本文主要介绍了Swagger与Knife4j的配置要点、前后端对接方法以及分布式Session实现原理,... 目录一、Swagger 与 Knife4j 的深度理解及配置要点Knife4j 配置关键要点1.Spri

怎样通过分析GC日志来定位Java进程的内存问题

《怎样通过分析GC日志来定位Java进程的内存问题》:本文主要介绍怎样通过分析GC日志来定位Java进程的内存问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、GC 日志基础配置1. 启用详细 GC 日志2. 不同收集器的日志格式二、关键指标与分析维度1.

Java 线程安全与 volatile与单例模式问题及解决方案

《Java线程安全与volatile与单例模式问题及解决方案》文章主要讲解线程安全问题的五个成因(调度随机、变量修改、非原子操作、内存可见性、指令重排序)及解决方案,强调使用volatile关键字... 目录什么是线程安全线程安全问题的产生与解决方案线程的调度是随机的多个线程对同一个变量进行修改线程的修改操

Redis出现中文乱码的问题及解决

《Redis出现中文乱码的问题及解决》:本文主要介绍Redis出现中文乱码的问题及解决,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1. 问题的产生2China编程. 问题的解决redihttp://www.chinasem.cns数据进制问题的解决中文乱码问题解决总结

MySQL中的表连接原理分析

《MySQL中的表连接原理分析》:本文主要介绍MySQL中的表连接原理分析,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1、背景2、环境3、表连接原理【1】驱动表和被驱动表【2】内连接【3】外连接【4编程】嵌套循环连接【5】join buffer4、总结1、背景

全面解析MySQL索引长度限制问题与解决方案

《全面解析MySQL索引长度限制问题与解决方案》MySQL对索引长度设限是为了保持高效的数据检索性能,这个限制不是MySQL的缺陷,而是数据库设计中的权衡结果,下面我们就来看看如何解决这一问题吧... 目录引言:为什么会有索引键长度问题?一、问题根源深度解析mysql索引长度限制原理实际场景示例二、五大解决

Springboot如何正确使用AOP问题

《Springboot如何正确使用AOP问题》:本文主要介绍Springboot如何正确使用AOP问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录​一、AOP概念二、切点表达式​execution表达式案例三、AOP通知四、springboot中使用AOP导出

Python中Tensorflow无法调用GPU问题的解决方法

《Python中Tensorflow无法调用GPU问题的解决方法》文章详解如何解决TensorFlow在Windows无法识别GPU的问题,需降级至2.10版本,安装匹配CUDA11.2和cuDNN... 当用以下代码查看GPU数量时,gpuspython返回的是一个空列表,说明tensorflow没有找到

解决未解析的依赖项:‘net.sf.json-lib:json-lib:jar:2.4‘问题

《解决未解析的依赖项:‘net.sf.json-lib:json-lib:jar:2.4‘问题》:本文主要介绍解决未解析的依赖项:‘net.sf.json-lib:json-lib:jar:2.4... 目录未解析的依赖项:‘net.sf.json-lib:json-lib:jar:2.4‘打开pom.XM

IDEA Maven提示:未解析的依赖项的问题及解决

《IDEAMaven提示:未解析的依赖项的问题及解决》:本文主要介绍IDEAMaven提示:未解析的依赖项的问题及解决,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝... 目录IDEA Maven提示:未解析的依编程赖项例如总结IDEA Maven提示:未解析的依赖项例如