Redis【有与无】【Lettuce】L9.CDI支持、Spring支持
本文章基于Redis 6.0.9版本,Lettuce 6.0.1.RELEASE版本
目录
1.CDI支持
RedisClient
和RedisClusterClient
提供对Lettuce的CDI支持。 你需要提供一个RedisURI
才能注入Lettuce 。
1.1.RedisURI生产者
实现RedisURI
的简单生产者(字段生产者或生产者方法):
@Produces
public RedisURI redisURI() {
return RedisURI.Builder.redis("localhost").build();
}
Lettuce还支持合格的RedisURI
:
@Produces
@PersonDB
public RedisURI redisURI() {
return RedisURI.Builder.redis("localhost").build();
}
1.2.注入(Injection)
在声明你的RedisURI
之后,你可以在类中开始使用Lettuce:
public class InjectedClient {
@Inject
private RedisClient redisClient;
@Inject
private RedisClusterClient redisClusterClient;
@Inject
@PersonDB
private RedisClient redisClient;
private RedisConnection<String, String> connection;
@PostConstruct
public void postConstruct() {
connection = redisClient.connect();
}
public void pingRedis() {
connection.ping();
}
@PreDestroy
public void preDestroy() {
if (connection != null) {
connection.close();
}
}
}
1.3.**Lettuce的CDI扩展
默认情况下,只需将Lettuce放在类路径上并声明至少一个RedisURI
bean。
CDI扩展为每个发现的RedisURI
注册一个bean对(RedisClient
和RedisClusterClient
)。 这意味着,如果你不声明任何RedisURI
生产者,则CDI扩展根本不会被**。 这样,你甚至可以在不启用CDI扩展的情况下在具有CDI功能的容器中使用Lettuce。
只要你的应用程序正在运行,所有产生的bean(RedisClient
和RedisClusterClient
)都将保持活动状态,因为这些bean是@ApplicationScoped
。
2.Spring支持
从5.3版开始,不再支持Lettuce的Spring支持,并在Lettuce 6中将其删除。
2.1.Spring Data Redis
通过Spring Data Redis使用Lettuce为Redis的使用提供了熟悉的Spring抽象。 它与其他Spring组件(例如Spring Session或Spring Boot)很好地集成在一起。 有关Lettuce的用法,请参见Spring Data Redis参考文档。
2.2.Redis Client
可以通过RedisClient
使用Lettuce Standalone/Sentinel/Pub/Sub 和Upstream/Replica。你可以提供bean定义来管理Spring上下文中的Lettuce资源。 Bean管理可以照顾资源分配并通过Spring的Bean生命周期管理进行清理。 使用托管Bean,你可以从代码中的各个位置访问Lettuce的RedisClient/connections。 你的代码也可以从依赖注入中受益。
2.2.1.Java配置
使用带有@Bean
定义的Spring Java配置来配置生菜需要你提供Bean定义。 请注意,一旦应用程序上下文关闭,destroyMethod
的规范即可清理资源。
@Configuration
public class LettuceConfig {
@Bean(destroyMethod = "shutdown")
ClientResources clientResources() {
return DefaultClientResources.create();
}
@Bean(destroyMethod = "shutdown")
RedisClient redisClient(ClientResources clientResources) {
return RedisClient.create(clientResources, RedisURI.create(TestSettings.host(), TestSettings.port()));
}
@Bean(destroyMethod = "close")
StatefulRedisConnection<String, String> connection(RedisClient redisClient) {
return redisClient.connect();
}
}
2.2.2.XML配置
使用RedisClientFactoryBean
通过基于XML的配置来创建RedisClient
的托管实例。
<bean id="redisClient" class="io.lettuce.core.support.RedisClientFactoryBean">
<property name="password" value="mypassword"/>
<!-- Redis URI Format: redis://host[:port]/database -->
<!-- Redis URI: Specify Database as Path -->
<property name="uri" value="redis://localhost/12"/>
<!-- Redis Sentinel URI Format: redis-sentinel://host[:port][,host[:port][,host[:port]]/database#masterId -->
<!-- Redis Sentinel URI: You can specify multiple sentinels. Specify Database as Path, Master Id as Fragment. -->
<property name="uri" value="redis-sentinel://localhost,localhost2,localhost3/1#myMaster"/>
</bean>
2.3.Redis Cluster Client
可以通过RedisClusterClient
使用Lettuce Redis群集支持。你可以提供bean定义来管理Spring上下文中的Lettuce资源。 Bean管理可以处理资源分配问题,并通过Spring的Bean生命周期管理进行清理。 使用托管Bean,你可以从代码内的各个位置访问Lettuce的RedisClusterClient
/connections。 你的代码也可以从依赖注入中受益。
2.3.1.Java配置
使用带有@Bean
定义的Spring Java配置来配置Lettuce,需要你提供bean定义。 请注意,一旦应用程序上下文关闭,destroyMethod
的规范即可清理资源。
@Configuration
public class LettuceConfig {
@Bean(destroyMethod = "shutdown")
ClientResources clientResources() {
return DefaultClientResources.create();
}
@Bean(destroyMethod = "shutdown")
RedisClusterClient redisClusterClient(ClientResources clientResources) {
RedisURI redisURI = RedisURI.create(TestSettings.host(), 7379);
return RedisClusterClient.create(clientResources, redisURI);
}
@Bean(destroyMethod = "close")
StatefulRedisClusterConnection<String, String> clusterConnection(RedisClusterClient clusterClient) {
return clusterClient.connect();
}
}
2.3.2.XML配置
使用RedisClusterClientFactoryBean
通过基于XML的配置来创建RedisClusterClient
的托管实例。
<bean id="redisClient" class="io.lettuce.core.support.RedisClusterClientFactoryBean">
<property name="password" value="mypassword"/>
<!-- Redis URI Format: redis://host[:port]/database -->
<!-- Redis URI: Specify Database as Path -->
<property name="uri" value="redis://localhost/12"/>
</bean>