用netty 实现http server

古城微笑少年丶 2022-01-12 17:21 250阅读 0赞

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][]

workerGroup = new NioEventLoopGroup();  
bossGroup = new NioEventLoopGroup();  
ServerBootstrap b = new ServerBootstrap();  
b.group(bossGroup,workerGroup)  
.channel(NioServerSocketChannel.class)  
.option(ChannelOption.SO\_BACKLOG,100)  
.handler(new LoggingHandler(LogLevel.INFO))  
.childHandler(new ChannelInitializer<SocketChannel>() \{  
protected void initChannel(SocketChannel socketChannel) throws Exception \{  
socketChannel.pipeline().addLast(new HttpResponseEncoder());  
socketChannel.pipeline().addLast(new HttpRequestDecoder());  
socketChannel.pipeline().addLast(new HttpServerInboundHandler());  
\}  
\}).childOption(ChannelOption.SO\_KEEPALIVE, true);

//绑定端口，同步等待  
future = b.bind(Integer.parseInt(meta.getPort())).sync();

public class HttpServerInboundHandler extends ChannelInboundHandlerAdapter \{

private HttpRequest request;

public HttpServerInboundHandler() \{  
super();  
\}

[@Override][Override]  
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception \{  
if (msg instanceof HttpRequest) \{  
request = (HttpRequest) msg;  
  
\} else if (msg instanceof HttpContent) \{  
HttpContent content = (HttpContent) msg;  
ByteBuf buf = content.content();  
String result = buf.toString(io.netty.util.CharsetUtil.UTF\_8);  
buf.release();  
String res = "\{\\"status\\":0,\\"message\\":\\"ok\\"\}";  
FullHttpResponse response = new DefaultFullHttpResponse(HTTP\_1\_1, OK,  
Unpooled.wrappedBuffer(res.getBytes("UTF-8")));  
response.headers().set(CONTENT\_TYPE, "text/plain");  
response.headers().set(CONTENT\_LENGTH, response.content().readableBytes());  
  
ctx.write(response);  
ctx.flush();  
  
\} else \{  
  
\}  
\}

[@Override][Override]  
public void channelReadComplete(ChannelHandlerContext ctx) throws Exception \{  
ctx.flush();  
\}

[@Override][Override]  
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) \{  
ctx.close();  
\}

转载于:https://my.oschina.net/jingshishengxu/blog/3001909

[2019_Python_]: https://my.oschina.net/u/2663968/blog/3061697
[hot3.png]: /images/20220113/a80ff6f9ab7748358b3ee61ef1aa01cf.png
[Override]: https://my.oschina.net/u/1162528