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

类 SessionDataStore

java.lang.Object

com.alipay.sofa.registry.server.session.store.SessionDataStore

所有已实现的接口:

DataManager<Publisher,String,String>, DataStore

public class SessionDataStore
extends Object
implements DataStore

版本:

$Id: SessionDataStore.java, v 0.1 2017-12-01 18:14 shangyu.wh Exp $

作者:

shangyu.wh

构造器概要

构造器

构造器和说明
SessionDataStore()

方法概要

限定符和类型	方法和说明
void	add(Publisher publisher) new publisher and subscriber data add
long	count() count pub and sub number
boolean	deleteByConnectId(String connectId) remove data by client node connectId
boolean	deleteById(String registerId, String dataInfoId) remove single data by register id
Map<String,Map<String,Publisher>>	getConnectPublishers() get all publishers group by connectId
Collection<Publisher>	getStoreDataByDataInfoId(String dataInfoId) get all publishers by dataInfoId
Collection<String>	getStoreDataInfoIds() get all publisher dataInfoIds
Map<String,Publisher>	queryByConnectId(String connectId) query data by client node connectId
Publisher	queryById(String registerId, String dataInfoId) get Publiser by registerId and dataInfoId

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

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

构造器详细资料

SessionDataStore

public SessionDataStore()

方法详细资料

add

public void add(Publisher publisher)

从接口复制的说明: DataManager

new publisher and subscriber data add

指定者:

add 在接口中 DataManager<Publisher,String,String>

deleteById

public boolean deleteById(String registerId,
                          String dataInfoId)

从接口复制的说明: DataManager

remove single data by register id

指定者:

deleteById 在接口中 DataManager<Publisher,String,String>

返回:

queryByConnectId

public Map<String,Publisher> queryByConnectId(String connectId)

从接口复制的说明: DataManager

query data by client node connectId

指定者:

queryByConnectId 在接口中 DataManager<Publisher,String,String>

返回:

deleteByConnectId

public boolean deleteByConnectId(String connectId)

从接口复制的说明: DataManager

remove data by client node connectId

指定者:

deleteByConnectId 在接口中 DataManager<Publisher,String,String>

getStoreDataByDataInfoId

public Collection<Publisher> getStoreDataByDataInfoId(String dataInfoId)

从接口复制的说明: DataStore

get all publishers by dataInfoId

指定者:

getStoreDataByDataInfoId 在接口中 DataStore

返回:

queryById

public Publisher queryById(String registerId,
                           String dataInfoId)

从接口复制的说明: DataStore

get Publiser by registerId and dataInfoId

指定者:

queryById 在接口中 DataStore

返回:

getStoreDataInfoIds

public Collection<String> getStoreDataInfoIds()

从接口复制的说明: DataStore

get all publisher dataInfoIds

指定者:

getStoreDataInfoIds 在接口中 DataStore

返回:

count

public long count()

从接口复制的说明: DataManager

count pub and sub number

指定者:

count 在接口中 DataManager<Publisher,String,String>

返回:

getConnectPublishers

public Map<String,Map<String,Publisher>> getConnectPublishers()

从接口复制的说明: DataStore

get all publishers group by connectId

指定者:

getConnectPublishers 在接口中 DataStore

返回: