分享web开发知识

注册/登录|最近发布|今日推荐

主页 IT知识网页技术软件开发前端开发代码编程运营维护技术分享教程案例
当前位置：首页 > 教程案例

netty参考

发布时间：2023-09-06 01:24责任编辑：赖小花关键词：暂无标签

前言

问题

现如今我们使用通用的应用程序或者类库来实现系统之间地互相访问，比如我们经常使用一个HTTP客户端来从web服务器上获取信息，或者通过web service来执行一个远程的调用。

然而，有时候一个通用的协议和他的实现并没有覆盖一些场景。比如我们无法使用一个通用的HTTP服务器来处理大文件、电子邮件、近实时消息比如财务信息和多人游戏数据。我们需要一个合适的协议来处理一些特殊的场景。例如你可以实现一个优化的Ajax的聊天应用、媒体流传输或者是大文件传输的HTTP服务器，你甚至可以自己设计和实现一个新的协议来准确地实现你的需求。

另外不可避免的事情是你不得不处理这些私有协议来确保和原有系统的互通。这个例子将会展示如何快速实现一个不影响应用程序稳定性和性能的协议。

解决方案

Netty是一个提供异步事件驱动的网络应用框架，用以快速开发高性能、高可靠性的网络服务器和客户端程序。

换句话说，Netty是一个NIO框架，使用它可以简单快速地开发网络应用程序，比如客户端和服务端的协议。Netty大大简化了网络程序的开发过程比如TCP和UDP的 Socket的开发。

“快速和简单”并不意味着应用程序会有难维护和性能低的问题，Netty是一个精心设计的框架，它从许多协议的实现中吸收了很多的经验比如FTP、SMTP、HTTP、许多二进制和基于文本的传统协议，Netty在不降低开发效率、性能、稳定性、灵活性情况下，成功地找到了解决方案。

有一些用户可能已经发现其他的一些网络框架也声称自己有同样的优势，所以你可能会问是Netty和它们的不同之处。答案就是Netty的哲学设计理念。Netty从第一天开始就为用户提供了用户体验最好的API以及实现设计。正是因为Netty的设计理念，才让我们得以轻松地阅读本指南并使用Netty。

入门指南

这个章节会介绍Netty核心的结构，并通过一些简单的例子来帮助你快速入门。当你读完本章节你马上就可以用Netty写出一个客户端和服务端。

如果你在学习的时候喜欢“自顶向下（top-down）”的方法，那你可能需要要从第二章《架构概述》开始，然后再回到这里。

开始之前

运行本章节中的两个例子最低要求是：Netty的最新版本(Netty5)和JDK1.6及以上。最新的Netty版本在项目下载页面可以找到。为了下载到正确的JDK版本，请到你喜欢的网站下载。

阅读本章节过程中，你可能会对相关类有疑惑，关于这些类的详细的信息请请参考API说明文档。为了方便，所有文档中涉及到的类名字都会被关联到一个在线的API说明。当然如果有任何错误信息、语法错误或者你有任何好的建议来改进文档说明，那么请联系Netty社区。

DISCARD服务(丢弃服务，指的是会忽略所有接收的数据的一种协议)

世界上最简单的协议不是”Hello,World!”，是DISCARD，他是一种丢弃了所有接受到的数据，并不做有任何的响应的协议。

为了实现DISCARD协议，你唯一需要做的就是忽略所有收到的数据。让我们从处理器的实现开始，处理器是由Netty生成用来处理I/O事件的。

