net.ymate.platform.persistence.redis

Interface IRedis

All Superinterfaces:

AutoCloseable, IDestroyable, IInitialization<IApplication>, IPersistence<IRedisSession,IRedisConfig,IRedisCommandHolder>

All Known Implementing Classes:

Redis

@Ignored
public interface IRedis
extends IPersistence<IRedisSession,IRedisConfig,IRedisCommandHolder>

Redis管理器接口

Author:

刘镇 (suninformation@163.com) on 2019-05-22 02:26

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	IRedis.ConnectionType Redis连接方式

Field Summary

Fields

Modifier and Type	Field and Description
static String	MODULE_NAME

Method Summary

Modifier and Type	Method and Description
IRedisDataSourceAdapter	getDataSourceAdapter(String dataSourceName) 获取指定源数据源适配器
IRedisDataSourceAdapter	getDefaultDataSourceAdapter() 获取默认数据源适配器
<T> T	openSession(IDataSourceRouter dataSourceRouter, IRedisSessionExecutor<T> executor) 开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
<T> T	openSession(IRedisCommandHolder connectionHolder, IRedisSessionExecutor<T> executor) 开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
<T> T	openSession(IRedisSessionExecutor<T> executor) 开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
<T> T	openSession(String dataSourceName, IRedisSessionExecutor<T> executor) 开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)
void	subscribe(JedisPubSub jedisPubSub, String... channels) 订阅
void	subscribe(String dataSourceName, JedisPubSub jedisPubSub, String... channels) 订阅

Methods inherited from interface net.ymate.platform.core.persistence.IPersistence

getConfig, getConnectionHolder, getDefaultConnectionHolder, getOwner, openSession, openSession, openSession, openSession, releaseConnectionHolder

Methods inherited from interface net.ymate.platform.core.support.IInitialization

initialize, isInitialized

Methods inherited from interface java.lang.AutoCloseable

close

Field Detail

MODULE_NAME

static final String MODULE_NAME

See Also:

Constant Field Values

Method Detail

getDefaultDataSourceAdapter

IRedisDataSourceAdapter getDefaultDataSourceAdapter()
                                             throws Exception

获取默认数据源适配器

Returns:

返回数据源适配器对象

Throws:

Exception - 可能产生的任何异常

getDataSourceAdapter

IRedisDataSourceAdapter getDataSourceAdapter(String dataSourceName)
                                      throws Exception

获取指定源数据源适配器

Parameters:

dataSourceName - 数据源名称

Returns:

返回数据源适配器对象

Throws:

Exception - 可能产生的任何异常

openSession

<T> T openSession(IRedisSessionExecutor<T> executor)
           throws Exception

开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)

Type Parameters:

T - 执行结果对象类型

Parameters:

executor - 会话执行器

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openSession

<T> T openSession(String dataSourceName,
                  IRedisSessionExecutor<T> executor)
           throws Exception

开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)

Type Parameters:

T - 执行结果对象类型

Parameters:

dataSourceName - 数据源名称

executor - 会话执行器

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openSession

<T> T openSession(IRedisCommandHolder connectionHolder,
                  IRedisSessionExecutor<T> executor)
           throws Exception

开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)

Type Parameters:

T - 执行结果对象类型

Parameters:

connectionHolder - 数据源连接持有者对象

executor - 会话执行器

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

openSession

<T> T openSession(IDataSourceRouter dataSourceRouter,
                  IRedisSessionExecutor<T> executor)
           throws Exception

开启会话并执行会话执行器接口逻辑(执行完毕会话将自动关闭)

Type Parameters:

T - 执行结果对象类型

Parameters:

dataSourceRouter - 数据源路由对象

executor - 会话执行器

Returns:

返回执行结果

Throws:

Exception - 可能产生的任何异常

subscribe

void subscribe(JedisPubSub jedisPubSub,
               String... channels)

订阅

Parameters:

jedisPubSub - 发布订阅对象

channels - 频道

subscribe

void subscribe(String dataSourceName,
               JedisPubSub jedisPubSub,
               String... channels)

订阅

Parameters:

dataSourceName - 数据源名称

jedisPubSub - 发布订阅对象

channels - 频道