2019獨角獸企業重金招聘Python工程師標準>>>

根據netty一個官方例子改編

?

//html文件位置 public?class?Config?{public?static?String?getRealPath(String?uri)?{StringBuilder?sb=new?StringBuilder("E:/htmlDemo");sb.append(uri);if?(!uri.endsWith("/"))?{sb.append('/');}return?sb.toString();} } //根據url獲取html資源 public?class?HttpServerHandler2??extends?SimpleChannelInboundHandler<Object>?{private?HttpRequest?request;private?boolean?readingChunks;?private?static?final?HttpDataFactory?factory?=?new?DefaultHttpDataFactory(DefaultHttpDataFactory.MINSIZE);?//Diskprivate?HttpPostRequestDecoder?decoder;@Overridepublic?void?channelInactive(ChannelHandlerContext?ctx)?throws?Exception?{if?(decoder?!=?null)?{decoder.cleanFiles();}}@Overridepublic?void?channelReadComplete(ChannelHandlerContext?ctx){ctx.flush();System.out.println("channelReadComplete");}@Overrideprotected?void?messageReceived(ChannelHandlerContext?ctx,?Object?msg)?throws?Exception?{if?(msg?instanceof?HttpRequest)?{HttpRequest?request?=?this.request?=?(HttpRequest)?msg;if?(HttpHeaderUtil.is100ContinueExpected(request))?{send100Continue(ctx);}HttpHeaders?headers?=?request.headers();if?(!headers.isEmpty())?{for?(Map.Entry<CharSequence,?CharSequence>?h:?headers)?{CharSequence?key?=?h.getKey();CharSequence?value?=?h.getValue();}}QueryStringDecoder?queryStringDecoder?=?new?QueryStringDecoder(request.uri());Map<String,?List<String>>?params?=?queryStringDecoder.parameters();if?(!params.isEmpty())?{for?(Entry<String,?List<String>>?p:?params.entrySet())?{String?key?=?p.getKey();List<String>?vals?=?p.getValue();for?(String?val?:?vals)?{}}}try?{decoder?=?new?HttpPostRequestDecoder(factory,?request);}?catch?(ErrorDataDecoderException?e1)?{e1.printStackTrace();//writeResponse(ctx.channel());ctx.channel().close();return;}readingChunks?=?HttpHeaderUtil.isTransferEncodingChunked(request);System.out.println("Is?Chunked:?"?+?readingChunks?+?"\r\n");System.out.println("IsMultipart:?"?+?decoder.isMultipart()?+?"\r\n");if?(readingChunks)?{//?Chunk?versionSystem.out.println("Chunks:?");readingChunks?=?true;}}if(decoder?!=?null){if?(msg?instanceof?HttpContent)?{//?New?chunk?is?receivedHttpContent?chunk?=?(HttpContent)?msg;try?{decoder.offer(chunk);}?catch?(ErrorDataDecoderException?e1)?{e1.printStackTrace();//writeResponse(ctx.channel());ctx.channel().close();return;}System.out.println('o');//readHttpDataChunkByChunk();//?example?of?reading?only?if?at?the?endif?(chunk?instanceof?LastHttpContent)?{String?uri?=?this.request.uri();System.out.println("-----------------------------------------------------------------");System.out.println("uri:"+uri);System.out.println("-----------------------------------------------------------------");writeResponse(ctx,?uri);readingChunks?=?false;reset();}}}else?{writeResponse(ctx,?"/");}}private?void?reset()?{request?=?null;//?destroy?the?decoder?to?release?all?resourcesdecoder.destroy();decoder?=?null;}private?void?writeResponse(ChannelHandlerContext?ctx,?String?uri)?{//?解析Connection首部，判斷是否為持久連接boolean?keepAlive?=?HttpHeaderUtil.isKeepAlive(request);//?Build?the?response?object.FullHttpResponse?response?=?new?DefaultFullHttpResponse(HttpVersion.HTTP_1_1,?HttpResponseStatus.OK);response.setStatus(HttpResponseStatus.OK);//?服務端可以通過location首部將客戶端導向某個資源的地址。//?response.addHeader("Location",?uri);if?(keepAlive)?{//?Add?'Content-Length'?header?only?for?a?keep-alive?connection.response.headers().setInt(HttpHeaderNames.CONTENT_LENGTH,?response.content().readableBytes());}//?得到客戶端的cookie信息，并再次寫到客戶端String?cookieString?=?request.headers().getAndConvert(HttpHeaderNames.COOKIE);if?(cookieString?!=?null)?{Set<Cookie>?cookies?=?ServerCookieDecoder.decode(cookieString);if?(!cookies.isEmpty())?{//?Reset?the?cookies?if?necessary.for?(Cookie?cookie:?cookies)?{response.headers().add(HttpHeaderNames.SET_COOKIE,?ServerCookieEncoder.encode(cookie));}}}?else?{//?Browser?sent?no?cookie.??Add?some.response.headers().add(HttpHeaderNames.SET_COOKIE,?ServerCookieEncoder.encode("key1",?"value1"));response.headers().add(HttpHeaderNames.SET_COOKIE,?ServerCookieEncoder.encode("key2",?"value2"));}//文件路徑final?String?path?=?(Config.getRealPath(uri));File?localFile?=?new?File(path);????????//?如果文件隱藏或者不存在if?(localFile.isHidden()?||?!localFile.exists())?{//?邏輯處理System.out.println("如果文件隱藏或者不存在");sendError(ctx,?NOT_FOUND);return;}//?如果請求路徑為目錄if?(localFile.isDirectory())?{//?邏輯處理System.out.println("如果請求路徑為目錄");return;}RandomAccessFile?raf?=?null;try?{raf?=?new?RandomAccessFile(localFile,?"r");long?fileLength?=?raf.length();????????????response.headers().setLong(HttpHeaderNames.CONTENT_LENGTH,?fileLength);Channel?ch?=?ctx.channel();ch.write(response);//?這里又要重新溫習下http的方法，head方法與get方法類似，但是服務器在響應中只返回首部，不會返回實體的主體部分if?(!request.method().equals(HttpMethod.HEAD))?{System.out.println("讀文件");ch.write(new?ChunkedFile(raf,?0,?fileLength,?8192));//8kb}}?catch?(Exception?e2)?{e2.printStackTrace();}?finally?{if?(keepAlive)?{response.headers().setInt(HttpHeaderNames.CONTENT_LENGTH,?response.content().readableBytes());}if?(!keepAlive)?{ctx.writeAndFlush(Unpooled.EMPTY_BUFFER).addListener(ChannelFutureListener.CLOSE);}}?}private?void?send100Continue(ChannelHandlerContext?ctx)?{FullHttpResponse?response?=?new?DefaultFullHttpResponse(HttpVersion.HTTP_1_1,?HttpResponseStatus.CONTINUE);ctx.write(response);}@Overridepublic?void?exceptionCaught(ChannelHandlerContext?ctx,?Throwable?cause)?{cause.printStackTrace();ctx.close();}private?static?void?sendError(ChannelHandlerContext?ctx,?HttpResponseStatus?status)?{FullHttpResponse?response?=?new?DefaultFullHttpResponse(HTTP_1_1,?status,Unpooled.copiedBuffer("Failure:?"?+?status.toString()?+?"\r\n",?CharsetUtil.UTF_8));response.headers().set(CONTENT_TYPE,?"text/plain;?charset=UTF-8");ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);}? }

