深入浅出Netty之四 Client请求处理

前2篇分析了echo server端的运行机制，本篇同样以echo client为例，分析netty的nio客户端的运行机制。

总体来说client端和server端的处理是类似的，NioWorker是重用的，也就意味着client和server的读写机制是一样的，都是通过worker线程来管理的。所不同的是Boss线程，server端的boss线程一个bind端口起一个，主要负责接收新请求，而client端的boss线程是一个可配置的数组，一个connect端口分配一个，主要负责connect过程，如果connect成功则将channle注册到worker线程中处理。在Client同样有PipelineSink，叫做NioClientSocketPipelineSink，也是负责底层IO和pipeline之间的交互。

EchoClient代码:

Java代码

// 初始化Bootstrap和NioClientSocketChannelFactory，这一步将启动nioWorker线程，并初始化NioClientSocketPipelineSink，并将Boss线程创建
ClientBootstrap bootstrap = new ClientBootstrap(
new NioClientSocketChannelFactory(
Executors.newCachedThreadPool(),
Executors.newCachedThreadPool()));
// 用户自定义的pipeline工厂
bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
public ChannelPipeline getPipeline() throws Exception {
return Channels.pipeline(
new EchoClientHandler(firstMessageSize));
}
});
// 异步创建连接
ChannelFuture future = bootstrap.connect(new InetSocketAddress(host, port));
//等待连接关闭
future.getChannel().getCloseFuture().awaitUninterruptibly();
// 关闭资源，线程池等
bootstrap.releaseExternalResources();

        // 初始化Bootstrap和NioClientSocketChannelFactory，这一步将启动nioWorker线程，并初始化NioClientSocketPipelineSink，并将Boss线程创建ClientBootstrap bootstrap = new ClientBootstrap(new NioClientSocketChannelFactory(Executors.newCachedThreadPool(),Executors.newCachedThreadPool()));// 用户自定义的pipeline工厂bootstrap.setPipelineFactory(new ChannelPipelineFactory() {public ChannelPipeline getPipeline() throws Exception {return Channels.pipeline(new EchoClientHandler(firstMessageSize));}});// 异步创建连接ChannelFuture future = bootstrap.connect(new InetSocketAddress(host, port));//等待连接关闭future.getChannel().getCloseFuture().awaitUninterruptibly();// 关闭资源，线程池等bootstrap.releaseExternalResources();

具体connect过程：

一.创建client的channel

Java代码

public ChannelFuture connect(final SocketAddress remoteAddress, final SocketAddress localAddress) {
......
//拿用户自定义的pipeline
ChannelPipeline pipeline;
try {
pipeline = getPipelineFactory().getPipeline();
} catch (Exception e) {
throw new ChannelPipelineException("Failed to initialize a pipeline.", e);
}
// 从ChannelFactory中，创建Channel，对于client来说factory是NioClientSocketChannelFactory，Channel是NioClientSocketChannel
Channel ch = getFactory().newChannel(pipeline);
// 通过channel连接
return ch.connect(remoteAddress);
}

public ChannelFuture connect(final SocketAddress remoteAddress, final SocketAddress localAddress) {......//拿用户自定义的pipelineChannelPipeline pipeline;try {pipeline = getPipelineFactory().getPipeline();} catch (Exception e) {throw new ChannelPipelineException("Failed to initialize a pipeline.", e);}// 从ChannelFactory中，创建Channel，对于client来说factory是NioClientSocketChannelFactory，Channel是NioClientSocketChannelChannel ch = getFactory().newChannel(pipeline);// 通过channel连接return ch.connect(remoteAddress);}

二.创建channel时，分配worker

Java代码

public SocketChannel newChannel(ChannelPipeline pipeline) {
return new NioClientSocketChannel(this, pipeline, sink, sink.nextWorker());
}

 public SocketChannel newChannel(ChannelPipeline pipeline) {return new NioClientSocketChannel(this, pipeline, sink, sink.nextWorker());}

三.创建内部的SocketChannel，触发ChannelOpen事件，不过echo client的handler没有对channelOpen事件做处理

转载于:https://blog.51cto.com/daheyuan/1140093

深入浅出Netty之四 Client请求处理相关推荐

gateway网关调用报 reactor.netty.http.client.HttpClient.chunkedTransfer(Z)Lreactor/netty/http/client/HttpC
reactor.netty.http.client.HttpClient.chunkedTransfer(Z)Lreactor/netty/http/client/HttpClient; 这个错误是因 ...
【问题归纳】开启gateway网关调用报错: reactor.netty.http.client.HttpClient.chunkedTransfer(Z)L
开启 gateway 网关报错reactor.netty.http.client.HttpClient.chunkedTransfer(Z)Lreactor/netty/http/client/Htt ...
Connection prematurely closed BEFORE response reactor.netty.http.client.PrematureCloseException: Co
一.最近在开发网关系统,就在感觉万事大吉可以上线的时候发现了如下的错误(这个是我在配置rabbitmq访问多个服务时发现的) Connection prematurely closed BEFORE ...
Netty入门教程——深入浅出Netty
在这里我们主要从TCP应用部分讲述 Netty 的架构体系. 它涉及到的内容主要分为三个部分 : bootstrap, channel, eventLoop. bootstrap 主要负责服务建立与发 ...
4、netty编写http服务器、增加压缩支持、netty编写client、netty添加SL/TLS保护https支持
注:源代码来自享学课堂,学习之后所做笔记,方便回顾,也给大家一个参考目录 1 netty编写http服务器 1.1 主函数 1.2 ServerHandlerInit 1.3 服务端自定义BusiH ...
Netty之四种常用 IO 模型
四种常用 IO 模型: 同步阻塞 BIO: 最简单的 IO 模型,用户线程在读写时被阻塞. 数据拷贝指请求到的数据先存放在内核空间, 然后从内核空间拷贝至程序的缓冲区. 用户线程在 IO 过程中被阻塞 ...
一篇文章让你彻底了解什么叫Netty！大牛看了直呼内行！
作者:java蜜蜜链接:https://www.jianshu.com/p/1369b30b9f99 一.Netty到底是什么 1.从HTTP说起有了Netty,你可以实现自己的HTTP服务器,F ...
netty websocket客户端_Websocket操作字节序之服务端
Websocket在JavaScript中操作字节序之客户端在上一篇文章中,把页面的websocket编码写好了,那么服务端又该如何实现呢?由于该文是在上上篇demo中修改的,所以不全的代码还请 ...
netty半包粘包处理_老王：Netty到底是个什么鬼？有没有简单的理解方式？
前语:不要为了读文章而读文章,一定要带着问题来读文章,勤思考. 作者:lyowish 来源:http://1t.click/7RY # 从HTTP说起有了Netty,你可以实现自己的HTTP服 ...

深入浅出Netty之四 Client请求处理

深入浅出Netty之四 Client请求处理相关推荐

最新文章

热门文章