com.alipay.sofa.registry.server.session.registry

类 SessionRegistry

java.lang.Object

com.alipay.sofa.registry.server.session.registry.SessionRegistry

所有已实现的接口:

Registry

public class SessionRegistry
extends Object
implements Registry

版本:

$Id: AbstractSessionRegistry.java, v 0.1 2017-11-30 18:13 shangyu.wh Exp $

作者:

shangyu.wh

构造器概要

构造器

构造器和说明
SessionRegistry()

方法概要

限定符和类型	方法和说明
void	cancel(List<String> connectIds) cancel publisher or subscriber data by client ip address and port(ip:port),one ip address has more than one processId when disconnection between client node and session node,disconnect event fire remove all pub and sub info on session and data node this function always use in Console manage Client node list,input ip list must transform to connectId through connect manage
void	cleanClientConnect() for scheduler clean no connect client
void	fetchChangData() Timing tasks to send all subscriber dataInfoId version to data, Select higher version data push to client node
void	fetchChangDataProcess() for fetchChangData first invoke
protected DataStore	getSessionDataStore() Getter method for property sessionDataStore.
protected Interests	getSessionInterests() Getter method for property sessionInterests.
protected TaskListenerManager	getTaskListenerManager() Getter method for property taskListenerManager.
void	register(StoreData storeData) register new publisher or subscriber data
void	remove(List<String> connectIds) remove publisher or subscriber data by client ip address and port(ip:port) this function always use in rest api Console manage ,the run mode is standard remove subscriber data will push empty datum to some one who has dataInfoId begin with pushEmptyDataDataIdPrefixes config
void	renewDatum(String connectId) Regularly send update Datum with same connectID valid time request service
void	sendDatumSnapshot(String connectId, String dataServerIP)
void	setEnableDataRenewSnapshot(boolean enableDataRenewSnapshot) Setter method for property enableDataRenewSnapshot .
void	unRegister(StoreData<String> storeData) message mode com.alipay.sofa.registry.client.provider for client node to unregister single subscriber or publisher data

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

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

构造器详细资料

SessionRegistry

public SessionRegistry()

方法详细资料

register

public void register(StoreData storeData)

从接口复制的说明: Registry

register new publisher or subscriber data

指定者:

register 在接口中 Registry

unRegister

public void unRegister(StoreData<String> storeData)

从接口复制的说明: Registry

message mode com.alipay.sofa.registry.client.provider for client node to unregister single subscriber or publisher data

指定者:

unRegister 在接口中 Registry

cancel

public void cancel(List<String> connectIds)

从接口复制的说明: Registry

cancel publisher or subscriber data by client ip address and port(ip:port),one ip address has more than one processId when disconnection between client node and session node,disconnect event fire remove all pub and sub info on session and data node this function always use in Console manage Client node list,input ip list must transform to connectId through connect manage

指定者:

cancel 在接口中 Registry

fetchChangData

public void fetchChangData()

从接口复制的说明: Registry

Timing tasks to send all subscriber dataInfoId version to data, Select higher version data push to client node

指定者:

fetchChangData 在接口中 Registry

fetchChangDataProcess

public void fetchChangDataProcess()

从接口复制的说明: Registry

for fetchChangData first invoke

指定者:

fetchChangDataProcess 在接口中 Registry

remove

public void remove(List<String> connectIds)

从接口复制的说明: Registry

remove publisher or subscriber data by client ip address and port(ip:port) this function always use in rest api Console manage ,the run mode is standard remove subscriber data will push empty datum to some one who has dataInfoId begin with pushEmptyDataDataIdPrefixes config

指定者:

remove 在接口中 Registry

cleanClientConnect

public void cleanClientConnect()

从接口复制的说明: Registry

for scheduler clean no connect client

指定者:

cleanClientConnect 在接口中 Registry

renewDatum

public void renewDatum(String connectId)

从接口复制的说明: Registry

Regularly send update Datum with same connectID valid time request service

指定者:

renewDatum 在接口中 Registry

sendDatumSnapshot

public void sendDatumSnapshot(String connectId,
                              String dataServerIP)

指定者:

sendDatumSnapshot 在接口中 Registry

getSessionInterests

protected Interests getSessionInterests()

Getter method for property sessionInterests.

返回:

property value of sessionInterests

getSessionDataStore

protected DataStore getSessionDataStore()

Getter method for property sessionDataStore.

返回:

property value of sessionDataStore

getTaskListenerManager

protected TaskListenerManager getTaskListenerManager()

Getter method for property taskListenerManager.

返回:

property value of taskListenerManager

setEnableDataRenewSnapshot

public void setEnableDataRenewSnapshot(boolean enableDataRenewSnapshot)

Setter method for property enableDataRenewSnapshot .

指定者:

setEnableDataRenewSnapshot 在接口中 Registry

参数:

enableDataRenewSnapshot - value to be assigned to property enableDataRenewSnapshot