Netty入门（一）：零基础“HelloWorld”详细图文步骤

时间  2019-11-13
标签 netty 入门 零基础 helloworld 详细 图文 步骤 栏目 Netty 繁體版
原文   原文链接

由于接下来的项目要用到netty,因此就了解一下这个程序，奈何网上的教程都是稍微有点基础的，因此，就写一篇对于netty零基础的，顺便也记录一下。html

 

先扔几个参考学习的网页： java

netty 官方API： http://netty.io/4.1/api/index.htmlapache

netty 中文指南：https://waylau.com/netty-4-user-guide/   （来自我的）bootstrap

 

关于NIO基础的知识：https://my.oschina.net/andylucc/blog/614295windows

　　　　　　　　　   http://www.cnblogs.com/dolphin0520/p/3919162.html　api

　　　　　　　　　　http://blog.csdn.net/wuxianglong/article/details/6604817  浏览器

我这里所使用的：服务器

netty版本：netty-5.0.0.Alpha2 http://files.cnblogs.com/files/applerosa/netty-5.0.0.Alpha2.7z网络

maven依赖：多线程

<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
    <version>5.0.0.Alpha2</version>
</dependency>

 

 

好了，咱们开始。

1、首先，你要创建一个java工程，至于普通工程仍是maven工程，看本身喜爱，由于我这里只是作为学习，就建了一个普通工程，而后把下载的jar包扔到lib中，引入便可。

　　

2、接下来咱们要搞清楚，netty是什么玩意。

　　官方那个给出的介绍是：Netty是由JBOSS提供的一个java开源框架。Netty提供异步的、事件驱动的网络应用程序框架和工具，用以快速开发高性能、高可靠性的网络服务器和客户端程序。

　　而后咱们简单理解一下，这玩意就是个程序，干什么的？netty是封装java socket noi的。 相似的功能是 apache的mina。

　　相对于Tomcat这种Web Server（顾名思义主要是提供Web协议相关的服务的），Netty是一个Network Server，是处于Web Server更下层的网络框架，也就是说你可使用Netty模仿Tomcat作一个提供HTTP服务的Web容器。

　　

　　说白了，就是一个好使的处理Socket的东西。要是想了解详细点，能够去看看官方的介绍。

　　

3、回到正题咱们开始写所谓的“Hello World"

　　这里插一下，就是咱们的的通讯是创建在必定的协议之上的，就好比咱们经常使用的Web工程，前台（浏览器）发送一个请求，后台作出相应返回相应的结果，这个通讯的过程亦是如此。

　　在netty官方指南里面有讲，世上最简单的协议不是'Hello, World!' 而是 DISCARD(抛弃服务)。这个协议将会抛弃任何收到的数据，而不响应。就是你客户端发送消息，好，发送过去了，服务器也收到了，可是抛弃了。

　　说白了，就是你发一条消息给我，我收到了，可是我直接就把消息抛弃了，不理你的。

 　　

其次，关于netty ，首先要搞清楚，这是创建在客户端和服务端之间的。

 

 

 

咱们先说服务端，服务端创建相应的规则，而后运行起来，等待客户端访问或者发送”消息“。好了，咱们先创建服务端代码：

 

第一步：先创建相应的规则：

package _01discard;

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerAdapter;
import io.netty.channel.ChannelHandlerContext;
import io.netty.util.CharsetUtil;
import io.netty.util.ReferenceCountUtil;

/**
 * 服务端处理通道.这里只是打印一下请求的内容，并不对请求进行任何的响应 DiscardServerHandler 继承自
 * ChannelHandlerAdapter， 这个类实现了ChannelHandler接口， ChannelHandler提供了许多事件处理的接口方法，
 * 而后你能够覆盖这些方法。 如今仅仅只须要继承ChannelHandlerAdapter类而不是你本身去实现接口方法。
 *
 */
public class DiscardServerHandler extends ChannelHandlerAdapter {
    /**
     * 这里咱们覆盖了chanelRead()事件处理方法。 每当从客户端收到新的数据时， 这个方法会在收到消息时被调用，
     * 这个例子中，收到的消息的类型是ByteBuf
     * 
     * @param ctx
     *            通道处理的上下文信息
     * @param msg
     *            接收的消息
     */
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) {

        try {
            ByteBuf in = (ByteBuf) msg;
            // 打印客户端输入，传输过来的的字符
            System.out.print(in.toString(CharsetUtil.UTF_8));
        } finally {
            /**
             * ByteBuf是一个引用计数对象，这个对象必须显示地调用release()方法来释放。
             * 请记住处理器的职责是释放全部传递处处理器的引用计数对象。
             */
            // 抛弃收到的数据
            ReferenceCountUtil.release(msg);
        }

    }

    /***
     * 这个方法会在发生异常时触发
     * 
     * @param ctx
     * @param cause
     */
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        /**
         * exceptionCaught() 事件处理方法是当出现 Throwable 对象才会被调用，即当 Netty 因为 IO
         * 错误或者处理器在处理事件时抛出的异常时。在大部分状况下，捕获的异常应该被记录下来 而且把关联的 channel
         * 给关闭掉。然而这个方法的处理方式会在遇到不一样异常的状况下有不 同的实现，好比你可能想在关闭链接以前发送一个错误码的响应消息。
         */
        // 出现异常就关闭
        cause.printStackTrace();
        ctx.close();
    }

}