01packageio.netty.example.discard;
02
03importio.netty.buffer.ByteBuf;
04
05importio.netty.channel.ChannelHandlerContext;
06importio.netty.channel.ChannelHandlerAdapter;
07
08/**
09* Handles a server-side channel.
10*/
11publicclassDiscardServerHandlerextendsChannelHandlerAdapter {// (1)
12
13@Override
14publicvoidchannelRead(ChannelHandlerContext ctx, Object msg) {// (2)
15// Discard the received data silently.
16((ByteBuf) msg).release();// (3)
17}
18
19@Override
20publicvoidexceptionCaught(ChannelHandlerContext ctx, Throwable cause) {// (4)
21// Close the connection when an exception is raised.
22cause.printStackTrace();
23ctx.close();
24}
25}
  1. DisCardServerHandler 继承自ChannelHandlerAdapter，这个类实现了ChannelHandler接口，ChannelHandler提供了许多事件处理的接口方法，然后你可以覆盖这些方法。现在仅仅只需要继承ChannelHandlerAdapter类而不是你自己去实现接口方法。
  2. 这里我们覆盖了chanelRead()事件处理方法。每当从客户端收到新的数据时，这个方法会在收到消息时被调用，这个例子中，收到的消息的类型是ByteBuf
  3. 为了实现DISCARD协议，处理器不得不忽略所有接受到的消息。ByteBuf是一个引用计数对象，这个对象必须显示地调用release()方法来释放。请记住处理器的职责是释放所有传递到处理器的引用计数对象。通常，channelRead()方法的实现就像下面的这段代码：
    1@Override
    2publicvoidchannelRead(ChannelHandlerContext ctx, Object msg) {
    3try{
    4// Do something with msg
    5}finally{
    6ReferenceCountUtil.release(msg);
    7}
    8}
  4. exceptionCaught()事件处理方法是当出现Throwable对象才会被调用，即当Netty由于IO错误或者处理器在处理事件时抛出的异常时。在大部分情况下，捕获的异常应该被记录下来并且把关联的channel给关闭掉。然而这个方法的处理方式会在遇到不同异常的情况下有不同的实现，比如你可能想在关闭连接之前发送一个错误码的响应消息。

到目前为止一切都还比较顺利，我们已经实现了DISCARD服务的一半功能，剩下的需要编写一个main()方法来启动服务端的DiscardServerHandler。

01packageio.netty.example.discard;
02
03importio.netty.bootstrap.ServerBootstrap;
04
05importio.netty.channel.ChannelFuture;
06importio.netty.channel.ChannelInitializer;
07importio.netty.channel.ChannelOption;
08importio.netty.channel.EventLoopGroup;
09importio.netty.channel.nio.NioEventLoopGroup;
10importio.netty.channel.socket.SocketChannel;
11importio.netty.channel.socket.nio.NioServerSocketChannel;
12
13/**
14* Discards any incoming data.
15*/
16publicclassDiscardServer {
17
18privateintport;
19
20publicDiscardServer(intport) {
21this.port = port;
22}
23
24publicvoidrun()throwsException {
25EventLoopGroup bossGroup =newNioEventLoopGroup();// (1)
26EventLoopGroup workerGroup =newNioEventLoopGroup();
27try{
28ServerBootstrap b =newServerBootstrap();// (2)
29b.group(bossGroup, workerGroup)
30.channel(NioServerSocketChannel.class)// (3)
31.childHandler(newChannelInitializer<SocketChannel>() {// (4)
32@Override
33publicvoidinitChannel(SocketChannel ch)throwsException {
34ch.pipeline().addLast(newDiscardServerHandler());
35}
36})
37.option(ChannelOption.SO_BACKLOG,128)// (5)
38.childOption(ChannelOption.SO_KEEPALIVE,true);// (6)
39
40// Bind and start to accept incoming connections.
41ChannelFuture f = b.bind(port).sync();// (7)
42
43// Wait until the server socket is closed.
44// In this example, this does not happen, but you can do that to gracefully
45// shut down your server.
46f.channel().closeFuture().sync();
47}finally{
48workerGroup.shutdownGracefully();
49bossGroup.shutdownGracefully();
50}
51}
52
53publicstaticvoidmain(String[] args)throwsException {
54intport;
55if(args.length >0) {
56port = Integer.parseInt(args[0]);
57}else{
58port =8080;
59}
60newDiscardServer(port).run();
61}
62}
  1. NioEventLoopGroup是用来处理I/O操作的多线程事件循环器，Netty提供了许多不同的EventLoopGroup的实现用来处理不同传输协议。在这个例子中我们实现了一个服务端的应用，因此会有2个NioEventLoopGroup会被使用。第一个经常被叫做‘boss’，用来接收进来的连接。第二个经常被叫做‘worker’，用来处理已经被接收的连接，一旦‘boss’接收到连接，就会把连接信息注册到‘worker’上。如何知道多少个线程已经被使用，如何映射到已经创建的Channels上都需要依赖于EventLoopGroup的实现，并且可以通过构造函数来配置他们的关系。
  2. ServerBootstrap是一个启动NIO服务的辅助启动类。你可以在这个服务中直接使用Channel，但是这会是一个复杂的处理过程，在很多情况下你并不需要这样做。
  3. 这里我们指定使用NioServerSocketChannel类来举例说明一个新的Channel如何接收进来的连接。
  4. 这里的事件处理类经常会被用来处理一个最近的已经接收的Channel。ChannelInitializer是一个特殊的处理类，他的目的是帮助使用者配置一个新的Channel。也许你想通过增加一些处理类比如DiscardServerHandle来配置一个新的Channel或者其对应的ChannelPipeline来实现你的网络程序。当你的程序变的复杂时，可能你会增加更多的处理类到pipline上，然后提取这些匿名类到最顶层的类上。
  5. 你可以设置这里指定的通道实现的配置参数。我们正在写一个TCP/IP的服务端，因此我们被允许设置socket的参数选项比如tcpNoDelay和keepAlive。请参考ChannelOption和详细的ChannelConfig实现的接口文档以此可以对ChannelOptions的有一个大概的认识。
  6. 你关注过option()和childOption()吗？option()是提供给NioServerSocketChannel用来接收进来的连接。childOption()是提供给由父管道ServerChannel接收到的连接，在这个例子中也是NioServerSocketChannel。
  7. 我们继续，剩下的就是绑定端口然后启动服务。这里我们在机器上绑定了机器所有网卡上的8080端口。当然现在你可以多次调用bind()方法(基于不同绑定地址)。

