com.seeyon.ctp.organization.cache

类 OrgRedisOptCluster

java.lang.Object

com.seeyon.ctp.organization.cache.OrgRedisOpt

com.seeyon.ctp.organization.cache.OrgRedisOptCluster

public class OrgRedisOptCluster
extends OrgRedisOpt

从以下版本开始:

V5 V8.1

嵌套类概要

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

OrgRedisOpt.ChannelListener

字段概要

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

CHANNEL_NAME, MAX_STORE_TIME

构造器概要

构造器

构造器和说明
OrgRedisOptCluster()
OrgRedisOptCluster(redis.clients.jedis.JedisCluster jedisCluster)

方法概要

限定符和类型	方法和说明
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) 推送数据到管道
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, reInitScript

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

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

构造器详细资料

OrgRedisOptCluster

public OrgRedisOptCluster()

OrgRedisOptCluster

public OrgRedisOptCluster(redis.clients.jedis.JedisCluster jedisCluster)

方法详细资料

checkAndReconnect

protected void checkAndReconnect()

从类复制的说明: OrgRedisOpt

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

指定者:

checkAndReconnect 在类中 OrgRedisOpt

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

返回:

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 - 本地版本号

返回:

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