SessionInterests (registry-server-session 5.4.2 API)

java.lang.Object
- com.alipay.sofa.registry.server.session.store.SessionInterests

所有已实现的接口:

DataManager<Subscriber,String,String>, Interests, ReSubscribers
```
public class SessionInterests
extends Object
implements Interests, ReSubscribers
```
版本:

$Id: AbstractSessionInterests.java, v 0.1 2017-11-30 20:42 shangyu.wh Exp $

作者:

shangyu.wh

构造器概要

构造器
构造器和说明

SessionInterests()

构造器
构造器和说明
`SessionInterests()`

方法概要

所有方法实例方法具体方法
限定符和类型	方法和说明
`void`	`add(Subscriber subscriber)` new publisher and subscriber data add
`void`	`addReSubscriber(Subscriber subscriber)`
`boolean`	`checkAndUpdateInterestVersions(String dataCenter, String dataInfoId, Long version)` check subscribers interest dataInfoId version,very dataCenter dataInfoId version different if not exist add else check and update big version
`boolean`	`checkAndUpdateInterestVersionZero(String dataCenter, String dataInfoId)` set subscribers interest dataInfoId version zero
`boolean`	`checkInterestVersions(String dataCenter, String dataInfoId, Long version)` check subscribers interest dataInfoId version,very dataCenter dataInfoId version different if return false else check return bigger version
`void`	`clearReSubscribers()`
`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
`boolean`	`deleteReSubscriber(Subscriber subscriber)`
`Map<String,Map<String,Subscriber>>`	`getConnectSubscribers()` get all subscribers group by connectId
`List<String>`	`getDataCenters()`
`Collection<String>`	`getInterestDataInfoIds()` get all subscriber dataInfoIds
`Collection<Subscriber>`	`getInterests(String dataInfoId)` query subscribers by dataInfoID
`Map<String,Map<String,Subscriber>>`	`getReSubscribers()`
`SessionServerConfig`	`getSessionServerConfig()`
`Map<String,Subscriber>`	`queryByConnectId(String connectId)` query data by client node connectId
`Subscriber`	`queryById(String registerId, String dataInfoId)` get subscriber by dataInfoId and registerId
`Map<InetSocketAddress,Map<String,Subscriber>>`	`querySubscriberIndex(String dataInfoId, com.alipay.sofa.registry.core.model.ScopeEnum scope)` get subscribers whith specify dataInfo and scope,and group by source InetSocketAddress
`void`	`setSessionServerConfig(SessionServerConfig sessionServerConfig)` Setter method for property `sessionServerConfig`.

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 构造器详细资料
  - SessionInterests
```
public SessionInterests()
```
- 方法详细资料
  - add
```
public void add(Subscriber subscriber)
```
    从接口复制的说明: DataManager
    
    new publisher and subscriber data add
    
    指定者:
    
    add 在接口中 DataManager<Subscriber,String,String>
  - deleteById
```
public boolean deleteById(String registerId,
                          String dataInfoId)
```
    从接口复制的说明: DataManager
    
    remove single data by register id
    
    指定者:
    
    deleteById 在接口中 DataManager<Subscriber,String,String>
    
    返回:
  - deleteByConnectId
```
public boolean deleteByConnectId(String connectId)
```
    从接口复制的说明: DataManager
    
    remove data by client node connectId
    
    指定者:
    
    deleteByConnectId 在接口中 DataManager<Subscriber,String,String>
  - count
```
public long count()
```
    从接口复制的说明: DataManager
    
    count pub and sub number
    
    指定者:
    
    count 在接口中 DataManager<Subscriber,String,String>
    
    返回:
  - queryByConnectId
```
public Map<String,Subscriber> queryByConnectId(String connectId)
```
    从接口复制的说明: DataManager
    
    query data by client node connectId
    
    指定者:
    
    queryByConnectId 在接口中 DataManager<Subscriber,String,String>
    
    返回:
  - queryById
```
public Subscriber queryById(String registerId,
                            String dataInfoId)