第二步：咱们须要应用相应的规则。就是说，咱们创建了接收消息的规则，可是光创建规则有什么用，仅仅只是一个规则，咱们须要把这个规则”应用“起来，一般就是咱们一般的”运行“。

package _01discard;

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;

/**
 * 丢弃任何进入的数据 启动服务端的DiscardServerHandler
 */
public class DiscardServer {
    private int port;

    public DiscardServer(int port) {
        super();
        this.port = port;
    }

    public void run() throws Exception {

        /***
         * NioEventLoopGroup 是用来处理I/O操做的多线程事件循环器，
         * Netty提供了许多不一样的EventLoopGroup的实现用来处理不一样传输协议。 在这个例子中咱们实现了一个服务端的应用，
         * 所以会有2个NioEventLoopGroup会被使用。 第一个常常被叫作‘boss’，用来接收进来的链接。
         * 第二个常常被叫作‘worker’，用来处理已经被接收的链接， 一旦‘boss’接收到链接，就会把链接信息注册到‘worker’上。
         * 如何知道多少个线程已经被使用，如何映射到已经建立的Channels上都须要依赖于EventLoopGroup的实现，
         * 而且能够经过构造函数来配置他们的关系。
         */
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        System.out.println("准备运行端口：" + port);
        try {
            /**
             * ServerBootstrap 是一个启动NIO服务的辅助启动类 你能够在这个服务中直接使用Channel
             */
            ServerBootstrap b = new ServerBootstrap();
            /**
             * 这一步是必须的，若是没有设置group将会报java.lang.IllegalStateException: group not
             * set异常
             */
            b = b.group(bossGroup, workerGroup);
            /***
             * ServerSocketChannel以NIO的selector为基础进行实现的，用来接收新的链接
             * 这里告诉Channel如何获取新的链接.
             */
            b = b.channel(NioServerSocketChannel.class);
            /***
             * 这里的事件处理类常常会被用来处理一个最近的已经接收的Channel。 ChannelInitializer是一个特殊的处理类，
             * 他的目的是帮助使用者配置一个新的Channel。
             * 也许你想经过增长一些处理类好比NettyServerHandler来配置一个新的Channel
             * 或者其对应的ChannelPipeline来实现你的网络程序。 当你的程序变的复杂时，可能你会增长更多的处理类到pipline上，
             * 而后提取这些匿名类到最顶层的类上。
             */
            b = b.childHandler(new ChannelInitializer<SocketChannel>() { // (4)
                @Override
                public void initChannel(SocketChannel ch) throws Exception {
                    ch.pipeline().addLast(new DiscardServerHandler());// demo1.discard
                    // ch.pipeline().addLast(new
                    // ResponseServerHandler());//demo2.echo
                    // ch.pipeline().addLast(new
                    // TimeServerHandler());//demo3.time
                }
            });
            /***
             * 你能够设置这里指定的通道实现的配置参数。 咱们正在写一个TCP/IP的服务端，
             * 所以咱们被容许设置socket的参数选项好比tcpNoDelay和keepAlive。
             * 请参考ChannelOption和详细的ChannelConfig实现的接口文档以此能够对ChannelOptions的有一个大概的认识。
             */
            b = b.option(ChannelOption.SO_BACKLOG, 128);
            /***
             * option()是提供给NioServerSocketChannel用来接收进来的链接。
             * childOption()是提供给由父管道ServerChannel接收到的链接，
             * 在这个例子中也是NioServerSocketChannel。
             */
            b = b.childOption(ChannelOption.SO_KEEPALIVE, true);
            /***
             * 绑定端口并启动去接收进来的链接
             */
            ChannelFuture f = b.bind(port).sync();
            /**
             * 这里会一直等待，直到socket被关闭
             */
            f.channel().closeFuture().sync();
        } finally {
            /***
             * 关闭
             */
            workerGroup.shutdownGracefully();
            bossGroup.shutdownGracefully();
        }
    }
　　

　　 //将规则跑起来 public static void main(String[] args) throws Exception {
        int port;
        if (args.length > 0) {
            port = Integer.parseInt(args[0]);
        } else {
            port = 8080;
        }
        new DiscardServer(port).run();
        System.out.println("server:run()");
    }
}

 

第三步：咱们如今相应的规则已经创建，而且”运行“规则的代码也OK，因此运行上面的   public static void main(String[] args) 启动服务端。

　　

此时服务端已经运行起来了，为等待访问的状态。

 

 

客户端

由于这是一个简单的demo,因此咱们使用telnet 来充当client使用。固然，项目中确定是根据需求来定制的。

首先打开终端，我这里是windows 系统，就以此为例，打开cmd 窗口；

　　

　　键入  telnet 127.0.0.1 8080 回车，进入telnet 终端

　　

 

　　这里补充一下，win系统默认是不开启telnet 客户端的，须要的朋友去控制面板>>程序>>打开或者关闭windows功能里面 勾选上，以下图

　　

 

 

好了，到了telnet 客户端这一步，就能够测试消息了

补充，默认的telnet 客户端输入是不显示的，不过反正输入以后控制台有输出就表示你这个过程跑通了。如：

 

 你也在终端使用 ctrl+] 来显示，如：

 

 

 

走到这里，整个过程大概是什么样子的，内心就有个数了，而后就和学习普通框架同样，开始的进阶之路吧。

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程