java培训学费多少钱（居然可以这样）java培训机构哪些好，Java，Netty，实现HTTP/HTTPS服务，WEB静态服务器，代码案例分享，-丞旭猿

HttpObjectAggregator聚合器：上述解码器会将每个HTTP消息中生成多个消息对象，如：HttpRequest、HttpResponse，HttpContent、LastHttpContent，使用聚合器可以将多个消息体合并为一个FullHttpRequest或者FullHttpResponse消息，便于处理请求和响应，Netty提供了HttpObjectAggregator聚合器完成该工作。

6.java培训要多少钱

SslHandlerSslHandler的ChannelHandler实现HTTPS报文加密和解密的功能，其中SslHandler在内部使用SSLEngine来完成实际的工作，SSLEngine的实现可以是JDK的SSLEngine，也可以是Netty 的OpenSslEngine，推荐使用Netty的OpenSslEngine，它性能更好，通过SslHandler进行解密和加密的过程。

7.Java培训机构多少钱

一般情况下，SslHandler在ChannelPipeline中是第一个ChannelHandler，确保只有在所有其它的ChannelHandler将它们的逻辑应用到数据之后，才会进行加密参考：SSL认证，代码案例，单向认证和双向认证的代码分享

8.java培训需要多少钱

实现HTTP服务package com.what21.netty02.demo01.http; import io.netty.bootstrap.ServerBootstrap; import io.netty.channel.*;

9.java培训学费是多少

import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.socket.nio.NioServerSocketChannel;

10.java培训要多少学费

import io.netty.handler.logging.LogLevel; import io.netty.handler.logging.LoggingHandler; import java.net.InetSocketAddress;

publicclassHttpServer{ private String serverName; private String bindHost; privateint bindPort;

publicHttpServer(String serverName, String bindHost, int bindPort){ this.serverName = serverName;

this.bindHost = bindHost; this.bindPort = bindPort; } publicvoidstart()throws Exception

{ // 用于Acceptor的主”线程池” EventLoopGroup bossEventGroup = new NioEventLoopGroup();

// 初始化==>用于I/O工作的从”线程池” EventLoopGroup workerEventGroup = new NioEventLoopGroup(); try

{ ServerBootstrap serverBootstrap = new ServerBootstrap(); // group方法设置主从线程池

serverBootstrap.group(bossEventGroup, workerEventGroup); // 指定通道channel类型，服务端为：NioServerSocketChannel

serverBootstrap.channel(NioServerSocketChannel.class); serverBootstrap.option(ChannelOption.SO_BACKLOG,

1024); serverBootstrap.childOption(ChannelOption.TCP_NODELAY, true); serverBootstrap.handler(

new LoggingHandler(LogLevel.INFO)); serverBootstrap.childHandler(new HttpServerInitializer()); ChannelFuture bindFuture =

null; if (“0.0.0.0”.equalsIgnoreCase(this.bindHost)) { bindFuture = serverBootstrap.bind(

this.bindPort).sync(); } else { InetSocketAddress bindAddress = new InetSocketAddress(

this.bindHost, this.bindPort); bindFuture = serverBootstrap.bind(bindAddress).sync(); } Channel parentChannel = bindFuture.channel(); bindFuture.addListener(

new ChannelFutureListener() { @OverridepublicvoidoperationComplete(ChannelFuture channelFuture)

throws Exception { if (channelFuture.isSuccess()) { System.out.println(HttpServer.

this.serverName + “，绑定监听成功,” + channelFuture.channel().localAddress()); } else { System.err.println(HttpServer.

this.serverName + “，绑定监听失败!” + channelFuture.cause()); } } }); ChannelFuture closeFuture = bindFuture.channel().closeFuture().sync(); closeFuture.addListener(

new ChannelFutureListener() { @OverridepublicvoidoperationComplete(ChannelFuture channelFuture)

throws Exception { if (channelFuture.isSuccess()) { System.out.println(HttpServer.

this.serverName + “，停止监听成功,” + channelFuture.channel().localAddress()); } else { System.err.println(HttpServer.

this.serverName + “，停止监听失败!” + channelFuture.cause()); } } }); }

catch (Exception e) { e.printStackTrace(); } finally { // 优雅退出，释放”线程池”

if (bossEventGroup != null) { bossEventGroup.shutdownGracefully(); }

if (workerEventGroup != null) { workerEventGroup.shutdownGracefully(); } } }

publicstaticvoidmain(String[] args){ try { new HttpServer(“Web服务器”,”0.0.0.0″,8888

).start(); } catch (Exception e) { e.printStackTrace(); } } }package

