學習分布式，正好看到Netty 是一個基于NIO的客戶、服務器端編程框架，所以本著學習的態度去官網看了一下，官網例子，本著以后可以翻出來再看看的心態，把官網的第一個例子貼出來，也希望自己以后有一個可以復習的地方,第一次使用博客功能，還有很多不懂的地方

一.jar包
<!-- Netty開始 -->
<!-- https://mvnrepository.com/artifact/io.netty/netty-all -->
<dependency>
? ?<groupId>io.netty</groupId>
? ?<artifactId>netty-all</artifactId>
? ?<version>4.1.6.Final</version>
</dependency>
<!-- Netty結束 -->
二.DEMO
官方并沒有使用Hello World來作為一個例子，而是采用RFC的DISCARD，這個協議定義了就是接收到請求后什么也不干。

第一步編寫DiscardServerHandler類:

package io.netty.example.discard;
?
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.util.ReferenceCountUtil;
//ChannelInboundHandlerAdapter實現自ChannelInboundHandler
//ChannelInboundHandler提供了不同的事件處理方法你可以重寫
public class DiscardServerHandler extends ChannelInboundHandlerAdapter {
?? ?/*?
?? ? * @作者:CJY
?? ? * @說明:該方法用于接收從客戶端接收的信息
?? ? * @時間:2017-4-2下午12:25:05
?? ? * @see io.netty.channel.ChannelInboundHandlerAdapter#channelRead(io.netty.channel.ChannelHandlerContext, java.lang.Object)
?? ? * @param ctx
?? ? * @param msg
?? ? * @throws Exception
?? ? */
?? ?@Override
?? ?public void channelRead(ChannelHandlerContext ctx, Object msg)
?? ??? ??? ?throws Exception {
?? ??? ?//Discard the received data silently
?? ??? ?//ByteBuf是一個引用計數對象實現ReferenceCounted，他就是在有對象引用的時候計數+1，無的時候計數-1，當為0對象釋放內存
?? ??? ?ByteBuf in=(ByteBuf)msg;
?? ??? ?try {
?? ??? ??? ?while(in.isReadable()){
?? ??? ??? ??? ?System.out.println((char)in.readByte());
?? ??? ??? ??? ?System.out.flush();
?? ??? ??? ?}
?? ??? ?} finally {
?? ??? ??? ?ReferenceCountUtil.release(msg);
?? ??? ?}
?? ?}
?? ?
?? ?@Override
?? ?public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)
?? ??? ??? ?throws Exception {
?? ??? ?cause.printStackTrace();
?? ??? ?ctx.close();
?? ?}
}

第二步編寫DiscardServer:

