net.ymate.platform.serv.nio

Class AbstractNioEventProcessor<LISTENER extends IListener<INioSession>>

java.lang.Object

java.lang.Thread

net.ymate.platform.serv.nio.AbstractNioEventProcessor<LISTENER>

Type Parameters:

LISTENER - 监听器类型

All Implemented Interfaces:

AutoCloseable, Runnable, INioEventProcessor<INioSession>

Direct Known Subclasses:

NioEventProcessor

public abstract class AbstractNioEventProcessor<LISTENER extends IListener<INioSession>>
extends Thread
implements INioEventProcessor<INioSession>

Author:

刘镇 (suninformation@163.com) on 2018/11/15 11:33 PM

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
AbstractNioEventProcessor(String name, INioEventGroup<LISTENER> eventGroup, long selectTimeout)

Method Summary

Modifier and Type	Method and Description
protected abstract INioSession	buildNioSession(INioEventGroup<LISTENER> eventGroup, SelectableChannel channel) 由子类实现创建会话的具体逻辑
void	close()
void	interrupt()
protected void	onExceptionEvent(SelectionKey key, Throwable e)
protected abstract void	onReadEvent(SelectionKey key) 由子类实现通道读逻辑
protected abstract void	onWriteEvent(SelectionKey key) 由子类实现通道写逻辑
void	registerEvent(SelectableChannel channel, int ops, INioSession session) 注册事件
void	run()
Selector	selector() 获取选择器
void	start() 启动
void	unregisterEvent(INioSession session) 解注册事件

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractNioEventProcessor

public AbstractNioEventProcessor(String name,
                                 INioEventGroup<LISTENER> eventGroup,
                                 long selectTimeout)
                          throws IOException

Throws:

IOException

Method Detail

start

public void start()

Description copied from interface: INioEventProcessor

启动

Specified by:

start in interface INioEventProcessor<INioSession>

Overrides:

start in class Thread

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

interrupt

public void interrupt()

Overrides:

interrupt in class Thread

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException

registerEvent

public void registerEvent(SelectableChannel channel,
                          int ops,
                          INioSession session)
                   throws IOException

Description copied from interface: INioEventProcessor

注册事件

Specified by:

registerEvent in interface INioEventProcessor<INioSession>

Parameters:

channel - 多路复用频道

ops - 操作标识

session - 会话对象

Throws:

IOException - 可能产生的IO异常

unregisterEvent

public void unregisterEvent(INioSession session)

Description copied from interface: INioEventProcessor

解注册事件

Specified by:

unregisterEvent in interface INioEventProcessor<INioSession>

Parameters:

session - 会话对象

selector

public Selector selector()

Description copied from interface: INioEventProcessor

获取选择器

Specified by:

selector in interface INioEventProcessor<INioSession>

Returns:

返回选择器对象

onExceptionEvent

protected void onExceptionEvent(SelectionKey key,
                                Throwable e)

buildNioSession

protected abstract INioSession buildNioSession(INioEventGroup<LISTENER> eventGroup,
                                               SelectableChannel channel)

由子类实现创建会话的具体逻辑

Parameters:

eventGroup - 多路复用通道事件处理器

channel - 通道

Returns:

返回会话对象

onReadEvent

protected abstract void onReadEvent(SelectionKey key)
                             throws IOException

由子类实现通道读逻辑

Parameters:

key - 选择键

Throws:

IOException - 可能产生的I/O异常

onWriteEvent

protected abstract void onWriteEvent(SelectionKey key)
                              throws IOException

由子类实现通道写逻辑

Parameters:

key - 选择键

Throws:

IOException - 可能产生的I/O异常