【xpack源码修改】【android gradle 源码】【c 11 源码】jedis 源码分析

2024-12-23 07:41:33 来源:中天体系源码 分类:焦点

1.Spring Data Redis切换底层Jedis 码分和 Lettuce实现
2.分析SpringBoot 的Redis源码
3.连接池:别让连接池帮了倒忙
4.jedis 和 strpin-data-redis 哪一个好
5.Jedis连接池究竟是何物?
6.Jedis那么低性能,还在用?赶紧换上 lettuce 吧!码分

jedis 源码分析

Spring Data Redis切换底层Jedis 和 Lettuce实现

       Spring Data Redis提供了对Redis操作的高级抽象,支持Jedis和Lettuce两种连接方式。码分通过简单的码分配置即可连接Redis并切换连接方式。具体步骤如下:

       引入Redis依赖使用Spring Boot的码分xpack源码修改spring-boot-starter-data-redis。

       自定义配置类设置Key和Value的码分序列化。

       修改Redis连接配置,码分可自由切换单节点、码分哨兵模式和集群模式。码分

       注入RedisTemplate后,码分即可操作Redis。码分RedisTemplate具有两个泛型。码分

       源码分析部分,码分从Redis自动配置类RedisAutoConfiguration开始,码分它引入了两个连接Redis配置类:LettuceConnectionConfiguration和JedisConnectionConfiguration。这两个配置类通过条件注解控制是否生效,如果生效,则会使用相应的依赖生成RedisConnectionFactory的Bean。引入Lettuce依赖时,能通过io.lettuce.core.RedisClient找到类,android gradle 源码说明默认使用Lettuce。若无Jedis相关依赖,则当前配置类无效。

       切换连接方式至Jedis有两种方式:利用@ConditionalOnClass注解排除Lettuce依赖,或利用@ConditionalOnProperty注解修改配置文件中的spring.redis.client-type为jedis。第一种方式优点在于不加载多余的依赖包,推荐使用。第二种方式则可通过配置文件自由切换连接方式。

       本文由OpenWrite平台发布。请按照上述步骤进行Spring Data Redis的使用和连接方式切换。

分析SpringBoot 的Redis源码

       在Spring Boot 2.X版本中,官方简化了项目配置,如无需编写繁琐的web.xml和相关XML文件,只需在pom.xml中引入如spring-boot-starter-data-redis的starter包即可完成大部分工作,这极大地提高了开发效率。

       深入理解其原理,我们研究了spring-boot-autoconfigure和spring-boot-starter-data-redis的源码。首先,配置项在application.properties中的设置会被自动映射到名为RedisProperties的类中,此类由RedisAutoConfiguration类负责扫描和配置。c 11 源码该类会检测是否存在RedisOperations接口的实现,例如官方支持的Jedis或Lettuce,以此来决定使用哪个客户端。

       在RedisAutoConfiguration中,通过@Bean注解,它引入了LettuceConnectionConfiguration和JedisConnectionConfiguration,这两个配置类会创建RedisConnectionFactory实例。在注入RedisTemplate时,实际使用的会是第一个被扫描到的RedisConnectionFactory,这里通常是LettuceConnectionFactory,因为它们在@Import注解的导入顺序中位于前面。

       自定义starter时,可以模仿官方starter的结构,首先引入spring-boot-autoconfigure,然后创建自己的配置类(如MyRedisProperties)和操作模板类(如JedisTemplete)。在MyRedisAutoConfiguration中,你需要编写相关配置并确保在spring.factories文件中注册,以便Spring Boot在启动时扫描到你的自定义配置。

       以自定义my-redis-starter为例,项目结构包括引入的app签到源码依赖,配置类的属性绑定,以及创建连接池和操作方法的实现。测试时,只需在Spring Boot项目中引入自定义starter,配置好相关参数,即可验证自定义starter的正确工作。

