add netty http server in spring boot sample

Author: ipipman

springboot-netty-sample/src/main/java/com/ipman/netty/springboot/sample/http/HttpServer.java

@@ -0,0 +1,55 @@
+package com.ipman.netty.springboot.sample.http;
+
+import io.netty.bootstrap.ServerBootstrap;
+import io.netty.channel.*;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioServerSocketChannel;
+import io.netty.handler.codec.http.HttpServerCodec;
+import io.netty.handler.codec.http.HttpServerExpectContinueHandler;
+import io.netty.handler.logging.LogLevel;
+import io.netty.handler.logging.LoggingHandler;
+
+/**
+* Created by ipipman on 2022/1/19.
+*
+* @version V1.0
+* @Package com.ipman.netty.springboot.sample.http
+* @Description: (用一句话描述该文件做什么)
+* @date 2022/1/19 10:00 下午
+*/
+public class HttpServer {
+
+public static void main(String[] args) {
+// 主从模式
+EventLoopGroup bossGroup = new NioEventLoopGroup(1);
+EventLoopGroup workerGroup = new NioEventLoopGroup();
+
+try {
+ServerBootstrap b = new ServerBootstrap();
+b.group(bossGroup, workerGroup)
+.channel(NioServerSocketChannel.class)
+.handler(new LoggingHandler(LogLevel.INFO))
+.childHandler(new ChannelInitializer<SocketChannel>() {
+@Override
+protected void initChannel(SocketChannel ch) throws Exception {
+// HTTP 模式
+ChannelPipeline p = ch.pipeline();
+p.addLast(new HttpServerCodec());
+p.addLast(new HttpServerExpectContinueHandler());
+p.addLast(new HttpServerHandler());
+}
+});
+ChannelFuture ch = b.bind(8099).sync();
+
+System.out.println("Open Http Server : http://127.0.0.1:8099");
+ch.channel().closeFuture().sync();
+
+} catch (Exception ex) {
+ex.printStackTrace();
+} finally {
+workerGroup.shutdownGracefully();
+bossGroup.shutdownGracefully();
+}
+}
+}

springboot-netty-sample/src/main/java/com/ipman/netty/springboot/sample/http/HttpServerHandler.java

@@ -0,0 +1,60 @@
+package com.ipman.netty.springboot.sample.http;
+
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelHandler.Sharable;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.SimpleChannelInboundHandler;
+import io.netty.handler.codec.http.*;
+
+import java.nio.charset.StandardCharsets;
+
+import static io.netty.handler.codec.http.HttpResponseStatus.OK;
+import static io.netty.handler.codec.http.HttpHeaderNames.CONTENT_TYPE;
+import static io.netty.handler.codec.http.HttpHeaderNames.CONTENT_LENGTH;
+import static io.netty.handler.codec.http.HttpHeaderValues.TEXT_PLAIN;
+
+
+/**
+* Created by ipipman on 2022/1/19.
+*
+* @version V1.0
+* @Package com.ipman.netty.springboot.sample.http
+* @Description: (用一句话描述该文件做什么)
+* @date 2022/1/19 9:50 下午
+*/
+@Sharable
+public class HttpServerHandler extends SimpleChannelInboundHandler<HttpObject> {
+
+private static final byte[] CONTEXT = "hello coding".getBytes(StandardCharsets.UTF_8);
+
+/**
+* 当读取完毕时
+*
+* @param ctx
+* @throws Exception
+*/
+@Override
+public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+ctx.flush();
+}
+
+@Override
+protected void channelRead0(ChannelHandlerContext ctx, HttpObject msg) throws Exception {
+if (msg instanceof HttpRequest) {
+HttpRequest req = (HttpRequest) msg;
+FullHttpResponse response = new DefaultFullHttpResponse(req.protocolVersion(), OK, Unpooled.wrappedBuffer(CONTEXT));
+response.headers()
+.set(CONTENT_TYPE, TEXT_PLAIN)
+.set(CONTENT_LENGTH, response.content().readableBytes());
+
+ChannelFuture f = ctx.write(response);
+}
+}
+
+@Override
+public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+cause.printStackTrace();
+ctx.close();
+}
+}