客戶端要做的是： * 連接服務器 * 發送信息 * 發送的每個信息，等待和接收從服務器返回的同樣的信息 * 關閉連接 ### [](https://github.com/waylau/essential-netty-in-action/blob/master/GETTING%20STARTED/Writing%20an%20echo%20client.md#用-channelhandler-實現客戶端邏輯)用 ChannelHandler 實現客戶端邏輯 跟寫服務器一樣，我們提供 ChannelInboundHandler 來處理數據。下面例子，我們用 SimpleChannelInboundHandler 來處理所有的任務，需要覆蓋三個方法： * channelActive() - 服務器的連接被建立后調用 * channelRead0() - 數據后從服務器接收到調用 * exceptionCaught() - 捕獲一個異常時調用 Listing 2.4 ChannelHandler for the client ~~~ @Sharable //1 public class EchoClientHandler extends SimpleChannelInboundHandler<ByteBuf> { @Override public void channelActive(ChannelHandlerContext ctx) { ctx.writeAndFlush(Unpooled.copiedBuffer("Netty rocks!", //2 CharsetUtil.UTF_8)); } @Override public void channelRead0(ChannelHandlerContext ctx, ByteBuf in) { System.out.println("Client received: " + in.toString(CharsetUtil.UTF_8)); //3 } @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) { //4 cause.printStackTrace(); ctx.close(); } } ~~~ 1.`@Sharable`標記這個類的實例可以在 channel 里共享 2.當被通知該 channel 是活動的時候就發送信息 3.記錄接收到的消息 4.記錄日志錯誤并關閉 channel 建立連接后該 channelActive() 方法被調用一次。邏輯很簡單：一旦建立了連接，字節序列被發送到服務器。該消息的內容并不重要;在這里，我們使用了 Netty 編碼字符串 “Netty rocks!” 通過覆蓋這種方法，我們確保東西被盡快寫入到服務器。 接下來，我們覆蓋方法 channelRead0()。這種方法會在接收到數據時被調用。注意，由服務器所發送的消息可以以塊的形式被接收。即，當服務器發送 5 個字節是不是保證所有的 5 個字節會立刻收到 - 即使是只有 5 個字節，channelRead0() 方法可被調用兩次，第一次用一個ByteBuf（Netty的字節容器）裝載3個字節和第二次一個 ByteBuf 裝載 2 個字節。唯一要保證的是，該字節將按照它們發送的順序分別被接收。 （注意，這是真實的，只有面向流的協議如TCP）。 第三個方法重寫是 exceptionCaught()。正如在 EchoServerHandler （清單2.2），所述的記錄 Throwable 并且關閉通道，在這種情況下終止 連接到服務器。 *SimpleChannelInboundHandler vs. ChannelInboundHandler* *何時用這2個要看具體業務的需要。在客戶端，當 channelRead0() 完成，我們已經拿到的入站的信息。當方法返回，SimpleChannelInboundHandler 會小心的釋放對 ByteBuf（保存信息） 的引用。而在 EchoServerHandler,我們需要將入站的信息返回給發送者，write() 是異步的在 channelRead()返回時，可能還沒有完成。所以，我們使用 ChannelInboundHandlerAdapter,無需釋放信息。最后在 channelReadComplete() 我們調用 ctxWriteAndFlush() 來釋放信息。詳見第5、6章* ### [](https://github.com/waylau/essential-netty-in-action/blob/master/GETTING%20STARTED/Writing%20an%20echo%20client.md#引導客戶端)引導客戶端 客戶端引導需要 host 、port 兩個參數連接服務器。 Listing 2.5 Main class for the client ~~~ public class EchoClient { private final String host; private final int port; public EchoClient(String host, int port) { this.host = host; this.port = port; } public void start() throws Exception { EventLoopGroup group = new NioEventLoopGroup(); try { Bootstrap b = new Bootstrap(); //1 b.group(group) //2 .channel(NioSocketChannel.class) //3 .remoteAddress(new InetSocketAddress(host, port)) //4 .handler(new ChannelInitializer<SocketChannel>() { //5 @Override public void initChannel(SocketChannel ch) throws Exception { ch.pipeline().addLast( new EchoClientHandler()); } }); ChannelFuture f = b.connect().sync(); //6 f.channel().closeFuture().sync(); //7 } finally { group.shutdownGracefully().sync(); //8 } } public static void main(String[] args) throws Exception { if (args.length != 2) { System.err.println( "Usage: " + EchoClient.class.getSimpleName() + " <host> <port>"); return; } final String host = args[0]; final int port = Integer.parseInt(args[1]); new EchoClient(host, port).start(); } } ~~~ 1.創建 Bootstrap 2.指定 EventLoopGroup 來處理客戶端事件。由于我們使用 NIO 傳輸，所以用到了 NioEventLoopGroup 的實現 3.使用的 channel 類型是一個用于 NIO 傳輸 4.設置服務器的 InetSocketAddress 5.當建立一個連接和一個新的通道時，創建添加到 EchoClientHandler 實例 到 channel pipeline 6.連接到遠程;等待連接完成 7.阻塞直到 Channel 關閉 8.調用 shutdownGracefully() 來關閉線程池和釋放所有資源 與以前一樣，在這里使用了 NIO 傳輸。請注意，您可以在 客戶端和服務器 使用不同的傳輸 ，例如 NIO 在服務器端和 OIO 客戶端。在第四章中，我們將研究一些具體的因素和情況，這將導致 您可以選擇一種傳輸，而不是另一種。 讓我們回顧一下我們在本節所介紹的要點 * 一個 Bootstrap 被創建來初始化客戶端 * 一個 NioEventLoopGroup 實例被分配給處理該事件的處理，這包括創建新的連接和處理入站和出站數據 * 一個 InetSocketAddress 為連接到服務器而創建 * 一個 EchoClientHandler 將被安裝在 pipeline 當連接完成時 * 之后 Bootstrap.connect（）被調用連接到遠程的 - 本例就是 echo(回聲)服務器。