From 35bb69a09fc476d4dffde31c608b9d6224bab35e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=B5=B5=E9=94=8B?= Date: Wed, 29 May 2024 10:02:41 +0800 Subject: [PATCH 1/3] =?UTF-8?q?=E5=8D=87=E7=BA=A7Jfinal=E7=89=88=E6=9C=AC?= =?UTF-8?q?=E5=88=B05.1.9=EF=BC=8C=E5=8D=87=E7=BA=A7sentinel=E7=89=88?= =?UTF-8?q?=E6=9C=AC=E5=88=B01.8.7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pom.xml b/pom.xml index bc7ecbad..f5dd0d80 100644 --- a/pom.xml +++ b/pom.xml @@ -41,7 +41,7 @@ - 5.1.2 + 5.1.9 2022.2 3.5 3.4 @@ -67,7 +67,7 @@ 4.5.12 4.4.13 4.1.52.Final - 1.8.3 + 1.8.7 2.7.23 3.14.0.Final 1.5.1 -- Gitee From 3fbc2ca61d81f7b6293747d474827c9da6fe14ec Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=B5=B5=E9=94=8B?= Date: Wed, 29 May 2024 11:32:15 +0800 Subject: [PATCH 2/3] =?UTF-8?q?DubboUtil=20metrics=20=E9=85=8D=E7=BD=AE?= =?UTF-8?q?=E5=A4=87=E6=B3=A8=E6=96=87=E5=AD=97=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/io/jboot/components/rpc/dubbo/DubboUtil.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/io/jboot/components/rpc/dubbo/DubboUtil.java b/src/main/java/io/jboot/components/rpc/dubbo/DubboUtil.java index 66b0dfb8..c8b48e08 100644 --- a/src/main/java/io/jboot/components/rpc/dubbo/DubboUtil.java +++ b/src/main/java/io/jboot/components/rpc/dubbo/DubboUtil.java @@ -73,7 +73,7 @@ class DubboUtil { dubboBootstrap.monitor(monitorConfig); - //monitor 配置 + //metrics 配置 MetricsConfig metricsConfig = config(MetricsConfig.class, "jboot.rpc.dubbo.metrics"); dubboBootstrap.metrics(metricsConfig); -- Gitee From 1ced3023d1fc0b76abd2ac7693ab0f28c9ad7141 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=B5=B5=E9=94=8B?= Date: Fri, 31 May 2024 18:28:55 +0800 Subject: [PATCH 3/3] =?UTF-8?q?=E5=8D=87=E7=BA=A7jedis=E7=89=88=E6=9C=AC?= =?UTF-8?q?=EF=BC=8Credis=E7=BC=93=E5=AD=98=E7=BB=84=E4=BB=B6=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3=E5=8D=87=E7=BA=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 4 +- .../io/jboot/support/redis/JbootRedis.java | 6 +-- .../redis/jedis/JbootJedisClusterImpl.java | 46 +++++++++---------- .../support/redis/jedis/JbootJedisImpl.java | 28 +++++------ .../redis/lettuce/JbootLettuceImpl.java | 6 +-- .../redis/redisson/JbootRedissonImpl.java | 6 +-- .../test/cache/redis/RedisCacheTester.java | 2 + .../java/io/jboot/test/redis/RedisTester.java | 2 + 8 files changed, 52 insertions(+), 48 deletions(-) diff --git a/pom.xml b/pom.xml index f5dd0d80..a39ac53c 100644 --- a/pom.xml +++ b/pom.xml @@ -6,7 +6,7 @@ io.jboot jboot - 4.1.5 + 4.1.5-GEH jar jboot @@ -57,7 +57,7 @@ 32.1.2-jre 2.2.5 - 3.8.0 + 5.1.3 1.16.1 2.10.9.2 2.9.3 diff --git a/src/main/java/io/jboot/support/redis/JbootRedis.java b/src/main/java/io/jboot/support/redis/JbootRedis.java index 78888fc0..33c03ff7 100644 --- a/src/main/java/io/jboot/support/redis/JbootRedis.java +++ b/src/main/java/io/jboot/support/redis/JbootRedis.java @@ -553,7 +553,7 @@ public interface JbootRedis { * 具有相同 score 值的成员按字典序(lexicographical order )来排列。 * 如果你需要成员按 score 值递减(从大到小)来排列，请使用 ZREVRANGE 命令。 */ - Set zrange(Object key, long start, long end); + List zrange(Object key, long start, long end); /** * 返回有序集 key 中，指定区间内的成员。 @@ -561,13 +561,13 @@ public interface JbootRedis { * 具有相同 score 值的成员按字典序的逆序(reverse lexicographical order)排列。 * 除了成员按 score 值递减的次序排列这一点外， ZREVRANGE 命令的其他方面和 ZRANGE 命令一样。 */ - Set zrevrange(Object key, long start, long end); + List zrevrange(Object key, long start, long end); /** * 返回有序集 key 中，所有 score 值介于 min 和 max 之间(包括等于 min 或 max )的成员。 * 有序集成员按 score 值递增(从小到大)次序排列。 */ - Set zrangeByScore(Object key, double min, double max); + List zrangeByScore(Object key, double min, double max); /** * 返回有序集 key 中成员 member 的排名。其中有序集成员按 score 值递增(从小到大)顺序排列。 diff --git a/src/main/java/io/jboot/support/redis/jedis/JbootJedisClusterImpl.java b/src/main/java/io/jboot/support/redis/jedis/JbootJedisClusterImpl.java index df7dd63a..1ce3c616 100644 --- a/src/main/java/io/jboot/support/redis/jedis/JbootJedisClusterImpl.java +++ b/src/main/java/io/jboot/support/redis/jedis/JbootJedisClusterImpl.java @@ -25,9 +25,12 @@ import io.jboot.utils.StrUtil; import org.apache.commons.pool2.impl.GenericObjectPoolConfig; import redis.clients.jedis.*; import redis.clients.jedis.exceptions.JedisConnectionException; +import redis.clients.jedis.params.ScanParams; +import redis.clients.jedis.resps.ScanResult; import java.util.*; import java.util.Map.Entry; +import java.util.stream.Collectors; /** * 参考： com.jfinal.plugin.redis @@ -219,16 +222,17 @@ public class JbootJedisClusterImpl extends JbootRedisBase { @Override public Set keys(String pattern) { HashSet keys = new HashSet<>(); - Map clusterNodes = jedisCluster.getClusterNodes(); + Map clusterNodes = jedisCluster.getClusterNodes(); for (String k : clusterNodes.keySet()) { - JedisPool jp = clusterNodes.get(k); - Jedis jedis = jp.getResource(); + ConnectionPool cp = clusterNodes.get(k); + Connection conn = cp.getResource(); try { - keys.addAll(jedis.keys(pattern)); + keys.addAll(conn.executeCommand(new ClusterCommandObjects().keys(pattern))); } catch (Exception e) { LOG.error(e.toString(), e); } finally { - jedis.close(); //用完一定要close这个链接！！！ + conn.close(); + cp.close(); //用完一定要close这个链接！！！ } } return keys; @@ -913,13 +917,12 @@ public class JbootJedisClusterImpl extends JbootRedisBase { // jedisCluster.getClusterNodes().get("aa").getResource().ping // return jedisCluster..ping(); - Map nodes = jedisCluster.getClusterNodes(); + Map nodes = jedisCluster.getClusterNodes(); if (nodes != null) { - for (JedisPool pool : nodes.values()) { - try (Jedis node = pool.getResource()) { - String ret = node.ping(); - if (ret != null) { - return ret; + for (ConnectionPool pool : nodes.values()) { + try (Connection node = pool.getResource()) { + if (node.ping()) { + return "PONG"; } } } @@ -1129,11 +1132,10 @@ public class JbootJedisClusterImpl extends JbootRedisBase { */ @Override @SuppressWarnings("rawtypes") - public Set zrange(Object key, long start, long end) { + public List zrange(Object key, long start, long end) { - Set data = jedisCluster.zrange(keyToBytes(key), start, end); - Set result = new LinkedHashSet(); // 有序集合必须 LinkedHashSet - valueSetFromBytesSet(data, result); + List data = jedisCluster.zrange(keyToBytes(key), start, end); + List result = data.stream().map(d->valueFromBytes(d)).collect(Collectors.toList()); // 有序集合必须 LinkedHashSet return result; } @@ -1146,11 +1148,10 @@ public class JbootJedisClusterImpl extends JbootRedisBase { */ @Override @SuppressWarnings("rawtypes") - public Set zrevrange(Object key, long start, long end) { + public List zrevrange(Object key, long start, long end) { - Set data = jedisCluster.zrevrange(keyToBytes(key), start, end); - Set result = new LinkedHashSet(); // 有序集合必须 LinkedHashSet - valueSetFromBytesSet(data, result); + List data = jedisCluster.zrevrange(keyToBytes(key), start, end); + List result = data.stream().map(d->valueFromBytes(d)).collect(Collectors.toList()); // 有序集合必须 LinkedHashSet return result; } @@ -1161,11 +1162,10 @@ public class JbootJedisClusterImpl extends JbootRedisBase { */ @Override @SuppressWarnings("rawtypes") - public Set zrangeByScore(Object key, double min, double max) { + public List zrangeByScore(Object key, double min, double max) { - Set data = jedisCluster.zrangeByScore(keyToBytes(key), min, max); - Set result = new LinkedHashSet(); // 有序集合必须 LinkedHashSet - valueSetFromBytesSet(data, result); + List data = jedisCluster.zrangeByScore(keyToBytes(key), min, max); + List result = data.stream().map(d->valueFromBytes(d)).collect(Collectors.toList()); // 有序集合必须 LinkedHashSet return result; } diff --git a/src/main/java/io/jboot/support/redis/jedis/JbootJedisImpl.java b/src/main/java/io/jboot/support/redis/jedis/JbootJedisImpl.java index 6b58582a..cc58035e 100644 --- a/src/main/java/io/jboot/support/redis/jedis/JbootJedisImpl.java +++ b/src/main/java/io/jboot/support/redis/jedis/JbootJedisImpl.java @@ -24,9 +24,12 @@ import io.jboot.utils.QuietlyUtil; import io.jboot.utils.StrUtil; import redis.clients.jedis.*; import redis.clients.jedis.exceptions.JedisConnectionException; +import redis.clients.jedis.params.ScanParams; +import redis.clients.jedis.resps.ScanResult; import java.util.*; import java.util.Map.Entry; +import java.util.stream.Collectors; /** * 参考： com.jfinal.plugin.redis @@ -993,7 +996,7 @@ public class JbootJedisImpl extends JbootRedisBase { public List blpop(Object... keys) { Jedis jedis = getJedis(); try { - List data = jedis.blpop(keysToBytesArray(keys)); + List data = jedis.blpop(this.config.getTimeout(),keysToBytesArray(keys)); return valueListFromBytesList(data); } finally { returnResource(jedis); @@ -1039,7 +1042,7 @@ public class JbootJedisImpl extends JbootRedisBase { public List brpop(Object... keys) { Jedis jedis = getJedis(); try { - List data = jedis.brpop(keysToBytesArray(keys)); + List data = jedis.brpop(this.config.getTimeout(),keysToBytesArray(keys)); return valueListFromBytesList(data); } finally { returnResource(jedis); @@ -1329,12 +1332,11 @@ public class JbootJedisImpl extends JbootRedisBase { */ @Override @SuppressWarnings("rawtypes") - public Set zrange(Object key, long start, long end) { + public List zrange(Object key, long start, long end) { Jedis jedis = getJedis(); try { - Set data = jedis.zrange(keyToBytes(key), start, end); - Set result = new LinkedHashSet(); // 有序集合必须 LinkedHashSet - valueSetFromBytesSet(data, result); + List data = jedis.zrange(keyToBytes(key), start, end); + List result = data.stream().map(d->valueFromBytes(d)).collect(Collectors.toList()); // 有序集合必须 LinkedHashSet return result; } finally { returnResource(jedis); @@ -1349,12 +1351,11 @@ public class JbootJedisImpl extends JbootRedisBase { */ @Override @SuppressWarnings("rawtypes") - public Set zrevrange(Object key, long start, long end) { + public List zrevrange(Object key, long start, long end) { Jedis jedis = getJedis(); try { - Set data = jedis.zrevrange(keyToBytes(key), start, end); - Set result = new LinkedHashSet(); // 有序集合必须 LinkedHashSet - valueSetFromBytesSet(data, result); + List data = jedis.zrevrange(keyToBytes(key), start, end); + List result = data.stream().map(d->valueFromBytes(d)).collect(Collectors.toList()); // 有序集合必须 LinkedHashSet return result; } finally { returnResource(jedis); @@ -1367,12 +1368,11 @@ public class JbootJedisImpl extends JbootRedisBase { */ @Override @SuppressWarnings("rawtypes") - public Set zrangeByScore(Object key, double min, double max) { + public List zrangeByScore(Object key, double min, double max) { Jedis jedis = getJedis(); try { - Set data = jedis.zrangeByScore(keyToBytes(key), min, max); - Set result = new LinkedHashSet(); // 有序集合必须 LinkedHashSet - valueSetFromBytesSet(data, result); + List data = jedis.zrangeByScore(keyToBytes(key), min, max); + List result = data.stream().map(d->valueFromBytes(d)).collect(Collectors.toList()); // 有序集合必须 LinkedHashSet return result; } finally { returnResource(jedis); diff --git a/src/main/java/io/jboot/support/redis/lettuce/JbootLettuceImpl.java b/src/main/java/io/jboot/support/redis/lettuce/JbootLettuceImpl.java index 260cc82b..a9177729 100644 --- a/src/main/java/io/jboot/support/redis/lettuce/JbootLettuceImpl.java +++ b/src/main/java/io/jboot/support/redis/lettuce/JbootLettuceImpl.java @@ -422,17 +422,17 @@ public class JbootLettuceImpl implements JbootRedis { } @Override - public Set zrange(Object key, long start, long end) { + public List zrange(Object key, long start, long end) { return null; } @Override - public Set zrevrange(Object key, long start, long end) { + public List zrevrange(Object key, long start, long end) { return null; } @Override - public Set zrangeByScore(Object key, double min, double max) { + public List zrangeByScore(Object key, double min, double max) { return null; } diff --git a/src/main/java/io/jboot/support/redis/redisson/JbootRedissonImpl.java b/src/main/java/io/jboot/support/redis/redisson/JbootRedissonImpl.java index aa75966d..7957c604 100644 --- a/src/main/java/io/jboot/support/redis/redisson/JbootRedissonImpl.java +++ b/src/main/java/io/jboot/support/redis/redisson/JbootRedissonImpl.java @@ -411,17 +411,17 @@ public class JbootRedissonImpl implements JbootRedis { } @Override - public Set zrange(Object key, long start, long end) { + public List zrange(Object key, long start, long end) { return null; } @Override - public Set zrevrange(Object key, long start, long end) { + public List zrevrange(Object key, long start, long end) { return null; } @Override - public Set zrangeByScore(Object key, double min, double max) { + public List zrangeByScore(Object key, double min, double max) { return null; } diff --git a/src/test/java/io/jboot/test/cache/redis/RedisCacheTester.java b/src/test/java/io/jboot/test/cache/redis/RedisCacheTester.java index 05d60eb9..dbcd1ff7 100644 --- a/src/test/java/io/jboot/test/cache/redis/RedisCacheTester.java +++ b/src/test/java/io/jboot/test/cache/redis/RedisCacheTester.java @@ -14,6 +14,7 @@ public class RedisCacheTester { public void config() { JbootApplication.setBootArg("jboot.cache.type", "redis"); JbootApplication.setBootArg("jboot.cache.redis.host", "127.0.0.1"); + JbootApplication.setBootArg("jboot.cache.redis.password", "123456"); JbootApplication.setBootArg("jboot.cache.redis.port", "6379"); JbootApplication.setBootArg("jboot.cache.redis.globalKeyPrefix", "myapp"); } @@ -28,6 +29,7 @@ public class RedisCacheTester { public void testPut() { Jboot.getCache().put("cachename", "key", "value"); String value = Jboot.getCache().get("cachename", "key"); + System.out.println(Jboot.getCache().getTtl("cachename", "key")); Assert.assertNotNull(value); } diff --git a/src/test/java/io/jboot/test/redis/RedisTester.java b/src/test/java/io/jboot/test/redis/RedisTester.java index 45bb80db..fcde6617 100644 --- a/src/test/java/io/jboot/test/redis/RedisTester.java +++ b/src/test/java/io/jboot/test/redis/RedisTester.java @@ -17,6 +17,7 @@ public class RedisTester { @Before public void config() { JbootApplication.setBootArg("jboot.redis.host", "127.0.0.1"); + JbootApplication.setBootArg("jboot.redis.password", "123456"); JbootApplication.setBootArg("jboot.redis.port", "6379"); } @@ -26,6 +27,7 @@ public class RedisTester { String key = "JbootRedisValue"; Assert.assertEquals("OK", redis.set(key, "10")); Assert.assertEquals("10", redis.get(key)); + System.out.println(redis.ttl(key)); redis.del(key); } -- Gitee