连接池:别让连接池帮了倒忙

       连接池技术在业务项目中扮演着重要角色,尤其是在数据库连接池、Redis连接池和HTTP连接池的使用上。今天,我们将围绕连接池的结构、使用和配置,以及如何避免常见错误,来深入探讨这一话题。

       连接池的结构主要包括对外提供连接获取与归还接口的客户端使用,以及内部实现的连接建立、连接心跳保持、连接管理、空闲连接回收、连接可用性检测等功能。jquery 源码解析在业务项目中,数据库连接池、Redis连接池和HTTP连接池是最常见的三种连接池。

       在使用第三方客户端SDK进行网络通信时,首先需要确认SDK是否基于连接池技术实现。TCP作为面向连接的基于字节流的协议,如果SDK没有使用连接池,而是直接建立TCP连接,将需要考虑每次连接的开销,并且在多线程环境下可能产生线程安全问题。因此,识别SDK连接池的实现方式至关重要。

       以Jedis作为Redis操作最常见的库为例,分析其源码。Jedis类是连接池与连接分离的API,内部维护一个Socket连接,多线程环境下复用连接可能导致命令执行不完整或线程安全问题。使用连接池如JedisPool,可以实现线程安全的复用,避免这些问题。确保关闭连接池,最好通过shutdownhook在程序退出时释放资源。

       连接池的配置不是一成不变的。最大连接数的设置需要根据容量规划,过大或过小都会影响性能。通过实践和监控,可以有效调整参数,满足性能需求同时避免资源浪费。连接池的正确使用方式包括复用连接和确保在程序退出前关闭连接池。

       总结来说,理解连接池的实现方式、正确使用姿势和合理配置参数是确保高效、稳定的连接管理的关键。连接池技术能够显著提升性能,减少资源浪费,因此正确应用连接池对于提高系统性能至关重要。

