Jedis 的编程实践 - 版本历史

Eijux：/* JedisPool：使用 */

2021-12-27T04:54:48Z

JedisPool：使用

←上一版本		2021年12月27日 (一) 12:54的版本
第581行：		第581行：
	}		}
	</syntaxhighlight>		</syntaxhighlight>



第638行：		第639行：
	testDel(); // 首先删除之前创建的Zset		testDel(); // 首先删除之前创建的Zset

	try (~~Jedisredis~~ = JredisPoolBuilder.getJedis()) {		try (Jedis redis = JredisPoolBuilder.getJedis()) {
	int loop = 0;		int loop = 0;
	long start = System.currentTimeMillis();		long start = System.currentTimeMillis();

Eijux：/* JedisPool连接池 */

2021-11-05T23:57:50Z

JedisPool连接池

←上一版本		2021年11月6日 (六) 07:57的版本
第581行：		第581行：
	}		}
	</syntaxhighlight>		</syntaxhighlight>


	=== JedisPool：使用 ===		=== JedisPool：使用 ===
第593行：		第594行：
	: <syntaxhighlight lang="Java" highlight="">		: <syntaxhighlight lang="Java" highlight="">
	package com.crazymakercircle.redis.jedisPool;		package com.crazymakercircle.redis.jedisPool;
	//. . .		//...
	public class JredisPoolTester {		public class JredisPoolTester {
	public static final int NUM = 200;		public static final int NUM = 200;
第617行：		第618行：
	}		}

	//. . .		//...
	}		}
	</syntaxhighlight>		</syntaxhighlight>
第627行：		第628行：
	: <syntaxhighlight lang="Java" highlight="">		: <syntaxhighlight lang="Java" highlight="">
	package com.crazymakercircle.redis.jedisPool;		package com.crazymakercircle.redis.jedisPool;
	//. . .		//...
	public class JredisPoolTester {		public class JredisPoolTester {
	public static final int NUM = 200;		public static final int NUM = 200;
第649行：		第650行：
	}		}

	//. . .		//...
	}		}
	</syntaxhighlight>		</syntaxhighlight>

Eijux：/* JedisPool：使用 */

2021-11-05T23:57:04Z

JedisPool：使用

←上一版本		2021年11月6日 (六) 07:57的版本
第583行：		第583行：

	=== JedisPool：使用 ===		=== JedisPool：使用 ===
			JedisPool 的使用：
			# 可以使用前面定义好的“'''getJedis()'''”方法，间接地通过“pool.getResource()”从连接池获取连接；也可以直接通过“'''pool.getResource()'''”方法获取 Jedis 连接。
			# Jedis 连接使用完后，一定要调用“'''close()'''”方法关闭连接。
			#* 这个关闭操作不是真正地关闭连接，而是归还给连接池。这一点和使用数据库连接池是一样的。
			#* 一般来说，关闭操作放在 '''finally''' 代码段中，确保 Jedis 的关闭最终都会被执行到。


			示例：
			: <syntaxhighlight lang="Java" highlight="">
			package com.crazymakercircle.redis.jedisPool;
			//. . .
			public class JredisPoolTester {
			public static final int NUM = 200;
			public static final String ZSET_KEY = "zset1";

			// 测试删除
			@Test
			public void testDel() {
			Jedisredis =null;
			try {
			redis = JredisPoolBuilder.getJedis();

			long start = System.currentTimeMillis();
			redis.del(ZSET_KEY);
			long end = System.currentTimeMillis();
			Logger.info("删除 zset1 毫秒数:", end - start);
			} finally {
			// 使用后一定关闭，还给连接池
			if (redis != null) {
			redis.close();
			}
			}
			}

			//. . .
			}
			</syntaxhighlight>


			由于 Jedis 类实现了'''java.io.Closeable'''接口，故而在 JDK 1.7 或者以上版本中可以使用 '''try-with-resources''' 语句，在其隐藏的 finally 部分自动调用 close 方法。

			示例：
			: <syntaxhighlight lang="Java" highlight="">
			package com.crazymakercircle.redis.jedisPool;
			//. . .
			public class JredisPoolTester {
			public static final int NUM = 200;
			public static final String ZSET_KEY = "zset1";

			// 测试创建Zset
			@Test
			public void testSet() {
			testDel(); // 首先删除之前创建的Zset

			try (Jedisredis = JredisPoolBuilder.getJedis()) {
			int loop = 0;
			long start = System.currentTimeMillis();
			while (loop < NUM) {
			redis.zadd(ZSET_KEY, loop, "field-" + loop);
			loop++;
			}
			long end = System.currentTimeMillis();
			Logger.info("设置Zset :", loop, "次, 毫秒数:", end - start);
			}
			}

			//. . .
			}
			</syntaxhighlight>

