欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

java netty http https pool 例子

程序员文章站 2022-04-23 11:55:23
...
                                 java netty http https pool 例子

1.废话不多说,写出这个netty 的例子还是花了我不少时间的,,期间遇到各种问题折腾了蛮久的。
netty 的核心组件我这里就不详解了,,有很多讲的很好的文章大家可以在百度搜索下

首先上一个netty 最简单的例子

boot = new Bootstrap();

// 绑定管理分组
boot.group(new NioEventLoopGroup());

// 这里是设置Channel 类型,一般用 NioSocketChannel  比较多,毕竟netty异步玩的6
boot.channel(NioSocketChannel.class).option(ChannelOption.TCP_NODELAY, true);;

boot.handler(new ChannelInitializer<NioSocketChannel>() {

        @Override
        protected void initChannel(NioSocketChannel arg0) throws Exception {

            // 将多个消息转为一个full
            arg0.pipeline().addLast(new HttpObjectAggregator(65536));

            // 添加请求编码
            arg0.pipeline().addLast(new HttpRequestEncoder());

            // 添加请求解码
            arg0.pipeline().addLast(new HttpResponseDecoder());

        }
    });


其实写代码的时候最重要的是   ChannelHandler  所有的数据都是经过 ChannelHandler  处理的, 
pipeline 的作用是将所有的 ChannelHandler 连在一起形成一个链表
我们现在抛开netty的io 管理 不谈,就只管pipeline  
比如 现在有一个http请求
“` ——————————– 分割线————- HTTP/1.1 200 OK Cache-Control: private Connection: Keep-Alive Content-Encoding: gzip Content-Length: 267 Content-Type: text/javascript; charset=gbk Date: Thu, 31 Aug 2017 15:01:56 GMT Expires: Thu, 31 Aug 2017 16:01:56 GMT Server: suggestion.baidu.zbb.df ———- 下面是http响应body jQuery110205708391915849484_1504191642334({“q”:”hah”,”p”:false,”bs”:”“,”csor”:”3”,”status”:0,”g”:[ { “q”: “¹þ¹þmx”, “t”: “n”, “st”: { “q”: “¹þ¹þmx”, “new”: 0 } }, { “q”: “¹þ¹þÉÙ¶ù”, “t”: “n”, “st”: { “q”

“¹þ¹þÉÙ¶ù”, “new”: 0 } }, { “q”: “¹þ¹þ”, “t”: “n”, “st”: { “q”: “¹þ¹þ”, “new”: 0 } }, { “q”: “haha”
, “t”: “n”, “st”: { “q”: “haha”, “new”: 0 } }, { “q”: “¹þ¹þ¶¯Âþ”, “t”: “n”, “st”: { “q”: “¹þ¹þ¶¯Âþ”,
“new”: 0 } }, { “q”: “¹þ¹þ¹þ”, “t”: “n”, “st”: { “q”: “¹þ¹þ¹þ”, “new”: 0 } }, { “q”: “¹þ¹þ¾µ”, “t”:
“n”, “st”: { “q”: “¹þ¹þ¾µ”, “new”: 0 } }, { “q”: “hahaha”, “t”: “n”, “st”: { “q”: “hahaha”, “new”: 0
} }, { “q”: “¹þ¹þ¹þ¹þàÔ, “t”: “n”, “st”: { “q”: “¹þ¹þ¹þ¹þàÔ, “new”: 0 } }, { “q”: “¹þ¹þ¹þ±íÇé°ü”,
“t”: “n”, “st”: { “q”: “¹þ¹þ¹þ±íÇé°ü”, “new”: 0 } } ],”s”:[“¹þ¹þmx”,”¹þ¹þÉÙ¶ù”,”¹þ¹þ”,”haha”,”¹þ¹þ¶
¯Âþ”,”¹þ¹þ¹þ”,”¹þ¹þ¾µ”,”hahaha”,”¹þ¹þ¹þ¹þàÔ,”¹þ¹þ¹þ±íÇé°ü”]});

你好,我是http请求body

“`——————————– 分割线————-
上面是一个完整的http请求,我们在使用时一般只需要body 那么问题来了,我们这里用的io 是 NioSocketChannel 它其实是一个tcp 连接,未经处理返回的是一个byte数组,我们不能直接使用,这个时候就需要用到 ChannelHandler 来处理了!因为是服务端返回的数据我们需要解码,这里用的是 HttpResponseDecoder 来处理。HttpResponseDecoder 能将它解成handler 和 body两部分,这样我们就可以像httpclient一样来使用了!
同样我们发起http请求也需要 ChannelHandler 来帮我们将请求的内容进行一个组装 (HttpRequestEncoder)这样我们基本的http请求和http响应就处理完成了,

但是我们现在还没有对响应的数据进行接收。同样我们接收数据也需要用到ChannelHandler 但是我们没必要直接去实现ChannelHandler 接口 我们可以继承 ChannelInboundHandlerAdapter 在ChannelInboundHandlerAdapter 中帮我们做了很多处理工作,我们只需要关心基本的接收数据就可以了

—————————- 分割线

@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {

    if (msg instanceof HttpResponse) {

        HttpResponse response = (HttpResponse) msg;

        List<Map.Entry<String, String>>  headresList =  response.headers().entries();

        for (Map.Entry<String, String>  h : headresList){
            result.handles.put(h.getKey(), h.getValue());
        }



    }
    if (msg instanceof HttpContent) {

        HttpContent content = (HttpContent) msg;
        ByteBuf buf = content.content();

        int bodyLength = ( result.body != null ?  result.body.length : 0);

        byte[] tempBs = new byte[buf.readableBytes() + bodyLength];

        if (tempBs.length != bodyLength){

            if ( bodyLength > 0){
                System.arraycopy(result.body , 0 , tempBs , 0 , bodyLength);
            }

            buf.readBytes(tempBs ,bodyLength , buf.readableBytes() );
            result.body = tempBs;
        }

        // 如果是最后一个,,释放客户端
        if(msg instanceof LastHttpContent){
            result.completeBody();
            client.release(ctx.channel(), uri);
        }


    }
}

————————– 分割线

其中 channelRead 是用来接收数据的,但是channelRead可能会被调用多次,比如 http响应数据至少会被调用两次,第一次是 HttpResponse里面主要包含响应头
第二次是 HttpContent 响应数据 ,有一点要注意 HttpContent 可能分为几次返回 我们可以使用 LastHttpContent 来判断是否是最后一次
netty中响应数据是异步的。我们需要用异步的方式处理

下面是我们使用时简单处理逻辑图

简单流程图](https://img-blog.csdn.net/20170831233615744?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvdXBkYXRlXzAwMQ==/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast)

总之一点,netty中所有的操作都是异步的,不管是 创建链接,发送数据,接收数据都是会异步放在线程池处理,这样就可以使用很少的线程资源来管理大量io连接

具体代码请看 src\xiaoa\java\netty\HttpClientUtils.java (https://git.oschina.net/xiaoa1/java1.7Dome/tree/master/src/xiaoa/java/netty
一切都以 HttpClientUtils.java 为开头

相关标签: java netty