Writing a Time Client 写个时间客户端

不像 DISCARD 和 ECHO 的服务端，对于 TIME 协议我们需要一个客户端,因为人们不能把一个 32 位的二进制数据翻译成一个日期或者日历。在这一部分，我们将会讨论如何确保服务端是正常工作的，并且学习怎样用 Netty 编写一个客户端。

在 Netty 中,编写服务端和客户端最大的并且唯一不同的使用了不同的BootStrap 和 Channel的实现。请看一下下面的代码：

  1. public class TimeClient {
  3.     public static void main(String[] args) throws Exception {
  5.         String host = args[0];
  6.         int port = Integer.parseInt(args[1]);
  7.         EventLoopGroup workerGroup = new NioEventLoopGroup();
  9.         try {
  10.             Bootstrap b = new Bootstrap(); // (1)
  11.             b.group(workerGroup); // (2)
  12.             b.channel(NioSocketChannel.class); // (3)
  13.             b.option(ChannelOption.SO_KEEPALIVE, true); // (4)
  14.             b.handler(new ChannelInitializer<SocketChannel>() {
  15.                 @Override
  16.                 public void initChannel(SocketChannel ch) throws Exception {
  17.                     ch.pipeline().addLast(new TimeClientHandler());
  18.                 }
  19.             });
  21.             // 启动客户端
  22.             ChannelFuture f = b.connect(host, port).sync(); // (5)
  24.             // 等待连接关闭
  25.             f.channel().closeFuture().sync();
  26.         } finally {
  27.             workerGroup.shutdownGracefully();
  28.         }
  29.     }
  30. }

  1. BootStrap 和 ServerBootstrap 类似,不过他是对非服务端的 channel 而言，比如客户端或者无连接传输模式的 channel。

  2. 如果你只指定了一个 EventLoopGroup，那他就会即作为一个 boss group ，也会作为一个 workder group，尽管客户端不需要使用到 boss worker 。

  3. 代替NioServerSocketChannel的是NioSocketChannel,这个类在客户端 channel 被创建时使用。

  4. 不像在使用 ServerBootstrap 时需要用 childOption() 方法，因为客户端的 SocketChannel 没有父亲。

  5. 我们用 connect() 方法代替了 bind() 方法。

正如你看到的，他和服务端的代码是不一样的。ChannelHandler 是如何实现的?他应该从服务端接受一个 32 位的整数消息，把他翻译成人们能读懂的格式，并打印翻译好的时间，最后关闭连接:

  1.  import java.util.Date;
  3.  public class TimeClientHandler extends ChannelInboundHandlerAdapter {
  4.      @Override
  5.      public void channelRead(ChannelHandlerContext ctx, Object msg) {
  6.          ByteBuf m = (ByteBuf) msg; // (1)
  7.          try {
  8.              long currentTimeMillis = (m.readUnsignedInt() - 2208988800L) * 1000L;
  9.              System.out.println(new Date(currentTimeMillis));
  10.              ctx.close();
  11.          } finally {
  12.              m.release();
  13.          }
  14.      }
  16.      @Override
  17.      public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
  18.          cause.printStackTrace();
  19.          ctx.close();
  20.      }
  21.  }
  1. 在 TCP/IP 中，Netty 会把读到的数据放到 ByteBuf 的数据结构中。

这样看起来非常简单，并且和服务端的那个例子的代码也相差不多。然而，处理器有时候会因为抛出 IndexOutOfBoundsException 而拒绝工作。在下个部分我们会讨论为什么会发生这种情况。