com.what21.netty02.demo01.http; import io.netty.channel.ChannelHandler; import io.netty.channel.ChannelInitializer;

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

import io.netty.handler.codec.http.HttpServerCodec; import java.util.Map; publicclassHttpServerInitializer

extendsChannelInitializer { @OverrideprotectedvoidinitChannel(SocketChannel channel)

throws Exception { ChannelPipeline pipeline = channel.pipeline(); // http 编解码 pipeline.addLast(

new HttpServerCodec()); // http 消息聚合器 512*1024为接收的最大contentlength pipeline.addLast(“httpAggregator”

, new HttpObjectAggregator(512 * 1024)); // 请求处理器 pipeline.addLast(new HttpRequestHandler());

// 打印一下，每次http请求都打印 Map handlerMap = pipeline.toMap(); for (String key : handlerMap.keySet()) { System.out.println(key +

“=” + handlerMap.get(key)); } } }package com.what21.netty02.demo01.http; import io.netty.buffer.ByteBuf;

import io.netty.buffer.Unpooled; import io.netty.channel.ChannelFutureListener; import io.netty.channel.ChannelHandlerContext;

import io.netty.channel.SimpleChannelInboundHandler; import io.netty.handler.codec.http.*; import io.netty.util.CharsetUtil;

import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.net.SocketAddress;

import java.util.HashMap; import java.util.Map; publicclassHttpRequestHandlerextendsSimpleChannelInboundHandler

{ @OverrideprotectedvoidchannelRead0(ChannelHandlerContext ctx, FullHttpRequest httpRequest)

throws Exception { //100 Continueif (HttpUtil.is100ContinueExpected(httpRequest)) { ctx.write(

new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.CONTINUE)); } // 远程地址

SocketAddress clientSocketAddress = ctx.channel().remoteAddress(); String uri = httpRequest.uri();

if (uri.equals(“/”)) { uri = “/index.html”; } String physicalPath = “D:/Users/www/dist/”

; File file = new File(physicalPath + uri); if (!file.exists()) { file =

new File(physicalPath + “/index.html”); } try { byte[] responseBytes = getContent(file.getPath()); ByteBuf content = Unpooled.copiedBuffer(responseBytes);

boolean validateHeaders = false; FullHttpResponse fullHttpResponse = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK, content, validateHeaders); ctx.writeAndFlush(fullHttpResponse).addListener(ChannelFutureListener.CLOSE); }

catch (IOException e) { e.printStackTrace(); HttpResponseStatus responseStatus = HttpResponseStatus.INTERNAL_SERVER_ERROR; FullHttpResponse fullHttpResponse =

new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, responseStatus); ctx.writeAndFlush(fullHttpResponse).addListener(ChannelFutureListener.CLOSE); } }

/** * @param filePath * @return * @throws IOException */privatebyte[] getContent(String filePath)

throws IOException { File file = new File(filePath); long fileSize = file.length();

if (fileSize > Integer.MAX_VALUE) { returnnull; } FileInputStream fi = new

FileInputStream(file); byte[] buffer = newbyte[(int) fileSize]; int offset = 0;

int numRead = 0; while (offset =

0) { offset += numRead; } // 确保所有数据均被读取if (offset != buffer.length) {

thrownew IOException(“Could not completely read file ” + file.getName()); } fi.close();

return buffer; } @OverridepublicvoidchannelReadComplete(ChannelHandlerContext ctx){ ctx.flush(); } }

实现HTTP/HTTPS服务，共用端口package com.what21.netty02.demo01.https; import io.netty.bootstrap.ServerBootstrap;

import io.netty.channel.*; import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.socket.nio.NioServerSocketChannel;