netty 实现http

1. package cn.rainwer.nettywebsocket.Server;
3. import io.netty.bootstrap.ServerBootstrap;
4. import io.netty.channel.ChannelFuture;
5. import io.netty.channel.ChannelInitializer;
6. import io.netty.channel.EventLoopGroup;
7. import io.netty.channel.nio.NioEventLoopGroup;
8. import io.netty.channel.socket.SocketChannel;
9. import io.netty.channel.socket.nio.NioServerSocketChannel;
10. import io.netty.handler.codec.http.HttpObjectAggregator;
11. import io.netty.handler.codec.http.HttpServerCodec;
12. import io.netty.handler.codec.http.HttpServerExpectContinueHandler;
14. public class NettyHttpServer {
15.     public static void main(String[] args) {
17.         EventLoopGroup bossGroup = new NioEventLoopGroup(1);
18.         EventLoopGroup workerGroup = new NioEventLoopGroup();
19.         ChannelFuture f = null;
20.         try {
21.             //ServerBootstrap负责初始化netty服务器，并且开始监听端口的socket请求
22.             ServerBootstrap b = new ServerBootstrap();
23.             b.group(bossGroup, workerGroup)
24.                     .channel(NioServerSocketChannel.class)
25.                     .childHandler(new ChannelInitializer<SocketChannel>() {
26.                         @Override
27.                         protected void initChannel(SocketChannel socketChannel) throws Exception {
28.                             // 为监听客户端read/write事件的Channel添加用户自定义的ChannelHandler
29.                             socketChannel.pipeline()
30. //                                    .addLast("decoder", new HttpRequestDecoder())
31. //                                    .addLast("encoder", new HttpResponseEncoder())
32.                                     .addLast(new HttpServerCodec())
33.                                     .addLast(new HttpServerExpectContinueHandler())
34.                                     .addLast("aggregator", new HttpObjectAggregator(512 * 1024))
35.                                     .addLast(new NettyWebSocketConnectHandler2());
36.                         }
37.                     });
38.             f = b.bind(9996).sync();
39.             System.out.println("======NettyServer启动成功!!!=========");
40.             // f.channel().closeFuture().sync();
41.         } catch (Exception e) {
42.             e.printStackTrace();
43.         } finally {
44.             if (f != null && f.isSuccess()) {
45.                 System.out.println("Netty server listening on port " + " and ready for connections...");
46.             } else {
47.                 System.out.println("Netty server start up Error!");
48.             }
49.         }
50.     }
51. }

复制代码

1. package cn.rainwer.nettywebsocket.Server;
3. import io.netty.buffer.Unpooled;
4. import io.netty.channel.ChannelHandler;
5. import io.netty.channel.ChannelHandlerContext;
6. import io.netty.channel.SimpleChannelInboundHandler;
7. import io.netty.handler.codec.http.*;
8. import lombok.extern.slf4j.Slf4j;
9. import org.springframework.stereotype.Component;
11. import java.net.InetAddress;
12. import java.nio.charset.StandardCharsets;
14. @Slf4j
15. @ChannelHandler.Sharable
16. @Component
17. public class NettyWebSocketConnectHandler2 extends SimpleChannelInboundHandler<Object> {
19.     @Override
20.     public void channelRead(ChannelHandlerContext channelHandlerContext, Object msg) throws Exception {
21.         if (msg instanceof FullHttpRequest) {
22.             log.info("准备提取token");
23.             //转化为http请求
24.             FullHttpRequest request = (FullHttpRequest) msg;
25.             //拿到请求地址
26.             String uri = request.uri();
27.             System.out.println(uri);
28.             //判断是不是websocket请求，如果是拿出我们传递的参数（我的是token）
29.             channelHandlerContext.channel().writeAndFlush("Welcome to " + InetAddress.getLocalHost().getHostName() + " service!\n");
30.             FullHttpResponse fullHttpResponse = new DefaultFullHttpResponse(request.protocolVersion(), HttpResponseStatus.OK, Unpooled.wrappedBuffer(uri.getBytes(StandardCharsets.UTF_8)));
31.             fullHttpResponse.headers().set(HttpHeaderNames.CONTENT_TYPE, HttpHeaderValues.TEXT_PLAIN)
32.                     .set(HttpHeaderNames.CONTENT_LENGTH, fullHttpResponse.content().readableBytes());
33.             channelHandlerContext.writeAndFlush(fullHttpResponse);
34.         } else {
35.         }
36.     }
37. }

复制代码