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

接口 Registry

所有已知实现类:

SessionRegistry

public interface Registry

版本:

$Id: SessionRegistry.java, v 0.1 2017-11-27 19:49 shangyu.wh Exp $

作者:

shangyu.wh

方法概要

限定符和类型	方法和说明
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
void	register(StoreData<String> data) 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)
void	unRegister(StoreData<String> data) message mode com.alipay.sofa.registry.client.provider for client node to unregister single subscriber or publisher data

方法详细资料

register

void register(StoreData<String> data)

register new publisher or subscriber data

参数:

data -

cancel

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

参数:

connectIds -

remove

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

参数:

connectIds -

unRegister

void unRegister(StoreData<String> data)

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

参数:

data -

fetchChangData

void fetchChangData()

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

fetchChangDataProcess

void fetchChangDataProcess()

for fetchChangData first invoke

renewDatum

void renewDatum(String connectId)

Regularly send update Datum with same connectID valid time request service

sendDatumSnapshot

void sendDatumSnapshot(String connectId,
                       String dataServerIp)

cleanClientConnect

void cleanClientConnect()

for scheduler clean no connect client

setEnableDataRenewSnapshot

void setEnableDataRenewSnapshot(boolean enableDataRenewSnapshot)