netty 原理
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了netty 原理，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3057字，纯文字阅读大概需要5分钟。
内容图文
netty 实现
1. 各组件之间的关系
每个ServerBootstrap与一个事件循环对象（一个线程）都会与一个Channel绑定，如NioServerSocketChannel
2. 如何绑定
在做bind操作时，会执行方法，register进行注册
ChannelFuture regFuture = config().group().register(channel);
关键接口及类之间的关系：
EventLoopGroup与EventLoop及其类关系图之间形成组合模式。
@Override
public ChannelFuture register(Channel channel) {
returnnext().register(channel);//选择一个线程执行器，调用register方法，绑定channel
}
@Override
public ChannelFuture register(Channel channel) {
returnregister(newDefaultChannelPromise(channel, this));
}
3. 代表客户端的channel创建
注意到ServerBootstrap有两个EventLoopGroup,parent 负责代表客户端channel的分发，child负责代码客户端channel的处理。
- Accept事件，创建代表客户端的channel
if ((readyOps & (SelectionKey.OP_READ | SelectionKey.OP_ACCEPT)) != 0 || readyOps == 0) {
unsafe.read();
}
try {
do {
int localRead = doReadMessages(readBuf);
if (localRead == 0) {
break;
}
if (localRead < 0) {
closed = true;
break;
}
allocHandle.incMessagesRead(localRead);
} while (allocHandle.continueReading());
} catch (Throwable t) {
exception = t;
}
int size = readBuf.size();
for (int i = 0; i < size; i ++) {
readPending = false;
pipeline.fireChannelRead(readBuf.get(i));
}
readBuf.clear();
allocHandle.readComplete();
pipeline.fireChannelReadComplete();
protected
int
doReadMessages(List<Object> buf) throws Exception {
SocketChannel ch = SocketUtils.accept(javaChannel());
try {
if (ch != null) {
buf.add(newNioSocketChannel(this, ch));
return1;
}
} catch (Throwable t) {
logger.warn("Failed to create a new channel from an accepted socket.", t);
try {
ch.close();
} catch (Throwable t2) {
logger.warn("Failed to close a socket.", t2);
}
}
return0;
}
注意到doReadMessages会创建代表客户端的channel,创建完成会触发，fireChannelRead 事件。
4. 代表客户端的channel分发
上一节知道，channel创建完成会触发fireChannelRead 事件。在ServerSocketChannel初始化时，会注册ServerBootstrapAcceptor 用户接收代表客户端channel并分发到child EventLoopGroup中执行。
p.addLast(new ChannelInitializer<Channel>() {
@OverridepublicvoidinitChannel(final Channel ch) throws Exception {
final ChannelPipeline pipeline = ch.pipeline();
ChannelHandler handler = config.handler();
if (handler != null) {
pipeline.addLast(handler);
}
ch.eventLoop().execute(new Runnable() {
@Overridepublicvoidrun() {
pipeline.addLast(newServerBootstrapAcceptor(
ch, currentChildGroup, currentChildHandler, currentChildOptions, currentChildAttrs));
}
});
}
});
@Override
@SuppressWarnings("unchecked")
publicvoidchannelRead(ChannelHandlerContext ctx, Object msg) {
final Channel child = (Channel) msg;
child.pipeline().addLast(childHandler);
setChannelOptions(child, childOptions, logger);
for (Entry<AttributeKey<?>, Object> e: childAttrs) {
child.attr((AttributeKey<Object>) e.getKey()).set(e.getValue());
}
try {
childGroup.register(child).addListener(newChannelFutureListener() {
@OverridepublicvoidoperationComplete(ChannelFuture future) throws Exception {
if (!future.isSuccess()) {
forceClose(child, future.cause());
}
}
});
} catch (Throwable t) {
forceClose(child, t);
}
}
5. netty线程模型
不管是客户端还是服务端可以通过一个Channel同时读或者写，不需要阻塞，读写多路复用。
6. handler链模型
原文：https://www.cnblogs.com/dragonfei/p/9074752.html
内容总结
以上是互联网集市为您收集整理的netty 原理全部内容，希望文章能够帮你解决netty 原理所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。