恭喜！你已经完成熟练地完成了第一个基于Netty的服务端程序。

观察接收到的数据

现在我们已经编写出我们第一个服务端，我们需要测试一下他是否真的可以运行。最简单的测试方法是用telnet 命令。例如，你可以在命令行上输入telnet localhost 8080或者其他类型参数。

然而我们能说这个服务端是正常运行了吗？事实上我们也不知道因为他是一个discard服务，你根本不可能得到任何的响应。为了证明他仍然是在工作的，让我们修改服务端的程序来打印出他到底接收到了什么。

我们已经知道channelRead()方法是在数据被接收的时候调用。让我们放一些代码到DiscardServerHandler类的channelRead()方法。

01@Override
02publicvoidchannelRead(ChannelHandlerContext ctx, Object msg) {
03ByteBuf in = (ByteBuf) msg;
04try{
05while(in.isReadable()) {// (1)
06System.out.print((char) in.readByte());
07System.out.flush();
08}
09}finally{
10ReferenceCountUtil.release(msg);// (2)
11}
12}
  1. 这个低效的循环事实上可以简化为:System.out.println(in.toString(io.netty.util.CharsetUtil.US_ASCII))
  2. 或者，你可以在这里调用in.release()。

如果你再次运行telnet命令，你将会看到服务端打印出了他所接收到的消息。
完整的discard server代码放在了io.netty.example.discard包下面。

ECHO服务（响应式协议）

到目前为止，我们虽然接收到了数据，但没有做任何的响应。然而一个服务端通常会对一个请求作出响应。让我们学习怎样在ECHO协议的实现下编写一个响应消息给客户端，这个协议针对任何接收的数据都会返回一个响应。

和discard server唯一不同的是把在此之前我们实现的channelRead()方法，返回所有的数据替代打印接收数据到控制台上的逻辑。因此，需要把channelRead()方法修改如下：

1@Override
2pu

知识推荐

我的编程学习网——分享web前端后端开发技术知识。 垃圾信息处理邮箱 tousu563@163.com 网站地图
icp备案号 闽ICP备2023006418号-8 不良信息举报平台 互联网安全管理备案 Copyright 2023 www.wodecom.cn All Rights Reserved