标签:style blog http color os 使用 java io strong
Future<Connection> clientConnectionFuture = tcpNioTransport.connect("grizzly.java.net",80);
Connection clientConnection = clientConnectionFuture.get();
Connection conn;
conn.addCloseListener(newCloseListener<Closeable,ICloseType>(){
@Override
publicvoid onClosed(Closeable closeable,ICloseType type)
throwsIOException{
// TODO Auto-generated method stub
}
});
publicNextAction handleRead(FilterChainContext ctx)throwsIOException;
publicNextAction handleWrite(FilterChainContext ctx)throwsIOException;
publicNextAction handleConnect(FilterChainContext ctx)throwsIOException;
publicNextAction handleAccept(FilterChainContext ctx)throwsIOException;
publicNextAction handleClose(FilterChainContext ctx)throwsIOException;
return ctx.getStopAction(incompleteChunk);
如果是继续下一次Filter流程,就返回InvokeAction
return ctx.getInvokeAction();
如果数据流里面有粘包(两个数据包一起发来,我们需要一个个处理),同样可以添加参数:
return ctx.getInvokeAction(incompleteChunk);
return ctx.getRerunFilterAction()
这个就是当前Filter的action多执行一次。
return ctx.getSuspendAction();
这个是暂停。。。。中断线程,并且通过另外一个线程调用
ctx.resume():
return ctx.getForkAction();
和上一个类似。
标签:style blog http color os 使用 java io strong
原文地址:http://www.cnblogs.com/chzcb/p/3942323.html