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

相关文章

Spring的RedisTemplate的json反序列泛型丢失问题解决

《Spring的RedisTemplate的json反序列泛型丢失问题解决》本文主要介绍了SpringRedisTemplate中使用JSON序列化时泛型信息丢失的问题及其提出三种解决方案,可以根据性... 目录背景解决方案方案一方案二方案三总结背景在使用RedisTemplate操作redis时我们针对

Kotlin Map映射转换问题小结

《KotlinMap映射转换问题小结》文章介绍了Kotlin集合转换的多种方法,包括map(一对一转换)、mapIndexed(带索引)、mapNotNull(过滤null)、mapKeys/map... 目录Kotlin 集合转换:map、mapIndexed、mapNotNull、mapKeys、map

nginx中端口无权限的问题解决

《nginx中端口无权限的问题解决》当Nginx日志报错bind()to80failed(13:Permissiondenied)时,这通常是由于权限不足导致Nginx无法绑定到80端口,下面就来... 目录一、问题原因分析二、解决方案1. 以 root 权限运行 Nginx(不推荐)2. 为 Nginx

解决1093 - You can‘t specify target table报错问题及原因分析

《解决1093-Youcan‘tspecifytargettable报错问题及原因分析》MySQL1093错误因UPDATE/DELETE语句的FROM子句直接引用目标表或嵌套子查询导致,... 目录报js错原因分析具体原因解决办法方法一:使用临时表方法二:使用JOIN方法三:使用EXISTS示例总结报错原

Windows环境下解决Matplotlib中文字体显示问题的详细教程

《Windows环境下解决Matplotlib中文字体显示问题的详细教程》本文详细介绍了在Windows下解决Matplotlib中文显示问题的方法,包括安装字体、更新缓存、配置文件设置及编码調整,并... 目录引言问题分析解决方案详解1. 检查系统已安装字体2. 手动添加中文字体(以SimHei为例)步骤

Redis中Stream详解及应用小结

《Redis中Stream详解及应用小结》RedisStreams是Redis5.0引入的新功能,提供了一种类似于传统消息队列的机制,但具有更高的灵活性和可扩展性,本文给大家介绍Redis中Strea... 目录1. Redis Stream 概述2. Redis Stream 的基本操作2.1. XADD

SpringSecurity整合redission序列化问题小结(最新整理)

《SpringSecurity整合redission序列化问题小结(最新整理)》文章详解SpringSecurity整合Redisson时的序列化问题,指出需排除官方Jackson依赖,通过自定义反序... 目录1. 前言2. Redission配置2.1 RedissonProperties2.2 Red

nginx 负载均衡配置及如何解决重复登录问题

《nginx负载均衡配置及如何解决重复登录问题》文章详解Nginx源码安装与Docker部署,介绍四层/七层代理区别及负载均衡策略,通过ip_hash解决重复登录问题,对nginx负载均衡配置及如何... 目录一:源码安装:1.配置编译参数2.编译3.编译安装 二,四层代理和七层代理区别1.二者混合使用举例

C#连接SQL server数据库命令的基本步骤

《C#连接SQLserver数据库命令的基本步骤》文章讲解了连接SQLServer数据库的步骤,包括引入命名空间、构建连接字符串、使用SqlConnection和SqlCommand执行SQL操作,... 目录建议配合使用:如何下载和安装SQL server数据库-CSDN博客1. 引入必要的命名空间2.

Java通过驱动包(jar包)连接MySQL数据库的步骤总结及验证方式

《Java通过驱动包(jar包)连接MySQL数据库的步骤总结及验证方式》本文详细介绍如何使用Java通过JDBC连接MySQL数据库,包括下载驱动、配置Eclipse环境、检测数据库连接等关键步骤,... 目录一、下载驱动包二、放jar包三、检测数据库连接JavaJava 如何使用 JDBC 连接 mys