?

?

? //服務運行類 public?class?HttpServer?{public?void?run(final?int?port)?throws?Exception?{EventLoopGroup?bossGroup?=?new?NioEventLoopGroup();EventLoopGroup?workerGroup?=?new?NioEventLoopGroup();try?{ServerBootstrap?b?=?new?ServerBootstrap();b.group(bossGroup,?workerGroup).channel(NioServerSocketChannel.class).childHandler(new?ChannelInitializer<SocketChannel>()?{@Overrideprotected?void?initChannel(SocketChannel?ch)throws?Exception?{ch.pipeline().addLast("http-decoder",new?HttpRequestDecoder());ch.pipeline().addLast("http-aggregator",new?HttpObjectAggregator(65536));ch.pipeline().addLast("http-encoder",new?HttpResponseEncoder());ch.pipeline().addLast("http-chunked",new?ChunkedWriteHandler());ch.pipeline().addLast("handler",new?HttpServerHandler());}});ChannelFuture?future?=?b.bind("192.168.1.10",?port).sync();System.out.println("HTTP服務器啟動，網址是?:?"?+?"http://192.168.1.10:"+?port);future.channel().closeFuture().sync();}?finally?{bossGroup.shutdownGracefully();workerGroup.shutdownGracefully();}}public?static?void?main(String[]?args)?throws?Exception?{new?HttpServer().run(8080);}

?

轉載于:https://my.oschina.net/u/572362/blog/648823

總結

以上是生活随笔為你收集整理的基于Netty的http服务器的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。