redis-lettuce连接池

Posted 2023-03-30 @@星辰大海

概念

客户端连接 Redis 使用的是 TCP协议，直连的方式每次需要建立 TCP连接，而连接池的方式是可以预先初始化好客户端连接，所以每次只需要从 连接池借用即可，而借用和归还操作是在本地进行的，只有少量的并发同步开销，远远小于新建TCP连接的开销。另外，直连的方式无法限制 redis客户端对象的个数，在极端情况下可能会造成连接泄漏，而连接池的形式可以有效的保护和控制资源的使用。

两个框架

比较突出的是 Lettuce 和 jedis。Lettuce 和 jedis 的都是连接 Redis Server的客户端，Jedis 在实现上是直连 redis server，多线程环境下非线程安全，除非使用连接池，为每个 redis实例增加 物理连接。
Lettuce 是 一种可伸缩，线程安全，完全非阻塞的Redis客户端，多个线程可以共享一个RedisConnection,它利用Netty NIO 框架来高效地管理多个连接，从而提供了异步和同步数据访问方式，用于构建非阻塞的反应性应用程序。

比较

在 springboot 1.5.x版本的默认的Redis客户端是 Jedis实现的，springboot 2.x版本中默认客户端是用 lettuce实现的。

  Jedis 和 Lettuce 是 Java 操作 Redis 的客户端。在 Spring Boot 1.x 版本默认使用的是 jedis ，而在 Spring Boot 2.x 版本默认使用的就是Lettuce。关于 Jedis 跟 Lettuce 的区别如下：

Jedis在实现上是直接连接的redis server，如果在多线程环境下是非线程安全的，这个时候只有使用连接池，为每个Jedis实例增加物理连接
Lettuce的连接是基于Netty的，连接实例（StatefulRedisConnection）可以在多个线程间并发访问，应为StatefulRedisConnection是线程安全的，所以一个连接实例（StatefulRedisConnection）就可以满足多线程环境下的并发访问，当然这个也是可伸缩的设计，一个连接实例不够的情况也可以按需增加连接实例。
springboot2.x通过配置类连接工厂方式集成Redis并不会读取配置文件中的 spring.redis.host等这样的配置
lettuce与jedis两者有什么区别呢？

lettuce：底层是用netty实现，线程安全，默认只有一个实例。
jedis：可直连redis服务端，配合连接池使用，可增加物理连接。

在执行一些简单指令的情况下，lettuce不配置连接池，使用单连接是最佳方案。连接池配置太小，性能会急剧下降，连接池配置太大，性能和单连接情况下大致相当，但会造成资源浪费。

需要配置LettuceConnectionFactory参数“shareNativeConnection”为false，该参数默认为true，默认启用共享连接，此时所有redis操作共用一个redis物理连接，redis连接池配置失效。
得益于netty内部种采用的异步处理方式，相较于采用连接池的方式，更加高效。
总结 要想使lettuce连接池生效，即使用多个redis物理连接。这行设置不能缺少
genericObjectPoolConfig.setTimeBetweenEvictionRunsMillis(100); 这个设置是，每隔多少毫秒，空闲线程驱逐器关闭多余的空闲连接，且保持最少空闲连接可用，这个值最好设置大一点，否者影响性能。同时 genericObjectPoolConfig.setMinIdle(minIdle); 中minldle值要大于0。
lettuce连接池属性timeBetweenEvictionRunsMillis如果不设置 默认是 -1，当该属性值为负值时，lettuce连接池要维护的最小空闲连接数的目标minIdle就不会生效 。
factory.setShareNativeConnection(true)，shareNativeConnection 这个属性默认是true,允许多个连接公用一个物理连接。如果设置false ,每一个连接的操作都会开启和关闭socket连接。如果设置为false,会导致性能下降
factory.setValidateConnection(false)， validateConnection这个属性是每次获取连接时，校验连接是否可用。默认false,不去校验。默认情况下，lettuce开启一个共享的物理连接，是一个长连接，所以默认情况下是不会校验连接是否可用的。如果设置true,会导致性能下降。

连接池

一、连接池介绍

  一次性创建多个连接，将多个连接缓存在内存中，形成数据库连接池，如果应用程序需要操作数据库，只需要从连接池中获取一个连接，使用后，并不需要关闭连接，只需要将连接放回到连接池中。

  连接池的好处：节省创建连接与释放连接，连接池中连接起到复用的作用，提高程序性能。

二、自定义连接池

  编写连接池需要实现javax.sql.DataSource接口。DataSource接口中定义了两个重载的方法。

public Connection getConnection() throws SQLException

publicConnection getConnection(String username,String password) throws SQLException

  实现DataSource接口，并实现连接池功能的步骤：

    在DataSource构造方法中批量创建于数据库的连接，并把创建的连接保存到一个集合对象之中。

    实现getConnection()方法，让getConnection()方法每次调用时，从集合对象中取出一个Connection对象返回给用户。

    当用户使用完Connection，调用conn.close()方法时，Connection对象应该保证将自己返回到连接池的集合对象中，而不应该把conn还给数据库。

  自定义连接池注意问题：

    尽量不要使用具体对象类型的引用。

    使用自定义方法close()将连接放回到连接池，需要用户在使用的时候调用额外的API，即让用户定义连接池的时候，DataSource  dataSource = new MyDataSource()；在用户使用连接后，应该调用conn.close()完成将连接放回到连接池。

三、主流开源连接池

  DBCP连接池和c3p0连接池

本文出自 “11831428” 博客，请务必保留此出处http://11841428.blog.51cto.com/11831428/1911595