netty的自我学习(八)—Netty的异步模型(Future)以及Netty-HTTP服务实例

学习这件事,不在乎有没有人督促你,最重要的是在于你自己有没有觉悟和恒心。

温习中,会以笔记的形式记录下自我学习的过程.

文章部分图片来源于视频笔记!!非我自画!!

netty的自我学习(八)—Netty的异步模型(Future)以及Netty-HTTP服务实例

netty的自我学习(一)—BIONIOAIO的简单介绍

netty的自我学习(二)—初识NIO以及Buffer

netty的自我学习(三)—NIO的channel

netty的自我学习(四)—NIO的Selector(选择器)

netty的自我学习(五)—NIO之零拷贝

netty的自我学习(六)—Reactor模型以及Netty模型介绍

netty的自我学习(七)—Netty的简单入门案例

异步模型

  1. 表示异步的执行结果, 可以通过它提供的方法来检测执行是否完成,比如检索计算等等.

  2. ChannelFuture 是一个接口 : public interface ChannelFuture extends Future 我们可以添加监听器,当监听的事件发生时,就会通知到监听器。

netty的自我学习(八)—Netty的异步模型(Future)以及Netty-HTTP服务实例

在使用 Netty 进行编程时,拦截操作和转换出入站数据只需要您提供 callback 或利用future 即可。这使得链式操作简单、高效, 并有利于编写可重用的、通用的代码

netty的自我学习(八)—Netty的异步模型(Future)以及Netty-HTTP服务实例

Future-Listener 机制

  1. 当 Future 对象刚刚创建时,处于非完成状态,调用者可以通过返回的 ChannelFuture 来获取操作执行的状态,注册监听函数来执行完成后的操作。

  2. 常见有如下操作

    通过 isDone 方法来判断当前操作是否完成;
     
     通过 isSuccess 方法来判断已完成的当前操作是否成功;
     
     通过 getCause 方法来获取已完成的当前操作失败的原因;
     
     通过 isCancelled 方法来判断已完成的当前操作是否被取消;
     
     通过 addListener 方法来注册监听器,当操作已完成(isDone 方法返回完成),将会通知指定的监听器;如果 Future 对象已完成,则通知指定的监听器
    复制代码
//绑定一个端口并且同步, 生成了一个 ChannelFuture 对象
            //启动服务器(并绑定端口)
            ChannelFuture cf = bootstrap.bind(6668).sync();

            //给cf 注册监听器,监控我们关心的事件

            cf.addListener(new ChannelFutureListener() {
                @Override
                public void operationComplete(ChannelFuture future) throws Exception {
                    if (cf.isSuccess()) {
                        System.out.println("监听端口 6668 成功");
                    } else {
                        System.out.println("监听端口 6668 失败");
                    }
                }
            });
复制代码
netty的自我学习(八)—Netty的异步模型(Future)以及Netty-HTTP服务实例

小结

相比传统阻塞 I/O,执行 I/O 操作后线程会被阻塞住, 直到操作完成;异步处理的好处是不会造成线程阻塞,线程在 I/O 操作期间可以执行别的程序,在高并发情形下会更稳定和更高的吞吐量

http服务

要求:

  1. Netty 服务器在 8888 端口监听,浏览器发出请求 " http://localhost:8888/ "
  2. 服务器可以回复消息给客户端 "Hello! 我是服务器 5 " , 并对特定请求资源进行过滤.
package netty.netty.http;

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 TestServer {
   public static void main(String[] args) throws Exception {

       EventLoopGroup bossGroup = new NioEventLoopGroup(1);
       EventLoopGroup workerGroup = new NioEventLoopGroup();
       try {
           ServerBootstrap serverBootstrap = new ServerBootstrap();
           serverBootstrap.group(bossGroup, workerGroup).
                   channel(NioServerSocketChannel.class).
                   childHandler(new TestServerInitializer());

           ChannelFuture channelFuture = serverBootstrap.bind(8888).sync();
           channelFuture.channel().closeFuture().sync();
       }finally {
           bossGroup.shutdownGracefully();
           workerGroup.shutdownGracefully();
       }
   }
}