jedis 和 strpin-data-redis 哪一个好

       ä¹‹å‰ä¸€ç›´æ²¡ä»”细看过ShardedJedis的代码,最近遇到了shard后集群扩容后的数据迁移问题。

       ä»Šå¤©åœ¨çœ‹ShardedJedis源码的时候,发现ShardedJedis并没有使用节点的Ip和port做hash,而是用的instance的顺序或者name,太赞了。

       private void initialize(List<S> shards) {

        nodes = new TreeMap<Long, S>();

       for (int i = 0; i != shards.size(); ++i) {

        final S shardInfo = shards.get(i);

        if (shardInfo.getName() == null)

        for (int n = 0; n < * shardInfo.getWeight(); n++) {

        nodes.put(this.algo.hash("SHARD-" + i + "-NODE-" + n),

        shardInfo);

        }

        else

        for (int n = 0; n < * shardInfo.getWeight(); n++) {

        nodes.put(

        this.algo.hash(shardInfo.getName() + "*"

        + shardInfo.getWeight() + n), shardInfo);

        }

        resources.put(shardInfo, shardInfo.createResource());

        }

        }

       é…ç½®çš„时候也非常简单:

       <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">

        <property name="maxTotal" value=""/>

        <property name="maxIdle" value=""/>

        <property name="minIdle" value="1"/>

        <property name="maxWaitMillis" value=""/>

        <property name="testOnBorrow" value="true"/>

        <property name="testOnReturn" value="true"/>

        <property name="testWhileIdle" value="true"/>

        </bean>

        <bean id="shardedJedisPool" class="redis.clients.jedis.ShardedJedisPool" destroy-method="destroy">

        <constructor-arg ref="jedisPoolConfig"/>

        <constructor-arg>

        <list>

        <bean class="redis.clients.jedis.JedisShardInfo">

        <constructor-arg value=".0.0.1"/>

        <constructor-arg type="int" value=""/>

        <constructor-arg value="instance:"/>

        </bean>

        <bean class="redis.clients.jedis.JedisShardInfo">

        <constructor-arg value=".0.0.1"/>

        <constructor-arg type="int" value=""/>

        <constructor-arg value="instance:"/>

        </bean>

        <bean class="redis.clients.jedis.JedisShardInfo">

        <constructor-arg value=".0.0.1"/>

        <constructor-arg type="int" value=""/>

        <constructor-arg value="instance:"/>

        </bean>

        </list>

        </constructor-arg>

        </bean>

       ä¸€å¼€å§‹ä½ å¯ä»¥è®¾ç½®è¶³å¤Ÿå¤šçš„instance,数据扩容的时候,只需要将几个instance的数据copy到别的机器上。

       ç„¶åŽä¿®æ”¹é…ç½®æ–‡ä»¶çš„ip和端口即可。很方便吧?

       å¦å¤–,Jedis还提供了对jedis sentinel pool的封装,所以发生主从切换的时候,web server都不需要重新配置和deploy。高可用性的极佳体现啊。

       @Autowired private JedisSentinelPool pool;

       public void mymethod() {

        Jedis jedis = null;

        try {

        jedis = pool.getResource();

        jedis.hset(....

        } catch (JedisException je) {

        throw je;

        } finally {

        if (jedis != null) pool.returnResource(jedis);

        }

        }

       spring bean的配置:

       <bean id="redisSentinel" class="redis.clients.jedis.JedisSentinelPool">

        <constructor-arg index="0" value="mymaster" />

        <constructor-arg index="1">

        <set>

        <value>hostofsentinel:</value>

        </set>

        </constructor-arg>

        <constructor-arg index="2" ref="jedisPoolConfig" />

        </bean>

Jedis连接池究竟是何物?

       连接池是管理并回收资源的对象集合,以减少系统资源的创建和销毁开销,提升系统吞吐量,适用于创建/销毁资源耗时的场景。以Jedis为例,其底层使用的是GenericObjectPool作为连接池实现。业务从空闲连接队列获取连接,最长等待时间由maxWaitMillis决定。获取后,检查是否有效,关闭后再次放入空闲队列或销毁。连接池的参数如配置文件中详细列出,Spring-Data-Redis将参数进行收敛,用户主要配置参数较少,关键参数包括验证方法的启用和关闭。Jedis实例通过Spring-Data-Redis封装后,实现对连接池的管理,提供了BorrowObject方法获取连接和ReturnObject方法归还连接。其中BorrowObject方法可能从空闲队列获取或创建新连接,超过最大等待时间则抛出异常。ReturnObject方法负责归还连接并进行有效性验证。连接池还包括定期驱逐/保活机制、检查机制和抛弃机制,通过配置参数、源码分析和JMX工具实现连接状态监控和问题排查。了解连接池原理有助于提升资源管理效率,并在实际应用中根据业务需求优化配置。

Jedis那么低性能,还在用?赶紧换上 lettuce 吧!

       在大型企业的技术栈中,经常面临着选择Redis客户端工具的决策:Jedis、Redisson还是Lettuce?本文将深入探讨这三者的优缺点,以助你做出明智的选择。

       首先,我们来看一下官方推荐的三款Java客户端:Jedis,老牌的Redis客户端,它提供了全面的Redis命令支持,其官网链接为<a href="tool.oschina.net/upload...">tool.oschina.net/upload...,其优点在于功能全面,但可能在性能上存在短板。

       相比之下,Redisson是一个基于Redis的Java内存网格框架,它简化了Redis的使用,提供了一系列分布式Java对象和服务,如分布式锁和Spring cache等。Redisson官网和Git地址分别为:<a href="redisson.org/">redisson.org/ 和 <a href="github.com/redisson/red...">

       github.com/redisson/red...。Redisson强调关注分离,有助于业务逻辑的处理,但不支持某些高级Redis特性。

       然后是Lettuce,一个可扩展的线程安全Redis客户端,支持异步操作,并在多线程环境中表现出色,特别是对于避免阻塞和事务操作。Lettuce基于Netty,支持高级Redis功能,官网和Git地址是:<a href="lettuce.io/">lettuce.io/ 和 <a href="github.com/lettuce-io/l...">

       github.com/lettuce-io/l...。Lettuce在性能上优于Jedis,特别适合对高级功能需求不高的场景。

       在实际选择中,Jedis和Lettuce适合基础Redis操作,而Redisson则适合需要分布式和扩展性功能的应用。如果考虑使用分布式锁或高级数据结构,Redisson是更好的选择,但需注意其对字符串操作的限制。在Spring Boot 2及更高版本中,lettuce成为了默认连接选择,反映了其在性能上的优势。

       关于链接断裂的问题,Lettuce不提供心跳机制,但可以利用Netty的空闲检测机制来维持连接。这需要对Netty的开发和源码有一定理解,相关资料可以参考《java高并发核心编程卷1加强版》。

       总之,如果你追求性能和基础操作,Lettuce是值得考虑的升级选择。别让技术选择阻碍你的进步,及时更新和学习新的工具,保持技术的前沿性。

更多资讯请点击:焦点

推荐资讯

烏克蘭武裝部隊確認從阿夫傑耶夫卡方向拉斯托奇金諾村撤軍

烏克蘭國家通訊社當地時間26日報道稱,烏克蘭武裝部隊確認從阿夫傑耶夫卡方向拉斯托奇金諾村撤軍。此前,俄羅斯國防部發布消息稱,俄軍部隊控制了阿夫傑耶夫卡方向的拉斯托奇金諾村。來源:央視新聞客戶端)責任編

“铁拳”行动 | 河北:集中销毁120余吨假冒伪劣商品

中国消费者报石家庄讯记者李建)6月27日,河北省市场监管局组织开展2023年民生领域案件查办“铁拳”行动和“打假保名优”罚没物品集中统一销毁活动,对食品、日化用品、药械、童车、汽车配件、品牌运动鞋服等

四川“春雷行动2023”监测网络电商平台4.36万次 查处案件3.4万件

中国消费者报成都讯记者刘铭)日前,记者从四川省市场监管系统“春雷行动2023”总结会议上获悉,行动期间,四川省市场监管系统围绕6项重点整治任务,共查处案件3.4万件、移送司法机关案件335件;四川省市