Netty实战笔记

receiveMesage

sendMessage

Channel channel = ...;
// Does not block
ChannelFuture future = channel.connect(
new InetSocketAddress("192.168.0.1", 25));
future.addListener(new ChannelFutureListener() {
@Override
public void operationComplete(ChannelFuture future) {
if (future.isSuccess()){
ByteBuf buffer = Unpooled.copiedBuffer(
"Hello",Charset.defaultCharset());
ChannelFuture wf = future.channel()
.writeAndFlush(buffer);
....
} else {
Throwable cause = future.cause();
cause.printStackTrace();}}});

激活

失活

请求在新连接创建Channel时获得通知

请求创建一个新连接时获得通知

请求当数据已经就系,可以从channel中获得通知

请求可以向channel中写更多的数据时获得通知

字节

HTTP状态码

cookie

支撑数组    backing array

ByteBuf directBuf = ...;
if (!directBuf.hasArray()) {
int length = directBuf.readableBytes();
byte[] array = new byte[length];
directBuf.getBytes(directBuf.readerIndex(), array);
handleArray(array, 0, length);
}

CompositeByteBuf messageBuf = Unpooled.compositeBuffer();
ByteBuf headerBuf = ...; // can be backing or direct
ByteBuf bodyBuf = ...; // can be backing or direct
messageBuf.addComponents(headerBuf, bodyBuf);
.....
messageBuf.removeComponent(0); // remove the header
for (ByteBuf buf : messageBuf) {
System.out.println(buf.toString());
}
CompositeByteBuf 可能不支持访问其支撑数组，因此访问 CompositeByteBuf 中的数
据类似于（访问）直接缓冲区的模式

channelRegistered                        当 Channel 已经注册到它的 EventLoop 并且能够处理 I/O 时被调用
channelUnregistered                    当 Channel 从它的 EventLoop 注销并且无法处理任何 I/O 时被调用
channelActive                               当 Channel 处于活动状态时被调用； Channel 已经连接/绑定并且已经就绪
channelInactive                             当 Channel 离开活动状态并且不再连接它的远程节点时被调用
channelReadComplete                 当Channel上的一个读操作完成时被调用 ①
channelRead                                 当从 Channel 读取数据时被调用
ChannelWritabilityChanged          当 Channel 的可写状态发生改变时被调用。用户可以确保写操作不会完成 得太快（以避免发生 OutOfMemoryError）                                                                   或者可以在 Channel 变为再次可写时恢复写入。可以通过调用 Channel 的 isWritable()方法来检测Channel 的                                                                     可写性。 与可写性相关的阈值可以通过 Channel.config().setWriteHighWaterMark()和
                                                                 Channel.config().setWriteLowWaterMark()方法来设置
userEventTriggered                      当 ChannelnboundHandler.fireUserEventTriggered()方 法被调用时被调用.因为一个POJO被传经了ChannelPipeline

ReferenceCountUtil.release(msg);

bind
connect
disconnect
close
deregister
flush
write
writeAndFlush
read   

以上方法皆调用ChannelPipeline 中下一个ChannelOutboundHandler的对应方法

方法一    加入监听器

方法二    setFailure(Throwable cause)

是

否

eventloop

eventloop

eventloop

eventloop

eventloop

eventloop

创建连接

将读取的对象放入out.

然后会自动交给下一个InboundHandler处理

HttpContent

HttpContent

接着上一个

new ProtobufVarint32FrameDecoder()

new ProtobufEncoder()

new ProtobufDecoder(lite)

new ObjectHandler()