為什麼要學習netty

    當你寫了一段時間的客戶端以後你會發現除非你想寫opengl或者提別的複雜的圖形演算法，否則你不得不承認你只會寫一些邏輯的顯示，至於那些現在流行的，高併發，大資料，人工智慧就會越來越遠，於是我準備學習高併發的相關知識，順便也可以總結一下以前學習的c的linux網路程式設計的一些基礎知識。參考書（netty實戰）

第一天學習的程式碼

    我這裡的程式碼是jdk1.8

    使用工具Eclipse

    使用的netty-all-4.0.56.Final 這個版本

主類Hello_Server

package demo1;

import io.netty.bootstrap.ServerBootstrap;//伺服器執行緒
import io.netty.channel.ChannelFuture;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;

public class Hello_Server {
	private static final int portNumber = 7878;//埠
	public static void main(String[] args) throws InterruptedException{
		// TODO Auto-generated method stub
		EventLoopGroup bossGroup = new NioEventLoopGroup();//主執行緒
		EventLoopGroup workGroup = new NioEventLoopGroup();//工作執行緒
		try
		{
			System.out.print("伺服器已經啟動");
			ServerBootstrap b = new ServerBootstrap();
			b.group(bossGroup,workGroup);//裝入執行緒
			b.channel(NioServerSocketChannel.class);//制定Nio傳輸
			b.childHandler(new HelloServerInitializer());//新增到子channel的ChannelPipeline裡面
			ChannelFuture f = b.bind(portNumber).sync();//繫結埠
			
			f.channel().closeFuture().sync();//關閉
		}
		finally {
			bossGroup.shutdownGracefully();//關閉執行緒
			workGroup.shutdownGracefully();
		}
	}
}
 

對應的pipeline繫結事件類

HelloServerInitializer.java

package demo1;

import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.DelimiterBasedFrameDecoder;
import io.netty.handler.codec.Delimiters;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;

public class HelloServerInitializer extends ChannelInitializer<SocketChannel> {
	//初始化對的一些操作
	@Override
	protected void initChannel(SocketChannel ch) throws Exception
	{
		ChannelPipeline pipeline = ch.pipeline();//獲得連線
		//解析方式以\n作為標記
		pipeline.addLast("framer",new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter()));
		pipeline.addLast("decoder",new StringDecoder());
		pipeline.addLast("encode",new StringEncoder());
		//自己的邏輯
		pipeline.addLast("handler",new HelloServerHandler());
	}
}
 

處理我自己邏輯的類

HelloServerHandler.java

package demo1;

import java.net.InetAddress;

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;

public class HelloServerHandler extends SimpleChannelInboundHandler<String> {
	//收到資料
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, String msg)
            throws Exception {
        //ChannelHandlerContext 返回事件的物件
        // 收到訊息直接列印輸出
        System.out.println(ctx.channel().remoteAddress() + " Say : " + msg);

        // 返回客戶端訊息 - 我已經接收到了你的訊息
        ctx.writeAndFlush("Received your message !");
    }
    
    
    /*
     * 如果連線錯誤事件
     */
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
    	// TODO Auto-generated method stub
    	cause.printStackTrace();
    	ctx.close();
    }
    

    /*
     * 覆蓋 channelActive 方法 在channel被啟用的時候觸發 (在建立連線的時候)
     * channelActive 和 channelInActive 在後面的內容中講述，這裡先不做詳細的描述
     */
    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        System.out.println("RamoteAddress : " + ctx.channel().remoteAddress()
                + " active !");
        ctx.writeAndFlush("Welcome to "
                + InetAddress.getLocalHost().getHostName() + " service!\n");
        super.channelActive(ctx);
    }
}
 

使用dos命令telnet 127.0.0.1 7878來做連線測試如果成功如圖所示

這說明我的初級伺服器已經連線成功！當然還有不完善的地方比如不能傳送中文。