package io.netty.example.discard;
?
import io.netty.bootstrap.ServerBootstrap;
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.NioServerSocketChannel;
?
public class DiscardServer {
?? ?private int port;
?? ?public DiscardServer(int port){
?? ??? ?this.port = port;
?? ?}
?? ?
?? ?public void run() throws Exception{
?? ??? ?//Group：群組，Loop：循環，Event：事件，這幾個東西聯在一起，相比大家也大概明白它的用途了。
?? ??? ?//Netty內部都是通過線程在處理各種數據，EventLoopGroup就是用來管理調度他們的，注冊Channel，管理他們的生命周期。
?? ??? ?//NioEventLoopGroup是一個處理I/O操作的多線程事件循環
?? ??? ?//bossGroup作為boss,接收傳入連接
?? ??? ?//因為bossGroup僅接收客戶端連接，不做復雜的邏輯處理，為了盡可能減少資源的占用，取值越小越好
?? ??? ?EventLoopGroup bossGroup=new NioEventLoopGroup(1);
?? ??? ?//workerGroup作為worker，處理boss接收的連接的流量和將接收的連接注冊進入這個worker
?? ??? ?EventLoopGroup workerGroup=new NioEventLoopGroup();
?? ??? ?try {
?? ??? ??? ?//ServerBootstrap負責建立服務端
?? ??? ??? ?//你可以直接使用Channel去建立服務端，但是大多數情況下你無需做這種乏味的事情
?? ??? ??? ?ServerBootstrap b=new ServerBootstrap();
?? ??? ??? ?b.group(bossGroup, workerGroup)
?? ??? ??? ?//指定使用NioServerSocketChannel產生一個Channel用來接收連接
?? ??? ??? ?.channel(NioServerSocketChannel.class)
?? ??? ??? ?//ChannelInitializer用于配置一個新的Channel
?? ??? ??? ?//用于向你的Channel當中添加ChannelInboundHandler的實現
?? ??? ??? ?.childHandler(new ChannelInitializer<SocketChannel>() {
?? ??? ??? ??? ?public void initChannel(SocketChannel ch) throws Exception {
?? ??? ??? ??? ??? ?//ChannelPipeline用于存放管理ChannelHandel
?? ??? ??? ??? ??? ?//ChannelHandler用于處理請求響應的業務邏輯相關代碼
?? ??? ??? ??? ??? ?ch.pipeline().addLast(new DiscardServerHandler());
?? ??? ??? ??? ?};
?? ??? ??? ?})
?? ??? ??? ?//對Channel進行一些配置
?? ??? ??? ?//注意以下是socket的標準參數
?? ??? ??? ?//BACKLOG用于構造服務端套接字ServerSocket對象，標識當服務器請求處理線程全滿時，用于臨時存放已完成三次握手的請求的隊列的最大長度。如果未設置或所設置的值小于1，Java將使用默認值50。
?? ??? ??? ?//Option是為了NioServerSocketChannel設置的，用來接收傳入連接的
?? ??? ??? ?.option(ChannelOption.SO_BACKLOG, 128)
?? ??? ??? ?//是否啟用心跳保活機制。在雙方TCP套接字建立連接后（即都進入ESTABLISHED狀態）并且在兩個小時左右上層沒有任何數據傳輸的情況下，這套機制才會被激活。
?? ??? ??? ?//childOption是用來給父級ServerChannel之下的Channels設置參數的
?? ??? ??? ?.childOption(ChannelOption.SO_KEEPALIVE, true);
?? ??? ??? ?// Bind and start to accept incoming connections.
?? ??? ??? ?ChannelFuture f=b.bind(port).sync();
?? ??? ??? ?// Wait until the server socket is closed.
? ? ? ? ? ? // In this example, this does not happen, but you can do that to gracefully
? ? ? ? ? ? // shut down your server.
?? ??? ??? ?//sync()會同步等待連接操作結果，用戶線程將在此wait()，直到連接操作完成之后，線程被notify(),用戶代碼繼續執行
?? ??? ??? ?//closeFuture()當Channel關閉時返回一個ChannelFuture,用于鏈路檢測
? ? ? ? ? ? f.channel().closeFuture().sync();
?? ??? ?}finally{
?? ??? ??? ?//資源優雅釋放
?? ??? ??? ?bossGroup.shutdownGracefully();
?? ??? ??? ?workerGroup.shutdownGracefully();
?? ??? ?}
?? ?}
?? ?
?? ?public static void main(String[] args) {
?? ??? ?int port=8088;
?? ??? ?try {
?? ??? ??? ?new DiscardServer(port).run();
?? ??? ?} catch (Exception e) {
?? ??? ??? ?// TODO Auto-generated catch block
?? ??? ??? ?e.printStackTrace();
?? ??? ?}
?? ?}
}
里面的具體的類在注釋當中進行了說明這里就不在一個一個羅列了，目前也是在初步學習階段，所以如果有不對的也希望大神指正。
三.測試
打開Window的命令行，輸入telnet命令:telnet localhost 8088,如果能夠正確連接就代表成功，在新打開的命令窗口隨意輸入字符，如果在myeclipse當中能夠正確輸出在console當中，就代表程序正常。

四.ECHO協議的DEMO
ECHO協議，定義了客戶端請求啥就返回啥

第一步編寫EchoServerHandler:

package io.netty.example.echo;
?
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
?
/**
?* @作者:CJY
?* @說明:這個是用來實現ECHO協議，這個協議的作用就是將客戶端輸入的信息全部返回
?* @時間:2017-4-8下午12:07:50
?*/
public class EchoServerHandler extends ChannelInboundHandlerAdapter {
?? ?/*?
?? ? * @作者:CJY
?? ? * @說明:該方法用于接收從客戶端接收的信息
?? ? * @時間:2017-4-8下午12:08:51
?? ? * @see io.netty.channel.ChannelInboundHandlerAdapter#channelRead(io.netty.channel.ChannelHandlerContext, java.lang.Object)
?? ? * @param ctx
?? ? * @param msg
?? ? * @throws Exception
?? ? */
?? ?@Override
?? ?public void channelRead(ChannelHandlerContext ctx, Object msg)
?? ??? ??? ?throws Exception {
?? ??? ?//ChannelHandlerContext提供各種不同的操作用于觸發不同的I/O時間和操作
?? ??? ?//調用write方法來逐字返回接收到的信息
?? ??? ?//這里我們不需要在DISCARD例子當中那樣調用釋放，因為Netty會在寫的時候自動釋放
?? ??? ?//只調用write是不會釋放的，它會緩存，直到調用flush
?? ??? ?ctx.write(msg);
?? ??? ?ctx.flush();
?? ??? ?//你可以直接使用writeAndFlush(msg)
?? ??? ?//ctx.writeAndFlush(msg);
?? ?}
?? ?
?? ?@Override
?? ?public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)
?? ??? ??? ?throws Exception {
?? ??? ?cause.printStackTrace();
?? ??? ?ctx.close();
?? ?}
}