```
    从接口复制的说明: Interests
    
    get subscriber by dataInfoId and registerId
    
    指定者:
    
    queryById 在接口中 Interests
    
    返回:
  - getInterests
```
public Collection<Subscriber> getInterests(String dataInfoId)
```
    从接口复制的说明: Interests
    
    query subscribers by dataInfoID
    
    指定者:
    
    getInterests 在接口中 Interests
    
    返回:
  - checkInterestVersions
```
public boolean checkInterestVersions(String dataCenter,
                                     String dataInfoId,
                                     Long version)
```
    从接口复制的说明: Interests
    
    check subscribers interest dataInfoId version,very dataCenter dataInfoId version different if return false else check return bigger version
    
    指定者:
    
    checkInterestVersions 在接口中 Interests
    
    返回:
  - checkAndUpdateInterestVersions
```
public boolean checkAndUpdateInterestVersions(String dataCenter,
                                              String dataInfoId,
                                              Long version)
```
    从接口复制的说明: Interests
    
    check subscribers interest dataInfoId version,very dataCenter dataInfoId version different if not exist add else check and update big version
    
    指定者:
    
    checkAndUpdateInterestVersions 在接口中 Interests
    
    返回:
  - checkAndUpdateInterestVersionZero
```
public boolean checkAndUpdateInterestVersionZero(String dataCenter,
                                                 String dataInfoId)
```
    从接口复制的说明: Interests
    
    set subscribers interest dataInfoId version zero
    
    指定者:
    
    checkAndUpdateInterestVersionZero 在接口中 Interests
    
    返回:
  - getInterestDataInfoIds
```
public Collection<String> getInterestDataInfoIds()
```
    从接口复制的说明: Interests
    
    get all subscriber dataInfoIds
    
    指定者:
    
    getInterestDataInfoIds 在接口中 Interests
    
    返回:
  - querySubscriberIndex
```
public Map<InetSocketAddress,Map<String,Subscriber>> querySubscriberIndex(String dataInfoId,
                                                                          com.alipay.sofa.registry.core.model.ScopeEnum scope)
```
    从接口复制的说明: Interests
    
    get subscribers whith specify dataInfo and scope,and group by source InetSocketAddress
    
    指定者:
    
    querySubscriberIndex 在接口中 Interests
    
    返回:
  - addReSubscriber
```
public void addReSubscriber(Subscriber subscriber)
```
    指定者:
    
    addReSubscriber 在接口中 ReSubscribers
  - deleteReSubscriber
```
public boolean deleteReSubscriber(Subscriber subscriber)
```
    指定者:
    
    deleteReSubscriber 在接口中 ReSubscribers
  - getReSubscribers
```
public Map<String,Map<String,Subscriber>> getReSubscribers()
```
    指定者:
    
    getReSubscribers 在接口中 ReSubscribers
  - clearReSubscribers
```
public void clearReSubscribers()
```
    指定者:
    
    clearReSubscribers 在接口中 ReSubscribers
  - getConnectSubscribers
```
public Map<String,Map<String,Subscriber>> getConnectSubscribers()
```
    从接口复制的说明: Interests
    
    get all subscribers group by connectId
    
    指定者:
    
    getConnectSubscribers 在接口中 Interests
    
    返回:
  - getSessionServerConfig
```
public SessionServerConfig getSessionServerConfig()
```
  - setSessionServerConfig
```
public void setSessionServerConfig(SessionServerConfig sessionServerConfig)
```
    Setter method for property sessionServerConfig.
    
    参数:
    
    sessionServerConfig - value to be assigned to property sessionServerConfig
  - getDataCenters
```
public List<String> getDataCenters()
```
    指定者:
    
    getDataCenters 在接口中 Interests

类 SessionInterests

构造器概要

方法概要

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

构造器详细资料

SessionInterests

方法详细资料

add

deleteById

deleteByConnectId

count

queryByConnectId

queryById

getInterests

checkInterestVersions

checkAndUpdateInterestVersions

checkAndUpdateInterestVersionZero

getInterestDataInfoIds

querySubscriberIndex

addReSubscriber

deleteReSubscriber

getReSubscribers

clearReSubscribers

getConnectSubscribers

getSessionServerConfig

setSessionServerConfig

getDataCenters