Eijux：/* JedisPool：创建、预热 */

2021-11-05T23:46:44Z

JedisPool：创建、预热

←上一版本		2021年11月6日 (六) 07:46的版本
第511行：		第511行：
	package com.crazymakercircle.redis.jedisPool;		package com.crazymakercircle.redis.jedisPool;
	//...		//...
	public class JredisPoolBuilder {		public class JredisPoolBuilder {
	public static final int MAX_IDLE = 50;		public static final int MAX_IDLE = 50;
	public static final int MAX_TOTAL = 50;		public static final int MAX_TOTAL = 50;

Eijux：/* JedisPool：创建、预热 */

2021-11-05T23:45:47Z

JedisPool：创建、预热

@@ 第493行： / 第493行： @@
 === JedisPool：创建、预热 ===
+代码实现：
+<syntaxhighlight lang="Java" highlight="">
+package com.crazymakercircle.redis.jedisPool;
+//...
 === JedisPool：使用 ===

Eijux：/* JedisPool连接池 */

2021-11-05T23:28:25Z

JedisPool连接池

←上一版本		2021年11月6日 (六) 07:28的版本
第423行：		第423行：
	Jedis 连接和数据库连接一样，也需要使用连接池（Connection Pool）来管理。		Jedis 连接和数据库连接一样，也需要使用连接池（Connection Pool）来管理。

			Jedis 开源库提供了一个负责管理 Jedis 连接对象的池，名为'''JedisPool 类'''，位于 '''redis.clients.jedis''' 包中。

	~~Jedis 开源库提供了一个负责管理 Jedis 连接对象的池，名为'''JedisPool 类'''，位于 '''redis.clients.jedis''' 包中。~~

	=== JedisPool：配置 ===		=== JedisPool：配置 ===
第490行：		第490行：

	使得连接池达到最佳性能的设置是“'''maxTotal = maxIdle'''”，应尽可能地避免由于频繁地创建和销毁 Jedis 连接所带来的连接池性能的下降。		使得连接池达到最佳性能的设置是“'''maxTotal = maxIdle'''”，应尽可能地避免由于频繁地创建和销毁 Jedis 连接所带来的连接池性能的下降。


	=== JedisPool：创建、预热 ===		=== JedisPool：创建、预热 ===

Eijux：/* JedisPool：配置 */

2021-11-05T23:27:21Z

JedisPool：配置

←上一版本		2021年11月6日 (六) 07:27的版本
第471行：		第471行：


			==== 关于“maxTotal” ====
			有个实际的问题：如何推算一个连接池的最大连接数 maxTotal 呢？
			实际上，这是一个很难精准回答的问题，主要是依赖的因素比较多。大致的推算方法是：“'''业务QPS / 单连接的QPS = 最大连接数'''”。

			如何推算单个 Jedis 连接的 QPS 呢？
			假设一个Jedis命令操作的时间约为 5ms（包含：borrow + return + Jedis执行命令 + 网络延迟），那么，单个 Jedis 连接的 QPS 大约是“1000 / 5 = 200”。

			所以，如果业务期望的 QPS 是 100000，则需要的最大连接数为“100000 / 200 = 500”。
			事实上，上面的估算仅仅是个理论值。在实际的生产场景中，还要预留一些资源，'''通常来讲所配置的 maxTotal 要比理论值大一些'''。
			* 如果连接数确实太多，可以考虑 Redis 集群，那么单个 Redis 节点的最大连接数的公式为：“maxTotal = 预估的连接数 / nodes节点数”。

			在并发量不大时，maxTotal 设置过高会导致不必要的连接资源的浪费。可以根据实际总 QPS 和 nodes 节点数，合理评估每个节点所使用的最大连接数。


			==== 关于“maxIdle” ====
			再看一个问题：如何推算连接池的最大空闲连接数 maxIdle 值呢？
			'''实际上，maxTotal 只是给出了一个连接数量的上限，maxIdle 实际上才是业务可用的最大连接数'''，从这个层面来说，maxIdle不能设置过小，否则会有创建、销毁连接的开销。

			使得连接池达到最佳性能的设置是“'''maxTotal = maxIdle'''”，应尽可能地避免由于频繁地创建和销毁 Jedis 连接所带来的连接池性能的下降。

	=== JedisPool：创建、预热 ===		=== JedisPool：创建、预热 ===

Eijux：/* JedisPool连接池的实践 */

2021-11-05T23:12:04Z

JedisPool连接池的实践

←上一版本		2021年11月6日 (六) 07:12的版本
第414行：		第414行：
	</syntaxhighlight>		</syntaxhighlight>

	== ~~JedisPool连接池的实践~~ ==		== JedisPool连接池 ==
			使用 Jedis API 可以方便地在 Java 程序中操作 Redis，就像通过 JDBC API 操作数据库一样。但是，仅仅实现这一点还是不够的。

			为什么呢？
			大家知道，数据库连接的底层是一条 Socket 通道，创建和销毁很耗时。
			在数据库连接过程中，为了防止数据库连接的频繁创建、销毁带来的性能损耗，常常会用到'''连接池（Connection Pool）'''，例如淘宝的 Druid 连接池、Tomcat 的 DBCP 连接池。

			Jedis 连接和数据库连接一样，也需要使用连接池（Connection Pool）来管理。


			Jedis 开源库提供了一个负责管理 Jedis 连接对象的池，名为'''JedisPool 类'''，位于 '''redis.clients.jedis''' 包中。

			=== JedisPool：配置 ===
			在使用 JedisPool 类创建 Jedis 连接池之前，首先要了解一个很重要的配置类——'''JedisPoolConfig 配置类'''，它也位于 redis.clients.jedis 包中。这个连接池的配置类负责配置 JedisPool 的参数。


			'''JedisPoolConfig 配置类'''涉及到很多与连接管理和使用有关的参数：
			# '''maxTotal'''：资源池中最大的连接数，默认值为 '''8'''。
			# '''maxIdle'''：资源池允许最大空闲的连接数，默认值为 '''8'''。
			# '''minIdle'''：资源池确保最少空闲的连接数，默认值为 '''0'''。
			#* 如果 JedisPool 开启了空闲连接的有效性检测，如果空闲连接无效，就销毁。销毁连接后，连接数量就少了，如果小于 minIdle 数量，就新建连接，维护数量不少于 minIdle 的数量。
			#* minIdle 确保了线程池中有最小的空闲 Jedis 实例的数量。
			# '''blockWhenExhausted'''：当资源池用尽后，调用者是否要等待，默认值为 true。
			#* 当为 true 时，maxWaitMillis 才会生效。
			# '''maxWaitMillis'''：当资源池连接用尽后，调用者的最大等待时间（单位为毫秒）。
			#* 默认值为 '''-1'''，表示永不超时，不建议使用默认值。
			# '''testOnBorrow'''：向资源池借用连接时，是否做有效性检测（ping命令）：如果是无效连接，会被移除。
			#* 默认值为 false，表示不做检测。
			#* 如果为 true，则得到的 Jedis 实例均是可用的。
			#* 在业务量小的应用场景，建议设置为 true，确保连接可用；在业务量很大的应用场景，建议设置为 false（默认值），少一次 ping 命令的开销，有助于提升性能。
			# '''testOnReturn'''：向资源池归还连接时，是否做有效性检测（ping命令）：如果是无效连接，会被移除。
			#* 默认值为 false，表示不做检测。
			#* 同样，在业务量很大的应用场景，建议设置为 false（默认值），少一次 ping 命令的开销。
			# '''testWhileIdle'''：如果为 true，表示用一个专门的线程对空闲的连接进行有效性的检测扫描，如果有效性检测失败，即表示无效连接，会从资源池中移除。
			#* 默认值为true，表示进行空闲连接的检测。
			#* 这个选项存在一个附加条件，需要配置项 timeBetweenEvictionRunsMillis 的值大于 '''0'''；否则，testWhileIdle 不会生效。
			# '''timeBetweenEvictionRunsMillis'''：表示两次空闲连接扫描的活动之间，要睡眠的毫秒数，默认为30000毫秒，也就是30秒钟。
			# '''minEvictableIdleTimeMillis'''：表示一个 Jedis 连接至少停留在空闲状态的最短时间，然后才能被空闲连接扫描线程进行有效性检测，默认值为 '''60000''' 毫秒，即 60 秒。
			#: 也就是说在默认情况下，一条 Jedis 连接只有在空闲 60 秒后，才会参与空闲线程的有效性检测。
			#* 这个选项存在一个附加条件，需要在 timeBetweenEvictionRunsMillis 大于 '''0''' 时才会生效。也就是说，如果不启动空闲检测线程，这个参数也没有什么意义。
			# '''numTestsPerEvictionRun'''：表示空闲检测线程每次最多扫描的 Jedis 连接数，默认值为 '''-1'''，表示扫描全部的空闲连接。
			#* 空闲扫描的选项在 JedisPoolConfig 的构造器中都有默认值，具体如下：
			#*: <syntaxhighlight lang="Java" highlight="">
			package redis.clients.jedis;
			import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
			public class JedisPoolConfig extends GenericObjectPoolConfig {
			public JedisPoolConfig() {
			this.setTestWhileIdle(true);
			this.setMinEvictableIdleTimeMillis(60000L);
			this.setTimeBetweenEvictionRunsMillis(30000L);
			this.setNumTestsPerEvictionRun(-1);
			}
			}
			</syntaxhighlight>
			# '''jmxEnabled'''：是否开启 jmx 监控，默认值为 true，建议开启。










			=== JedisPool：创建、预热 ===







			=== JedisPool：使用 ===

Eijux：/* Jedis 操作 Zset（有序集合） */

2021-11-05T22:54:26Z

Jedis 操作 Zset（有序集合）

←上一版本		2021年11月6日 (六) 06:54的版本
第413行：		第413行：
	[main\|ZSetDemo.operateZset] \|>jedis.zrange(): [u11, u12, u13]		[main\|ZSetDemo.operateZset] \|>jedis.zrange(): [u11, u12, u13]
	</syntaxhighlight>		</syntaxhighlight>

			== JedisPool连接池的实践 ==

Eijux：/* Jedis 操作 List（列表） */

2021-11-05T22:53:32Z

Jedis 操作 List（列表）

←上一版本		2021年11月6日 (六) 06:53的版本
第131行：		第131行：
	=== Jedis 操作 List（列表） ===		=== Jedis 操作 List（列表） ===
	示例：		示例：
	: <syntaxhighlight lang="Java" highlight="">		: <syntaxhighlight lang="Java" highlight="" line>
	package com.crazymakercircle.redis.jedis;		package com.crazymakercircle.redis.jedis;
	//...		//...

Jedis 的编程实践 - 版本历史

Eijux：​/* JedisPool：使用 */

Eijux：​/* JedisPool连接池 */

Eijux：​/* JedisPool：使用 */

Eijux：​/* JedisPool：创建、预热 */

Eijux：​/* JedisPool：创建、预热 */

Eijux：​/* JedisPool连接池 */

Eijux：​/* JedisPool：配置 */

Eijux：​/* JedisPool连接池的实践 */

Eijux：​/* Jedis 操作 Zset（有序集合） */

Eijux：​/* Jedis 操作 List（列表） */

Eijux：/* JedisPool：使用 */

Eijux：/* JedisPool连接池 */

Eijux：/* JedisPool：使用 */

Eijux：/* JedisPool：创建、预热 */

Eijux：/* JedisPool：创建、预热 */

Eijux：/* JedisPool连接池 */

Eijux：/* JedisPool：配置 */

Eijux：/* JedisPool连接池的实践 */

Eijux：/* Jedis 操作 Zset（有序集合） */

Eijux：/* Jedis 操作 List（列表） */