Netty基础教程之客户端创建

437次阅读

共计 3316 个字符，预计需要花费 9 分钟才能阅读完成。

阅读目录

一、客户端开发时序图
二、Netty 客户端开发步骤
三、Netty 客户端开发示例代码
四、参考资料

Netty 基础教程之客户端创建

图片来源:Netty 权威指南 (第 2 版)

使用 Netty 进行客户端开发主要有以下几个步骤：

Bootstrap b = new Bootstrap();

Bootstrap 是 Socket 客户端创建工具类，通过 API 设置创建客户端相关的参数，异步发起客户端连接。

EventLoopGroup group = new NioEventLoopGroup();

b.group(group).channel(NioSocketChannel.class).option(ChannelOption.TCP_NODELAY, true)

此处的 NioSocketChannel 类似于 Java NIO 提供的 SocketChannel。

b.group(group).channel(NioSocketChannel.class).option(ChannelOption.TCP_NODELAY, true)
 .handler(new ChannelInitializer<SocketChannel>()
  {
       @Override
       public void initChannel(SocketChannel ch) throws Exception
       {ch.pipeline().addLast(new HelloClientHandler());
        }
  });

用于调度和执行网络事件。

// 发起异步连接操作 
 ChannelFuture f = b.connect(host, port).sync();

SocketChannel 执行 connect() 操作后有以下三种结果：

连接成功，然会 true;
暂时没有连接上，服务器端没有返回 ACK 应答，连接结果不确定，返回 false。此种结果下，需要将 NioSocketChannel 中的 selectionKey 设置为 OP_CONNECT，监听连接结果；
接连失败，直接抛出 I / O 异常

需求：客户端端实现，连接服务器端，并向服务器端发送 hello Netty。(注：本代码使用的 netty 是 netty-all-5.0.0.Alpha1-sources.jar 版本)

服务器端代码见 Netty 学习之服务器端创建

客户端代码：

import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;

public class HelloClient
{public void connect(int port, String host) throws Exception
    {// 配置客户端 NIO 线程组 
        EventLoopGroup group = new NioEventLoopGroup();
        try
        {Bootstrap b = new Bootstrap();
            b.group(group).channel(NioSocketChannel.class).option(ChannelOption.TCP_NODELAY, true)
                    .handler(new ChannelInitializer<SocketChannel>()
                    {
                        @Override
                        public void initChannel(SocketChannel ch) throws Exception
                        {ch.pipeline().addLast(new HelloClientHandler());
                        }
                    });

            // 发起异步连接操作 
            ChannelFuture f = b.connect(host, port).sync();

            // 等待客户端链路关闭 
            f.channel().closeFuture().sync();} finally
        {group.shutdownGracefully();
        }
    }
    public static void main(String[] args) throws Exception
    {int port = 8080;
        new HelloClient().connect(port, "127.0.0.1");
    }
}

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerAdapter;
import io.netty.channel.ChannelHandlerContext;

public class HelloClientHandler  extends ChannelHandlerAdapter
{private final ByteBuf message;
    
    public HelloClientHandler()
    {byte[] req="hello Netty".getBytes();
        message=Unpooled.buffer(req.length);
        message.writeBytes(req);
    }

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception
    {ctx.writeAndFlush(message);
    }
    
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception
    {ctx.close();
    }
}