Netty簡單的入門代碼示例

更新時間：2023年12月21日 10:34:30 作者：Colins~

這篇文章主要介紹了Netty簡單的入門代碼示例,Netty 的內部實現(xiàn)是很復雜的,但是 Netty 提供了簡單易用的API從網(wǎng)絡處理代碼中解耦業(yè)務邏輯,Netty 是完全基于 NIO 實現(xiàn)的,所以整個 Netty 都是異步的,需要的朋友可以參考下

前言

純Java幾種網(wǎng)絡IO的開發(fā)步驟及示例，毫無疑問最好的就是NIO，這也是目前最主流的方式，但是這玩意編寫復雜，拓展性也不強，在通信上方方面面都需要重寫，這不是一般人能搞得定了，所以呀我們得會用框架呀，Netty就是這方面框架中的佼佼者！

基礎示例入門

服務端

NettyServer.class

@Slf4j
public class NettyServer{
    //1.創(chuàng)建線程組  bossGroup：連接線程   workGroup：工作線程
    private final NioEventLoopGroup bossGroup = new NioEventLoopGroup();
    private final NioEventLoopGroup workerGroup = new NioEventLoopGroup();
    public void serverStart() throws InterruptedException {
        try{
            // 服務端啟動類
            ServerBootstrap bootstrap = new ServerBootstrap();
            // 傳入兩個線程組
            bootstrap.group(bossGroup, workerGroup)
                    // 指定Channel 和NIO一樣是采用Channel通道的方式通信 所以需要指定服務端通道
                    .channel(NioServerSocketChannel.class)
                    //使用指定的端口設置套接字地址
                    .localAddress(new InetSocketAddress(11111))
                    //服務端可連接隊列數(shù),對應TCP/IP協(xié)議listen函數(shù)中backlog參數(shù)
                    .option(ChannelOption.SO_BACKLOG, 1024)
                    //設置數(shù)據(jù)處理器
                    .childHandler(new ChannelInitializer<Channel>() {
                        @Override
                        protected void initChannel(Channel channel) throws Exception {
                            // 在管道中 添加數(shù)據(jù)處理類
                            channel.pipeline().addLast(new NettyServerTestHandler());
                        }
                    });
            // 同步等待成功
            ChannelFuture future = bootstrap.bind().sync();
            if (future.isSuccess()) {
                log.info("啟動 Netty Server 成功");
            }
            //等待服務端監(jiān)聽端口關閉 鏈路關閉后main函數(shù)才會結束
            future.channel().closeFuture().sync();
        }finally {
            // 優(yōu)雅的關閉 釋放資源
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }
    public static void main(String[] args) throws InterruptedException {
        new NettyServer().serverStart();
    }
}

看上去好多，感覺比NIO還麻煩？其實很方便的：

實例化一個服務端 ServerBootstrap ，這個NIO也一樣，Netty幫我們封裝了
設置兩個線程組，一個處理客戶端連接事件，一個處理連接后數(shù)據(jù)處理事件
指定服務端通道類型，并綁定地址
設置傳輸?shù)囊恍┡渲脜?shù)(這里有很多可以設置，所以拓展性強)
設置數(shù)據(jù)處理器，這里實際是添加了一個數(shù)據(jù)處理管道，管道內可以有很多數(shù)據(jù)處理類，所以可以一層一層處理，可插拔式設計(類似攔截器鏈)

channel.pipeline() : 這就是管道
new NettyServerTestHandler() : 這個就是管道里的一個數(shù)據(jù)處理類
// 數(shù)據(jù)處理類可以有多個

最后啟動

ServerBootstrap 實例化后，都是采用建造者模式設置的，對于我們來說是非常的方便的，這里配置好后我們的重心就可以放在數(shù)據(jù)處理類上了

NettyServerTestHandler.class