复制代码
package netty.netty.http;

import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.http.HttpServerCodec;


public class TestServerInitializer extends ChannelInitializer<SocketChannel> {

   @Override
   protected void initChannel(SocketChannel ch) throws Exception {
       //得到管道,向管道加入处理器
       ChannelPipeline pipeline = ch.pipeline();
       //加入一个netty 提供的httpServerCodec codec =>[coder - decoder]
       //HttpServerCodec 说明
       //1. HttpServerCodec 是netty 提供的处理http的 编-解码器
       pipeline.addLast("MyHttpServerCodec",new HttpServerCodec());
       //2. 增加一个自定义的handler
       pipeline.addLast("MyTestHttpServerHandler", new TestHttpServerHandler());

       System.out.println("ok~~~~");

   }
}

复制代码
package netty.netty.http;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.http.*;
import io.netty.util.CharsetUtil;

import java.net.URI;

/*
说明
1. SimpleChannelInboundHandler 是 ChannelInboundHandlerAdapter
2. HttpObject 客户端和服务器端相互通讯的数据被封装成 HttpObject
*/
public class TestHttpServerHandler extends SimpleChannelInboundHandler<HttpObject> {


   //channelRead0 读取客户端数据
   @Override
   protected void channelRead0(ChannelHandlerContext ctx, HttpObject msg) throws Exception {


       System.out.println("对应的channel=" + ctx.channel() + " pipeline=" + ctx.pipeline() + " 通过pipeline获取channel" + ctx.pipeline().channel());

       System.out.println("当前ctx的handler=" + ctx.handler());

       //判断 msg 是不是 httprequest请求
       if(msg instanceof HttpRequest) {
           // 1 HttpObject 的真实类型 是DefaultHttpRequest
           System.out.println("ctx 类型="+ctx.getClass());

           System.out.println("pipeline hashcode" + ctx.pipeline().hashCode() + " TestHttpServerHandler hash=" + this.hashCode());

           System.out.println("msg 类型=" + msg.getClass());
           System.out.println("客户端地址" + ctx.channel().remoteAddress());

           //获取到
           HttpRequest httpRequest = (HttpRequest) msg;
           /**********************注意 ********************************/
           /**
            * 如果不加此过滤,我们在浏览器访问 http://localhost:8888/ 的时候 会发送2次请求
            * 那么我们服务端就会收到2次请求,其中一次是 http://localhost:8888/favicon.ico 的网站图标请求
            * 这个请求,对于我们来说是多余的,所以需要过滤掉这个特定资源的响应
            */
           URI uri = new URI(httpRequest.uri());
          if("/favicon.ico".equals(uri.getPath())) {
               System.out.println("请求了 favicon.ico, 不做响应");
               return;
           }
           /******************* 结束***********************************/
           //回复信息给浏览器 [http协议]
           ByteBuf content = Unpooled.copiedBuffer("hello, 我是服务器", CharsetUtil.UTF_8);

           //构造一个http的相应,即 httpresponse
           FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK, content);

           response.headers().set(HttpHeaderNames.CONTENT_TYPE, "text/plain");
           response.headers().set(HttpHeaderNames.CONTENT_LENGTH, content.readableBytes());

           //将构建好 response返回
           ctx.writeAndFlush(response);

       }
   }



}

复制代码

打印结果如下:

