com.seeyon.ctp.organization.cache

类 OrgRedisOpt

java.lang.Object

com.seeyon.ctp.organization.cache.OrgRedisOpt

直接已知子类:

OrgRedisOptCluster, OrgRedisOptSingle

public abstract class OrgRedisOpt
extends java.lang.Object

组织机构redis环境操作接口

从以下版本开始:

V5 V8.1

嵌套类概要

嵌套类

限定符和类型	类和说明
static interface	OrgRedisOpt.ChannelListener

字段概要

字段

限定符和类型	字段和说明
protected static java.lang.String	CHANNEL_NAME
protected static long	MAX_STORE_TIME

构造器概要

构造器

构造器和说明
OrgRedisOpt()

方法概要

限定符和类型	方法和说明
protected abstract void	checkAndReconnect() 检查重连机制，防止网络波动导致redis连接失败
abstract java.lang.String	eval(java.lang.String script, java.lang.String key, java.util.List<java.lang.String> args) 执行lua脚本
abstract java.lang.String	get(java.lang.String key) 获取redis数据
abstract java.lang.Long	getCanalMaxVersion(java.lang.String cacheName) 获取管道数据的最大版本号,如果不存在，返回-1
static OrgRedisOpt	getInstance()
java.lang.Long	incrementGetOrDefault(java.lang.String key, int incrby, long defaultValue) 如果
java.lang.Long	incrementGetOrDefault(java.lang.String key, long defaultValue) 如果 @{key} 存在则+1并返回，否者返回默认值
static boolean	isRedisEnabled() 判断redis是否可用
abstract void	pubChannel(java.lang.String data) 发布数据到管道
abstract java.util.List<Pair<java.lang.Long,java.lang.String>>	pullFromCanal(java.lang.String canalName, java.lang.Long localVersion) 从管道拉取数据
abstract java.lang.Long	pushToCanal(java.lang.String canalName, java.lang.String content) 推送数据到管道
protected void	reInitScript() 重新初始化脚本[单机版本lua出现错误场景]
abstract void	remove(java.lang.String key)
abstract void	setIfAbsent(java.lang.String key, java.lang.Object value, java.lang.Integer cacheInvalidTime) 设置如果存在
abstract void	subChannel(OrgRedisOpt.ChannelListener listener) 订阅管道

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

CHANNEL_NAME

protected static final java.lang.String CHANNEL_NAME

另请参阅:

常量字段值

MAX_STORE_TIME

protected static long MAX_STORE_TIME

构造器详细资料

OrgRedisOpt

public OrgRedisOpt()

方法详细资料

getInstance

public static OrgRedisOpt getInstance()

isRedisEnabled

public static boolean isRedisEnabled()

判断redis是否可用

从以下版本开始:

V5 V8.1

checkAndReconnect

protected abstract void checkAndReconnect()

检查重连机制，防止网络波动导致redis连接失败

从以下版本开始:

V5 V8.1

reInitScript

protected void reInitScript()

重新初始化脚本[单机版本lua出现错误场景]

从以下版本开始:

V5 V8.2

eval

public abstract java.lang.String eval(java.lang.String script,
                                      java.lang.String key,
                                      java.util.List<java.lang.String> args)

执行lua脚本

参数:

script - 脚本

key - key

args - 参数

返回:

从以下版本开始:

V5 V8.1

get

public abstract java.lang.String get(java.lang.String key)

获取redis数据

参数:

key -

返回:

从以下版本开始:

V5 V8.1

pushToCanal

public abstract java.lang.Long pushToCanal(java.lang.String canalName,
                                           java.lang.String content)

推送数据到管道

参数:

canalName - 管道名称

content - 内容

返回:

从以下版本开始:

V5 V8.1

pullFromCanal

public abstract java.util.List<Pair<java.lang.Long,java.lang.String>> pullFromCanal(java.lang.String canalName,
                                                                                    java.lang.Long localVersion)

从管道拉取数据

参数:

canalName - 管道名称

localVersion - 本地版本号

返回:

getCanalMaxVersion

public abstract java.lang.Long getCanalMaxVersion(java.lang.String cacheName)

获取管道数据的最大版本号,如果不存在，返回-1

参数:

cacheName - 管道名称

返回:

从以下版本开始:

V5 V8.1

incrementGetOrDefault

public java.lang.Long incrementGetOrDefault(java.lang.String key,
                                            long defaultValue)

如果 @{key} 存在则+1并返回，否者返回默认值

参数:

key - redis的key

defaultValue - 默认值

返回:

incrementGetOrDefault

public java.lang.Long incrementGetOrDefault(java.lang.String key,
                                            int incrby,
                                            long defaultValue)

如果

参数:

key - redis的key

incrby - 增量

defaultValue - 默认值

返回:

setIfAbsent

public abstract void setIfAbsent(java.lang.String key,
                                 java.lang.Object value,
                                 java.lang.Integer cacheInvalidTime)

设置如果存在

参数:

key - redis的key

value - 值

cacheInvalidTime - 过期时间【单位s】，可以为空

remove

public abstract void remove(java.lang.String key)

pubChannel

public abstract void pubChannel(java.lang.String data)

发布数据到管道

参数:

data - 数据

从以下版本开始:

V5 V8.2

subChannel

public abstract void subChannel(OrgRedisOpt.ChannelListener listener)

订阅管道

从以下版本开始:

V5 V8.2