在了解 ChanelPipeline
,EventLoop
等组件之后,我们需要将这些组件组织起来,使其成为一个可运行的应用程序。 这里就需要引导 Boostrap
相关组件了。
1. Boostrap 类
引导类的层次结构包括一个抽象的父类和两个具体的引导子类:
服务端引导类 ServerBootstrap
总是需要一个 ServerSocketChannel
来处理客户端的连接通信,而客户端引导类 Bootstrap
则只需要一个普通的 Channel
用于与服务端的通信。
下面是 AbstractBootstrap
的主要方法:
方法 | 描述 |
---|---|
group |
设置用于处理所有事件的 EventLoopGroup |
channel |
指定服务端或客户端的 Channel |
channelFactory |
如果引导没有指定Channel,那么可以指定ChannelFactory来创建Channel |
localAddress |
指定Channel需要绑定的本地地址,如果不指定,则将由系统随机分配一个地址 |
remoteAddress |
设置Channel需要连接的远程地址 |
attr |
指定新创建的Channel的属性值 |
handler |
设置添加到ChannelPipeline中的ChannelHandler |
connect |
连接到远程主机,返回ChannelFuture,用于连接完成的回调 |
bind |
绑定指定地址,返回ChannelFuture,用于绑定完成的回调 |
2. 引导客户端和无连接协议 Booststrap
当需要引导客户端或一些无连接协议时,需要使用 Bootstrap
类。
Bootstrap
类负责创建管道给客户或应用程序,作为客户端,我们需要使用到 connect
API 来连接到远程 服务端,其过程如下:
客户端引导的编程模型如下:
// 创建EventLoopGroup
EventLoopGroup group = new NioEventLoopGroup();
// 创建客户端引导
Bootstrap bootstrap = new Bootstrap();
// 配置各种属性,如Channel,ChannelHandler等
bootstrap.group(group)
.channel(NioSocketChannel.class)
.handler(new SimpleChannelInboundHandler<ByteBuf>() {
@Override
protected void channeRead0(
ChannelHandlerContext channelHandlerContext,
ByteBuf byteBuf) throws Exception {
System.out.println("Received data");
byteBuf.clear();
}
});
// 连接到远程主机
ChannelFuture future = bootstrap.connect(new InetSocketAddress("www.manning.com", 80));
// 设置连接成功后的回调
future.addListener(new ChannelFutureListener() {
@Override
public void operationComplete(ChannelFuture channelFuture)
throws Exception {
if (channelFuture.isSuccess()) {
System.out.println("Connection established");
} else {
System.err.println("Connection attempt failed");
channelFuture.cause().printStackTrace();
}
}
});
3. 引导服务端 ServerBootstrap
ServerBootstrap
负责Netty应用程序的服务端引导,作为服务端,我们需要使用 bind
API来 与本地地址绑定,从而接收客户端连接,其过程如下:
服务端引导的编程模型如下:
//创建EventLoopGroup
NioEventLoopGroup group = new NioEventLoopGroup();
//创建服务端引导
ServerBootstrap bootstrap = new ServerBootstrap();
//配置各种属性,如Channel,ChannelHandler等
bootstrap.group(group)
.channel(NioServerSocketChannel.class)
.childHandler(new SimpleChannelInboundHandler<ByteBuf>() {
@Override
protected void channelRead0(ChannelHandlerContext ctx,
ByteBuf byteBuf) throws Exception {
System.out.println("Received data");
byteBuf.clear();
}
}
);
//绑定本地地址
ChannelFuture future = bootstrap.bind(new InetSocketAddress(8080));
//设置绑定成功后的回调
future.addListener(new ChannelFutureListener() {
@Override
public void operationComplete(ChannelFuture channelFuture)
throws Exception {
if (channelFuture.isSuccess()) {
System.out.println("Server bound");
} else {
System.err.println("Bound attempt failed");
channelFuture.cause().printStackTrace();
}
}
}
);
引用
《Netty 实战》