SessionRegistry (registry-server-session 6.3.0 API)

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

嵌套类概要

嵌套类
限定符和类型类和说明

static class SessionRegistry.SelectSubscriber

嵌套类
限定符和类型	类和说明
`static class`	`SessionRegistry.SelectSubscriber`

字段概要

字段
限定符和类型	字段和说明
`protected Exchange`	`boltExchange`
`protected ConfigProvideDataWatcher`	`configProvideDataWatcher`
`protected FirePushService`	`firePushService`
`protected static Logger`	`LOGGER`
`protected PushSwitchService`	`pushSwitchService`
`protected static Logger`	`SCAN_VER_LOGGER`
`protected DataStore`	`sessionDataStore` store publishers
`protected Interests`	`sessionInterests` store subscribers
`protected SessionRegistryStrategy`	`sessionRegistryStrategy`
`protected SessionServerConfig`	`sessionServerConfig`
`protected Watchers`	`sessionWatchers` store watchers
`protected WrapperInterceptorManager`	`wrapperInterceptorManager`
`protected WriteDataAcceptor`	`writeDataAcceptor`

构造器概要

构造器
构造器和说明

SessionRegistry()

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

方法概要

所有方法实例方法具体方法
限定符和类型	方法和说明
`void`	`blacklist(List<ConnectId> connectIds)` disable the connectIds: 1. clean pub/sub/wat; 2. check sub
`void`	`clean(List<ConnectId> connectIds)` clean all the connectIds: 1. clean pubs/sub/wat
`void`	`cleanClientConnect()` for scheduler clean no connect client
`void`	`clientOff(List<ConnectId> connectIds)` client off the connectIds: 1. clean pubs, keep sub/wat; 2. check sub
`String`	`getDataCenterWhenPushEmpty()`
`void`	`init()`
`boolean`	`isPushEmpty(Subscriber subscriber)`
`void`	`register(StoreData storeData, Channel channel)` register new publisher or subscriber data
`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

- 字段详细资料
  - LOGGER
```
protected static final Logger LOGGER
```
  - SCAN_VER_LOGGER
```
protected static final Logger SCAN_VER_LOGGER
```
  - sessionInterests
```
@Autowired
protected Interests sessionInterests
```
    store subscribers
  - sessionWatchers
```
@Autowired
protected Watchers sessionWatchers
```
    store watchers
  - sessionDataStore
```
@Autowired
protected DataStore sessionDataStore
```
    store publishers
  - sessionServerConfig
```
@Autowired
protected SessionServerConfig sessionServerConfig
```
  - pushSwitchService
```
@Autowired
protected PushSwitchService pushSwitchService
```
  - boltExchange
```
@Autowired
protected Exchange boltExchange
```
  - sessionRegistryStrategy
```
@Autowired
protected SessionRegistryStrategy sessionRegistryStrategy
```
  - wrapperInterceptorManager
```
@Autowired
protected WrapperInterceptorManager wrapperInterceptorManager
```
  - writeDataAcceptor
```
@Autowired
protected WriteDataAcceptor writeDataAcceptor
```
  - firePushService
```
@Autowired
protected FirePushService firePushService
```
  - configProvideDataWatcher
```
@Autowired
protected ConfigProvideDataWatcher configProvideDataWatcher
```
- 构造器详细资料
  - SessionRegistry
```
public SessionRegistry()
```
- 方法详细资料
  - init
```
@PostConstruct
public void init()
```
  - register
```
public void register(StoreData storeData,
                     Channel channel)
```
    从接口复制的说明: Registry
    
    register new publisher or subscriber data
    
    指定者:
    
    register 在接口中 Registry
    
    参数:
    
    storeData - data
    
    channel - channel
  - 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
    
    参数:
    
    storeData - data
  - clean
```
public void clean(List<ConnectId> connectIds)
```
    从接口复制的说明: Registry
    
    clean all the connectIds: 1. clean pubs/sub/wat
    
    指定者:
    
    clean 在接口中 Registry
    
    参数:
    
    connectIds - connectIds
  - clientOff
```
public void clientOff(List<ConnectId> connectIds)
```
    从接口复制的说明: Registry
    
    client off the connectIds: 1. clean pubs, keep sub/wat; 2. check sub
    
    指定者:
    
    clientOff 在接口中 Registry
    
    参数:
    
    connectIds - connectIds
  - blacklist
```
public void blacklist(List<ConnectId> connectIds)
```
    从接口复制的说明: Registry
    
    disable the connectIds: 1. clean pub/sub/wat; 2. check sub
    
    指定者:
    
    blacklist 在接口中 Registry
    
    参数:
    
    connectIds - connectIds
  - isPushEmpty
```
public boolean isPushEmpty(Subscriber subscriber)
```
  - getDataCenterWhenPushEmpty
```
public String getDataCenterWhenPushEmpty()
```
  - cleanClientConnect
```
public void cleanClientConnect()
```
    从接口复制的说明: Registry
    
    for scheduler clean no connect client
    
    指定者:
    
    cleanClientConnect 在接口中 Registry

类 SessionRegistry

嵌套类概要

字段概要

构造器概要

方法概要

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

字段详细资料

LOGGER

SCAN_VER_LOGGER

sessionInterests

sessionWatchers

sessionDataStore

sessionServerConfig

pushSwitchService

boltExchange

sessionRegistryStrategy

wrapperInterceptorManager

writeDataAcceptor

firePushService

configProvideDataWatcher

构造器详细资料

SessionRegistry

方法详细资料

init

register

unRegister

clean

clientOff

blacklist

isPushEmpty

getDataCenterWhenPushEmpty

cleanClientConnect