com.seeyon.ctp.organization.cache

类 OrgRedisOptSingle

java.lang.Object

com.seeyon.ctp.organization.cache.OrgRedisOpt

com.seeyon.ctp.organization.cache.OrgRedisOptSingle

public class OrgRedisOptSingle
extends OrgRedisOpt

从以下版本开始:

V5 V8.0SP2

嵌套类概要

从类继承的嵌套类/接口 com.seeyon.ctp.organization.cache.OrgRedisOpt

OrgRedisOpt.ChannelListener

字段概要

字段

限定符和类型	字段和说明
protected static java.lang.String	DATA_KEY 内容对应分组
protected static java.lang.String	VERSION_KEY 版本号对应的key

从类继承的字段 com.seeyon.ctp.organization.cache.OrgRedisOpt

CHANNEL_NAME, MAX_STORE_TIME

构造器概要

构造器

构造器和说明
OrgRedisOptSingle()
OrgRedisOptSingle(redis.clients.jedis.JedisPool jedisPool)

方法概要

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

从类继承的方法 com.seeyon.ctp.organization.cache.OrgRedisOpt

getInstance, incrementGetOrDefault, incrementGetOrDefault, isRedisEnabled

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

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

字段详细资料

VERSION_KEY

protected static final java.lang.String VERSION_KEY

版本号对应的key

另请参阅:

常量字段值

DATA_KEY

protected static final java.lang.String DATA_KEY

内容对应分组

另请参阅:

常量字段值

构造器详细资料

OrgRedisOptSingle

public OrgRedisOptSingle()

OrgRedisOptSingle

public OrgRedisOptSingle(redis.clients.jedis.JedisPool jedisPool)

方法详细资料

checkAndReconnect

protected void checkAndReconnect()

从类复制的说明: OrgRedisOpt

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

指定者:

checkAndReconnect 在类中 OrgRedisOpt

reInitScript

protected void reInitScript()

从类复制的说明: OrgRedisOpt

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

覆盖:

reInitScript 在类中 OrgRedisOpt

pushToCanal

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

从类复制的说明: OrgRedisOpt

推送数据到管道

指定者:

pushToCanal 在类中 OrgRedisOpt

参数:

canalName - 管道名称

content - 内容

返回:

pullFromCanal

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

从类复制的说明: OrgRedisOpt

从管道拉取数据

指定者:

pullFromCanal 在类中 OrgRedisOpt

参数:

canalName - 管道名称

localVersion - 本地版本号

返回:

eval

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

从类复制的说明: OrgRedisOpt

执行lua脚本

指定者:

eval 在类中 OrgRedisOpt

参数:

script - 脚本

key - key

args - 参数

返回:

get

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

从类复制的说明: OrgRedisOpt

获取redis数据

指定者:

get 在类中 OrgRedisOpt

返回:

getCanalMaxVersion

public java.lang.Long getCanalMaxVersion(java.lang.String canalName)

从类复制的说明: OrgRedisOpt

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

指定者:

getCanalMaxVersion 在类中 OrgRedisOpt

参数:

canalName - 管道名称

返回:

setIfAbsent

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

从类复制的说明: OrgRedisOpt

设置如果存在

指定者:

setIfAbsent 在类中 OrgRedisOpt

参数:

key - redis的key

value - 值

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

remove

public void remove(java.lang.String key)

指定者:

remove 在类中 OrgRedisOpt

pubChannel

public void pubChannel(java.lang.String data)

从类复制的说明: OrgRedisOpt

发布数据到管道

指定者:

pubChannel 在类中 OrgRedisOpt

参数:

data - 数据

subChannel

public void subChannel(OrgRedisOpt.ChannelListener listener)

从类复制的说明: OrgRedisOpt

订阅管道

指定者:

subChannel 在类中 OrgRedisOpt