public final class Redis extends Object implements IModule, IRedis
IRedis.ConnectionType
MODULE_NAME
Constructor and Description |
---|
Redis() |
Redis(IRedisConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
static IRedis |
get() |
IRedisConfig |
getConfig()
获取持久化配置对象
|
IRedisCommandHolder |
getConnectionHolder(String dataSourceName)
获取由dataSourceName指定的数据源连接持有者对象
|
IRedisDataSourceAdapter |
getDataSourceAdapter(String dataSourceName)
获取指定源数据源适配器
|
IRedisCommandHolder |
getDefaultConnectionHolder()
获取默认数据源连接持有者对象
|
IRedisDataSourceAdapter |
getDefaultDataSourceAdapter()
获取默认数据源适配器
|
String |
getName()
获取模块名称
|
IApplication |
getOwner()
获取所属应用容器
|
void |
initialize(IApplication owner)
初始化
|
boolean |
isInitialized()
是否已初始化
|
IRedisSession |
openSession()
开启数据库连接会话(注意一定记得关闭会话)
|
IRedisSession |
openSession(IDataSourceRouter dataSourceRouter)
开启数据库连接会话(注意一定记得关闭会话)
|
<T> T |
openSession(IDataSourceRouter dataSourceRouter,
IRedisSessionExecutor<T> executor)
开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
|
IRedisSession |
openSession(IRedisCommandHolder commandsHolder)
开启数据库连接会话(注意一定记得关闭会话)
|
<T> T |
openSession(IRedisCommandHolder commandsHolder,
IRedisSessionExecutor<T> executor)
开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
|
<T> T |
openSession(IRedisSessionExecutor<T> executor)
开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
|
IRedisSession |
openSession(String dsName)
开启数据库连接会话(注意一定记得关闭会话)
|
<T> T |
openSession(String dsName,
IRedisSessionExecutor<T> executor)
开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
|
void |
releaseConnectionHolder(IRedisCommandHolder connectionHolder)
安全关闭数据源的连接持有者(确保非事务状态下执行关闭)
|
void |
subscribe(JedisPubSub jedisPubSub,
String... channels)
订阅
|
void |
subscribe(String dsName,
JedisPubSub jedisPubSub,
String... channels)
订阅
|
public Redis()
public Redis(IRedisConfig config)
public static IRedis get()
public void initialize(IApplication owner) throws Exception
IInitialization
initialize
in interface IInitialization<IApplication>
owner
- 指定所属容器参数对象Exception
- 初始过程中产生的任何异常public boolean isInitialized()
IInitialization
isInitialized
in interface IInitialization<IApplication>
public IApplication getOwner()
IPersistence
getOwner
in interface IPersistence<IRedisSession,IRedisConfig,IRedisCommandHolder>
public IRedisConfig getConfig()
IPersistence
getConfig
in interface IPersistence<IRedisSession,IRedisConfig,IRedisCommandHolder>
public IRedisCommandHolder getDefaultConnectionHolder()
IPersistence
getDefaultConnectionHolder
in interface IPersistence<IRedisSession,IRedisConfig,IRedisCommandHolder>
public IRedisCommandHolder getConnectionHolder(String dataSourceName)
IPersistence
getConnectionHolder
in interface IPersistence<IRedisSession,IRedisConfig,IRedisCommandHolder>
dataSourceName
- 数据源名称public void releaseConnectionHolder(IRedisCommandHolder connectionHolder) throws Exception
IPersistence
releaseConnectionHolder
in interface IPersistence<IRedisSession,IRedisConfig,IRedisCommandHolder>
connectionHolder
- 数据源的连接持有者对象Exception
- 可能产生的异常public IRedisDataSourceAdapter getDefaultDataSourceAdapter()
IRedis
getDefaultDataSourceAdapter
in interface IRedis
public IRedisDataSourceAdapter getDataSourceAdapter(String dataSourceName)
IRedis
getDataSourceAdapter
in interface IRedis
dataSourceName
- 数据源名称public <T> T openSession(IRedisSessionExecutor<T> executor) throws Exception
IRedis
openSession
in interface IRedis
T
- 执行结果对象类型executor
- 会话执行器Exception
- 可能产生的任何异常public <T> T openSession(String dsName, IRedisSessionExecutor<T> executor) throws Exception
IRedis
openSession
in interface IRedis
T
- 执行结果对象类型dsName
- 数据源名称executor
- 会话执行器Exception
- 可能产生的任何异常public <T> T openSession(IRedisCommandHolder commandsHolder, IRedisSessionExecutor<T> executor) throws Exception
IRedis
openSession
in interface IRedis
T
- 执行结果对象类型commandsHolder
- 数据源连接持有者对象executor
- 会话执行器Exception
- 可能产生的任何异常public <T> T openSession(IDataSourceRouter dataSourceRouter, IRedisSessionExecutor<T> executor) throws Exception
IRedis
openSession
in interface IRedis
T
- 执行结果对象类型dataSourceRouter
- 数据源路由对象executor
- 会话执行器Exception
- 可能产生的任何异常public IRedisSession openSession()
IPersistence
openSession
in interface IPersistence<IRedisSession,IRedisConfig,IRedisCommandHolder>
public IRedisSession openSession(String dsName)
IPersistence
openSession
in interface IPersistence<IRedisSession,IRedisConfig,IRedisCommandHolder>
dsName
- 数据源名称public IRedisSession openSession(IRedisCommandHolder commandsHolder)
IPersistence
openSession
in interface IPersistence<IRedisSession,IRedisConfig,IRedisCommandHolder>
commandsHolder
- 数据源连接持有者对象public IRedisSession openSession(IDataSourceRouter dataSourceRouter)
IPersistence
openSession
in interface IPersistence<IRedisSession,IRedisConfig,IRedisCommandHolder>
dataSourceRouter
- 数据源路由对象public void subscribe(JedisPubSub jedisPubSub, String... channels)
IRedis
public void subscribe(String dsName, JedisPubSub jedisPubSub, String... channels)
IRedis
public void close()
close
in interface AutoCloseable
Copyright © 2022. All rights reserved.