第二步編寫EchoServer:
package io.netty.example.echo;
?
import io.netty.bootstrap.ServerBootstrap;
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.NioServerSocketChannel;
?
public class EchoServer {
?? ?private int port;
?? ?public EchoServer(int port){
?? ??? ?this.port = port;
?? ?}
?? ?
?? ?public void run() throws Exception{
?? ??? ?//NioEventLoopGroup是一個處理I/O操作的多線程事件循環
?? ??? ?//bossGroup作為boss,接收傳入連接
?? ??? ?//bossGroup只負責接收客戶端的連接，不做復雜操作，為了減少資源占用，取值越小越好
?? ??? ?//Group：群組，Loop：循環，Event：事件，這幾個東西聯在一起，相比大家也大概明白它的用途了。
?? ??? ?//Netty內部都是通過線程在處理各種數據，EventLoopGroup就是用來管理調度他們的，注冊Channel，管理他們的生命周期。
?? ??? ?EventLoopGroup bossGroup=new NioEventLoopGroup(1);
?? ??? ?//workerGroup作為worker，處理boss接收的連接的流量和將接收的連接注冊進入這個worker
?? ??? ?EventLoopGroup workerGroup=new NioEventLoopGroup();
?? ??? ?try {
?? ??? ??? ?//ServerBootstrap負責建立服務端
?? ??? ??? ?//你可以直接使用Channel去建立服務端，但是大多數情況下你無需做這種乏味的事情
?? ??? ??? ?ServerBootstrap b=new ServerBootstrap();
?? ??? ??? ?b.group(bossGroup, workerGroup)
?? ??? ??? ?//指定使用NioServerSocketChannel產生一個Channel用來接收連接
?? ??? ??? ?.channel(NioServerSocketChannel.class)
?? ??? ??? ?//ChannelInitializer用于配置一個新的Channel
?? ??? ??? ?//用于向你的Channel當中添加ChannelInboundHandler的實現
?? ??? ??? ?.childHandler(new ChannelInitializer<SocketChannel>() {
?? ??? ??? ??? ?public void initChannel(SocketChannel ch) throws Exception {
?? ??? ??? ??? ??? ?ch.pipeline().addLast(new EchoServerHandler());
?? ??? ??? ??? ?};
?? ??? ??? ?})
?? ??? ??? ?//對Channel進行一些配置
?? ??? ??? ?//注意以下是socket的標準參數
?? ??? ??? ?//BACKLOG用于構造服務端套接字ServerSocket對象，標識當服務器請求處理線程全滿時，用于臨時存放已完成三次握手的請求的隊列的最大長度。如果未設置或所設置的值小于1，Java將使用默認值50。
?? ??? ??? ?//Option是為了NioServerSocketChannel設置的，用來接收傳入連接的
?? ??? ??? ?.option(ChannelOption.SO_BACKLOG, 128)
?? ??? ??? ?//是否啟用心跳保活機制。在雙方TCP套接字建立連接后（即都進入ESTABLISHED狀態）并且在兩個小時左右上層沒有任何數據傳輸的情況下，這套機制才會被激活。
?? ??? ??? ?//childOption是用來給父級ServerChannel之下的Channels設置參數的
?? ??? ??? ?.childOption(ChannelOption.SO_KEEPALIVE, true);
?? ??? ??? ?// Bind and start to accept incoming connections.
?? ??? ??? ?ChannelFuture f=b.bind(port).sync();
?? ??? ??? ?// Wait until the server socket is closed.
? ? ? ? ? ? // In this example, this does not happen, but you can do that to gracefully
? ? ? ? ? ? // shut down your server.
?? ??? ??? ?//sync()會同步等待連接操作結果，用戶線程將在此wait()，直到連接操作完成之后，線程被notify(),用戶代碼繼續執行
?? ??? ??? ?//closeFuture()當Channel關閉時返回一個ChannelFuture,用于鏈路檢測
? ? ? ? ? ? f.channel().closeFuture().sync();
?? ??? ?}finally{
?? ??? ??? ?//資源優雅釋放
?? ??? ??? ?bossGroup.shutdownGracefully();
?? ??? ??? ?workerGroup.shutdownGracefully();
?? ??? ?}
?? ?}
?? ?
?? ?public static void main(String[] args) {
?? ??? ?int port=8088;
?? ??? ?try {
?? ??? ??? ?new EchoServer(port).run();
?? ??? ?} catch (Exception e) {
?? ??? ??? ?// TODO Auto-generated catch block
?? ??? ??? ?e.printStackTrace();
?? ??? ?}
?? ?}
}

測試如上
---------------------?
作者：wocjy?
來源：CSDN?
原文：https://blog.csdn.net/wocjy/article/details/78661464?
版權聲明：本文為博主原創文章，轉載請附上博文鏈接！

總結

以上是生活随笔為你收集整理的Netty入门官方例子的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。