NettyServerTestHandler 就是數(shù)據(jù)處理類，所有的方法都幫我們封裝好了，我們不需要考慮其中調用的問題，方法是處理什么事件的，我們寫對應的邏輯就好了，方法上的ChannelHandlerContext 可以理解為管道中所有數(shù)據(jù)處理類的紐帶，比如攔截器鏈不也有么

@Slf4j
public class NettyServerTestHandler extends ChannelInboundHandlerAdapter {
    // 讀取信息調用
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        // 和NIO一樣有緩沖區(qū) ByteBuf就是對ByteBuffer做了一層封裝
        ByteBuf msg1 = (ByteBuf) msg;
        log.info("客戶端信息：" + msg1.toString(CharsetUtil.UTF_8));
    }
    // 連接事件 連接成功調用
    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        SocketAddress socketAddress = ctx.channel().remoteAddress();
        log.info(socketAddress + " 已連接");
        // 發(fā)送數(shù)據(jù)
        ctx.writeAndFlush(Unpooled.copiedBuffer("Hello Client", CharsetUtil.UTF_8));
    }
    // 斷開連接調用
    @Override
    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
        log.info(ctx.channel().remoteAddress() + " 已斷開連接");
    }
    // 讀取信息完成事件  信息讀取完成后調用
    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
    }
    // 異常處理  發(fā)生異常調用
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        // 異常后 關閉與客戶端連接
        ctx.close();
    }
}

客戶端

NettyClient.class

客戶端啟動和服務端幾乎一致，只不過啟動類成了Bootstrap ，而且我還加入了一個斷連邏輯

@Slf4j
public class NettyClient  {
    private EventLoopGroup group = new NioEventLoopGroup();
    private int port=11111;
    private String host="127.0.0.1";
    public void start() throws InterruptedException {
        try{
            Bootstrap bootstrap = new Bootstrap();
            // 客戶端不需要處理連接 所以一個線程組就夠了
            bootstrap.group(group)
                    // 連接通道
                    .channel(NioSocketChannel.class)
                    .remoteAddress(host, port)
                    .option(ChannelOption.TCP_NODELAY, true)
                    // 數(shù)據(jù)處理
                    .handler(new ChannelInitializer<Channel>() {
                        @Override
                        protected void initChannel(Channel channel) throws Exception {
                            channel.pipeline().addLast(new NettyClientTestHandler());
                        }
                    });
            ChannelFuture future = bootstrap.connect();
            //客戶端斷線重連邏輯
            future.addListener((ChannelFutureListener) future1 -> {
                if (future1.isSuccess()) {
                    log.info("連接Netty服務端成功");
                } else {
                    log.info("連接失敗，進行斷線重連");
                    future1.channel().eventLoop().schedule(() -> {
                        try {
                            start();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }, 20, TimeUnit.SECONDS);
                }
            });
            future.channel().closeFuture().sync();
        }catch (Exception e){
            log.info("服務端異常");
        }finally {
            group.shutdownGracefully();
        }
    }
    public static void main(String[] args) throws InterruptedException {
        new NettyClient().start();
    }
}

NettyClientTestHandler.class

數(shù)據(jù)處理類也是一樣的

@Slf4j
public class NettyClientTestHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        ByteBuf msg1 = (ByteBuf) msg;
        log.info("服務端信息：" + msg1.toString(CharsetUtil.UTF_8));
    }
    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        // 連接上 就給服務端發(fā)送數(shù)據(jù)
        ctx.writeAndFlush(Unpooled.copiedBuffer("Hello Server", CharsetUtil.UTF_8));
        SocketAddress socketAddress = ctx.channel().remoteAddress();
        log.info(socketAddress + " 已連接");
    }
    @Override
    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
        log.info(ctx.channel().remoteAddress() + " 已斷開連接");
    }
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        ctx.close();
    }
}

到此這篇關于Netty簡單的入門代碼示例的文章就介紹到這了,更多相關Netty入門代碼內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: