org.cauli.server.netty

类 StaleConnectionTrackingHandler

java.lang.Object

org.jboss.netty.channel.SimpleChannelHandler

org.cauli.server.netty.StaleConnectionTrackingHandler

所有已实现的接口:

org.jboss.netty.channel.ChannelDownstreamHandler, org.jboss.netty.channel.ChannelHandler, org.jboss.netty.channel.ChannelUpstreamHandler

public class StaleConnectionTrackingHandler
extends org.jboss.netty.channel.SimpleChannelHandler

Keeps track of all connections and automatically closes the ones that are stale.

嵌套类概要

从接口继承的嵌套类/接口 org.jboss.netty.channel.ChannelHandler

org.jboss.netty.channel.ChannelHandler.Sharable

字段概要

字段

限定符和类型	字段和说明
private Executor	executor
private Map<org.jboss.netty.channel.Channel,Long>	stamps
private long	timeout

构造器概要

构造器

构造器和说明
StaleConnectionTrackingHandler(long timeout, Executor executor)

方法概要

方法

限定符和类型	方法和说明
void	channelOpen(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent e)
void	closeStaleConnections()
private boolean	isStale(Long timeStamp)
void	messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent e)
private void	stamp(org.jboss.netty.channel.Channel channel)
void	stopTracking(org.jboss.netty.channel.Channel channel) Stops tracking this channel for staleness.

从类继承的方法 org.jboss.netty.channel.SimpleChannelHandler

bindRequested, channelBound, channelClosed, channelConnected, channelDisconnected, channelInterestChanged, channelUnbound, childChannelClosed, childChannelOpen, closeRequested, connectRequested, disconnectRequested, exceptionCaught, handleDownstream, handleUpstream, setInterestOpsRequested, unbindRequested, writeComplete, writeRequested

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

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

字段详细资料

stamps

private final Map<org.jboss.netty.channel.Channel,Long> stamps

timeout

private final long timeout

executor

private final Executor executor

构造器详细资料

StaleConnectionTrackingHandler

public StaleConnectionTrackingHandler(long timeout,
                              Executor executor)

方法详细资料

channelOpen

public void channelOpen(org.jboss.netty.channel.ChannelHandlerContext ctx,
               org.jboss.netty.channel.ChannelStateEvent e)
                 throws Exception

覆盖:

channelOpen 在类中 org.jboss.netty.channel.SimpleChannelHandler

抛出:

Exception

messageReceived

public void messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx,
                   org.jboss.netty.channel.MessageEvent e)
                     throws Exception

覆盖:

messageReceived 在类中 org.jboss.netty.channel.SimpleChannelHandler

抛出:

Exception

stamp

private void stamp(org.jboss.netty.channel.Channel channel)

closeStaleConnections

public void closeStaleConnections()

stopTracking

public void stopTracking(org.jboss.netty.channel.Channel channel)

Stops tracking this channel for staleness. This happens for WebSockets and EventSource connections.

参数:

channel -

isStale

private boolean isStale(Long timeStamp)