cn.weforward.data.persister.remote

类 RemoteInvokerPersister<E extends AbstractRemotePersistent<?,V>,V>

java.lang.Object

cn.weforward.data.persister.support.AbstractPersister<E>

cn.weforward.data.persister.remote.AbstractRemotePersister<E,V>

cn.weforward.data.persister.remote.RemoteInvokerPersister<E,V>

类型参数:

E - 业务对象

V - 值对象

所有已实现的接口:

cn.weforward.common.Nameable, Persister<E>

public class RemoteInvokerPersister<E extends AbstractRemotePersistent<?,V>,V>
extends AbstractRemotePersister<E,V>

通过服务支撑的远程的持久化对象

作者:

daibo

嵌套类概要

从类继承的嵌套类/接口 cn.weforward.data.persister.support.AbstractPersister

AbstractPersister.Cache

字段概要

字段

限定符和类型	字段和说明
protected RemoteInvokerPersisterFactory	m_Factory 工厂
protected cn.weforward.protocol.ext.ObjectMapper<E>	m_Mapper 对象映射
protected cn.weforward.protocol.ext.ObjectMapper<V>	m_VoMapper 对象映射

从类继承的字段 cn.weforward.data.persister.remote.AbstractRemotePersister

m_Expiry, m_Offline, m_RefreshTimeout, m_ShareDelayLoader

从类继承的字段 cn.weforward.data.persister.support.AbstractPersister

_Logger, m_Cache, m_Flusher, m_ForOwnerEnabled, m_IdGenerator, m_Listeners, m_Name, m_ReloadEnabled, m_VerifyNewIdTrys

构造器概要

构造器

限定符	构造器和说明
protected	RemoteInvokerPersister(RemoteInvokerPersisterFactory factory, cn.weforward.protocol.ext.ObjectMapper<E> mapper, cn.weforward.protocol.ext.ObjectMapper<V> voMapper)

方法概要

限定符和类型	方法和说明
void	addListener(ChangeListener<E> l) 添加监听
static void	checkGateWayException(cn.weforward.protocol.Response response) 检查网关异常
static void	checkMicroserviceException(cn.weforward.protocol.support.datatype.FriendlyObject serviceResult) 检查微服务异常
protected E	create(String id, ObjectWithVersion<V> vo) 创建对象
protected String	genMethod(String method)
protected cn.weforward.protocol.client.ServiceInvoker	getInvoker()
protected boolean	remoteDelete(String id) 从远端删除对象
protected ObjectWithVersion<V>	remoteLoad(String id, String version) 从远程装入对象
protected String	remoteNew(String id, V object) 新增的对象（用于持久器在对象未刷写前能进行查询）到远端
protected String	remoteSave(String id, V object) 保存对象状态到远端
void	removeListener(ChangeListener<E> l) 移除监听
cn.weforward.common.ResultPage<String>	searchOfId(Condition condition, OrderBy orderBy) 条件查询
cn.weforward.common.ResultPage<String>	searchOfId(Date begin, Date end) 查找在指定时间段内变化（持久化）过的对象 (begin,end]
Iterator<String>	searchOfId(String serverId, Date begin, Date end) 查找在指定时间段内变化（持久化）过的对象
cn.weforward.common.ResultPage<String>	searchRangeOfId(String from, String to) 查找ID在指定区间内的对象，id>=from and id<=to
Iterator<String>	searchRangeOfId(String serverId, String from, String to) 查找ID在指定区间内的对象，id>=from and id<=to
cn.weforward.common.ResultPage<String>	startsWithOfId(String prefix) 查找ID为指定前缀的对象

从类继承的方法 cn.weforward.data.persister.remote.AbstractRemotePersister

getExpiry, innerDelete, innerLoad, innerNew, innerSave, isShareDelayLoader, remoteLoad, remoteNew, remoteSave, setExpiry, setRefreshTimeout, setShareDelayLoader, updateOffline

从类继承的方法 cn.weforward.data.persister.support.AbstractPersister

cleanup, equals, flush, get, get, getCache, getFlusher, getIdGenerator, getName, getNewId, getNewId, getOfCache, getPersisterId, getVerifyNewIdTrys, getVersion, hold, innerSave, isDirty, isForOwnerEnabled, isOwner, isReloadEnabled, persist, persist, putOfCache, remove, remove, removeOfCache, search, search, search, search, searchOfId, searchRange, searchRange, setFlusher, setForOwnerEnabled, setPersisterId, setReachable, setReloadEnabled, setVerifyNewIdTrys, startsWith, toString, update

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

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

字段详细资料

m_Factory

protected RemoteInvokerPersisterFactory m_Factory

工厂

m_Mapper

protected cn.weforward.protocol.ext.ObjectMapper<E extends AbstractRemotePersistent<?,V>> m_Mapper

对象映射

m_VoMapper

protected cn.weforward.protocol.ext.ObjectMapper<V> m_VoMapper

对象映射

构造器详细资料

RemoteInvokerPersister

protected RemoteInvokerPersister(RemoteInvokerPersisterFactory factory,
                                 cn.weforward.protocol.ext.ObjectMapper<E> mapper,
                                 cn.weforward.protocol.ext.ObjectMapper<V> voMapper)