ok~~~~
ok~~~~
对应的channel=[id: 0x46ba7e64, L:/0:0:0:0:0:0:0:1:8888 - R:/0:0:0:0:0:0:0:1:56766] pipeline=DefaultChannelPipeline{(MyHttpServerCodec = io.netty.handler.codec.http.HttpServerCodec), (MyTestHttpServerHandler = netty.netty.http.TestHttpServerHandler)} 通过pipeline获取channel[id: 0x46ba7e64, L:/0:0:0:0:0:0:0:1:8888 - R:/0:0:0:0:0:0:0:1:56766]
当前ctx的handler=netty.netty.http.TestHttpServerHandler@22dc040a
ctx 类型=class io.netty.channel.DefaultChannelHandlerContext
pipeline hashcode365619740 TestHttpServerHandler hash=584844298
msg 类型=class io.netty.handler.codec.http.DefaultHttpRequest
客户端地址/0:0:0:0:0:0:0:1:56766
对应的channel=[id: 0x46ba7e64, L:/0:0:0:0:0:0:0:1:8888 - R:/0:0:0:0:0:0:0:1:56766] pipeline=DefaultChannelPipeline{(MyHttpServerCodec = io.netty.handler.codec.http.HttpServerCodec), (MyTestHttpServerHandler = netty.netty.http.TestHttpServerHandler)} 通过pipeline获取channel[id: 0x46ba7e64, L:/0:0:0:0:0:0:0:1:8888 - R:/0:0:0:0:0:0:0:1:56766]
当前ctx的handler=netty.netty.http.TestHttpServerHandler@22dc040a
对应的channel=[id: 0x46ba7e64, L:/0:0:0:0:0:0:0:1:8888 - R:/0:0:0:0:0:0:0:1:56766] pipeline=DefaultChannelPipeline{(MyHttpServerCodec = io.netty.handler.codec.http.HttpServerCodec), (MyTestHttpServerHandler = netty.netty.http.TestHttpServerHandler)} 通过pipeline获取channel[id: 0x46ba7e64, L:/0:0:0:0:0:0:0:1:8888 - R:/0:0:0:0:0:0:0:1:56766]
当前ctx的handler=netty.netty.http.TestHttpServerHandler@22dc040a
ctx 类型=class io.netty.channel.DefaultChannelHandlerContext
pipeline hashcode365619740 TestHttpServerHandler hash=584844298
msg 类型=class io.netty.handler.codec.http.DefaultHttpRequest
客户端地址/0:0:0:0:0:0:0:1:56766
请求了 favicon.ico, 不做响应
对应的channel=[id: 0x46ba7e64, L:/0:0:0:0:0:0:0:1:8888 - R:/0:0:0:0:0:0:0:1:56766] pipeline=DefaultChannelPipeline{(MyHttpServerCodec = io.netty.handler.codec.http.HttpServerCodec), (MyTestHttpServerHandler = netty.netty.http.TestHttpServerHandler)} 通过pipeline获取channel[id: 0x46ba7e64, L:/0:0:0:0:0:0:0:1:8888 - R:/0:0:0:0:0:0:0:1:56766]
当前ctx的handler=netty.netty.http.TestHttpServerHandler@22dc040a

复制代码

简单说明:

  1. HttpObject 是是DefaultHttpRequest 类型的

  2. 浏览器请求的时候会生成一个对应hanlder,如果另外一个浏览器请求的时候,也会生成对应的一个handler,2个浏览器的请求生成不同的handler。 但是同一个浏览器,2个请求窗口也是不同的handler. 以下是同一个浏览器,不同窗口请求的

    netty的自我学习(八)—Netty的异步模型(Future)以及Netty-HTTP服务实例

    hashcode 值是一样的。

原文 

https://juejin.im/post/5e1e487d51882521414ae0f1

本站部分文章源于互联网,本着传播知识、有益学习和研究的目的进行的转载,为网友免费提供。如有著作权人或出版方提出异议,本站将立即删除。如果您对文章转载有任何疑问请告之我们,以便我们及时纠正。

PS:推荐一个微信公众号: askHarries 或者qq群:474807195,里面会分享一些资深架构师录制的视频录像:有Spring,MyBatis,Netty源码分析,高并发、高性能、分布式、微服务架构的原理,JVM性能优化这些成为架构师必备的知识体系。还能领取免费的学习资源,目前受益良多

转载请注明原文出处:Harries Blog™ » netty的自我学习(八)—Netty的异步模型(Future)以及Netty-HTTP服务实例

赞 (0)
分享到:更多 ()

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址