方法详细资料

genMethod

protected String genMethod(String method)

getInvoker

protected cn.weforward.protocol.client.ServiceInvoker getInvoker()

startsWithOfId

public cn.weforward.common.ResultPage<String> startsWithOfId(String prefix)

从接口复制的说明: Persister

查找ID为指定前缀的对象

参数:

prefix - ID前缀

返回:

对象结果页

searchOfId

public cn.weforward.common.ResultPage<String> searchOfId(Date begin,
                                                         Date end)

从接口复制的说明: Persister

查找在指定时间段内变化（持久化）过的对象 (begin,end]

参数:

begin - 开始时间，若=null则不限制开始时间

end - 结束时间，若=null则为当前时间

返回:

对象ID形式的结果页

searchRangeOfId

public cn.weforward.common.ResultPage<String> searchRangeOfId(String from,
                                                              String to)

从接口复制的说明: Persister

查找ID在指定区间内的对象，id>=from and id<=to

参数:

from - ID开始点，若为null则不限制开始（但to不能为null）

to - ID结束点，若为null则不限制结束（但from不能为null）

返回:

对象ID形式的结果页

searchOfId

public Iterator<String> searchOfId(String serverId,
                                   Date begin,
                                   Date end)

从接口复制的说明: Persister

查找在指定时间段内变化（持久化）过的对象

参数:

serverId - 服务器标识（1~255）

begin - 开始时间，若=null则不限制开始时间

end - 结束时间，若=null则为当前时间

返回:

结果集迭代器

searchRangeOfId

public Iterator<String> searchRangeOfId(String serverId,
                                        String from,
                                        String to)

从接口复制的说明: Persister

查找ID在指定区间内的对象，id>=from and id<=to

参数:

serverId - 服务器标识

from - ID开始点，若为null则不限制开始（但to不能为null）

to - ID结束点，若为null则不限制结束（但from不能为null）

返回:

结果集迭代器

create

protected E create(String id,
                   ObjectWithVersion<V> vo)

从类复制的说明: AbstractRemotePersister

创建对象

指定者:

create 在类中 AbstractRemotePersister<E extends AbstractRemotePersistent<?,V>,V>

参数:

id - 对象id

vo - 对象VO

返回:

对象

checkGateWayException

public static void checkGateWayException(cn.weforward.protocol.Response response)
                                  throws DataAccessException

检查网关异常

参数:

response - 响应

抛出:

DataAccessException - 数据异常

checkMicroserviceException

public static void checkMicroserviceException(cn.weforward.protocol.support.datatype.FriendlyObject serviceResult)
                                       throws DataAccessException

检查微服务异常

参数:

serviceResult - 结果

抛出:

DataAccessException - 据异常

remoteNew

protected String remoteNew(String id,
                           V object)

从类复制的说明: AbstractRemotePersister

新增的对象（用于持久器在对象未刷写前能进行查询）到远端

指定者:

remoteNew 在类中 AbstractRemotePersister<E extends AbstractRemotePersistent<?,V>,V>

参数:

id - 对象id

object - 对象值vo

返回:

对象保存后版本号

remoteLoad

protected ObjectWithVersion<V> remoteLoad(String id,
                                          String version)

从类复制的说明: AbstractRemotePersister

从远程装入对象

指定者:

remoteLoad 在类中 AbstractRemotePersister<E extends AbstractRemotePersistent<?,V>,V>

参数:

id - 对象ID

version - 当前对象的版本号,为null则表示未知,如果不为null且与远端版本一样可返回无修改提高性能

返回:

所加载的对象项及其版本号，没有则返回null

remoteSave

protected String remoteSave(String id,
                            V object)

从类复制的说明: AbstractRemotePersister

保存对象状态到远端

指定者:

remoteSave 在类中 AbstractRemotePersister<E extends AbstractRemotePersistent<?,V>,V>

参数:

id - 对象id

object - 对象值vo

返回:

对象保存后版本号

remoteDelete

protected boolean remoteDelete(String id)

从类复制的说明: AbstractRemotePersister

从远端删除对象

指定者:

remoteDelete 在类中 AbstractRemotePersister<E extends AbstractRemotePersistent<?,V>,V>

参数:

id - 对象ID

返回:

成功/失败

addListener

public void addListener(ChangeListener<E> l)

从接口复制的说明: Persister

添加监听

指定者:

addListener 在接口中 Persister<E extends AbstractRemotePersistent<?,V>>

覆盖:

addListener 在类中 AbstractPersister<E extends AbstractRemotePersistent<?,V>>

参数:

l - 监听对象

removeListener

public void removeListener(ChangeListener<E> l)

从接口复制的说明: Persister

移除监听

指定者:

removeListener 在接口中 Persister<E extends AbstractRemotePersistent<?,V>>

覆盖:

removeListener 在类中 AbstractPersister<E extends AbstractRemotePersistent<?,V>>

参数:

l - 监听对象

searchOfId

public cn.weforward.common.ResultPage<String> searchOfId(Condition condition,
                                                         OrderBy orderBy)

从接口复制的说明: Persister

条件查询

参数:

condition - 条件 ConditionUtil

orderBy - 排序 OrderByUtil

返回:

对象结果页