1
package net.narule.jnetty.httpdemo;
2

3
import io.netty.bootstrap.ServerBootstrap;
4
import io.netty.channel.ChannelFuture;
5
import io.netty.channel.EventLoopGroup;
6
import io.netty.channel.nio.NioEventLoopGroup;
7
import io.netty.channel.socket.nio.NioServerSocketChannel;
8
import io.netty.handler.logging.LogLevel;
9
import io.netty.handler.logging.LoggingHandler;
10

11
import java.net.InetSocketAddress;
12

13
/**
14
 * netty server
15
 */
16
public class HttpServer {
17

18
    int port ;
19

20
    public HttpServer(int port){
21
        this.port = port;
22
    }
23

24
    public void start() throws Exception{
25
        ServerBootstrap bootstrap = new ServerBootstrap();
26
        // 事件监听相关对象配置 netty 循环监听是否有新事件
27
        // 如果有 马上将事件交给处理器，处理器层层循环处理，会循环到自定义消息解析器  HttpRequestHandler
28
        EventLoopGroup boss = new NioEventLoopGroup();
29
        EventLoopGroup work = new NioEventLoopGroup();
30
        bootstrap.group(boss,work)
31
                .handler(new LoggingHandler(LogLevel.DEBUG))
32
                .channel(NioServerSocketChannel.class)
33
                .childHandler(new HttpServerInitializer());
34

35
        ChannelFuture f = bootstrap.bind(new InetSocketAddress(port)).sync();
36
        System.out.println("server start... port : " + port);
37
        f.channel().closeFuture().sync();
38

39
    }
40

41
}

1
package net.narule.jnetty.httpdemo;
2

3
import io.netty.channel.ChannelInitializer;
4
import io.netty.channel.ChannelPipeline;
5
import io.netty.channel.socket.SocketChannel;
6
import io.netty.handler.codec.http.HttpObjectAggregator;
7
import io.netty.handler.codec.http.HttpServerCodec;
8

9
public class HttpServerInitializer extends ChannelInitializer<SocketChannel> {
10

11
  @Override
12
  protected void initChannel(SocketChannel ch) throws Exception {
13
    ChannelPipeline pipeline = ch.pipeline();
14
    // http 编解码
15
        pipeline.addLast(new HttpServerCodec());
16
        // http 消息聚合器                                                                     512*1024为接收的最大contentlength
17
        pipeline.addLast("httpAggregator",new HttpObjectAggregator(512*1024));
18
        // 请求处理器
19
        pipeline.addLast(new HttpRequestHandler());
20

21
  }
22
}

1
package net.narule.jnetty.httpdemo;
2

3
import java.util.Date;
4
import java.util.HashMap;
5
import java.util.Map;
6
import java.util.Set;
7

8
import io.netty.buffer.Unpooled;
9
import io.netty.channel.ChannelFutureListener;
10
import io.netty.channel.ChannelHandlerContext;
11
import io.netty.channel.SimpleChannelInboundHandler;
12
import io.netty.handler.codec.http.DefaultFullHttpResponse;
13
import io.netty.handler.codec.http.FullHttpRequest;
14
import io.netty.handler.codec.http.FullHttpResponse;
15
import io.netty.handler.codec.http.HttpHeaderNames;
16
import io.netty.handler.codec.http.HttpResponseStatus;
17
import io.netty.handler.codec.http.HttpVersion;
18
import io.netty.util.CharsetUtil;
19

20
public class HttpRequestHandler extends SimpleChannelInboundHandler<FullHttpRequest> {
21

22
      @Override
23
      public void channelReadComplete(ChannelHandlerContext ctx) {
24
          ctx.flush();
25
      }
26

27
      @Override
28
      protected void channelRead0(ChannelHandlerContext ctx, FullHttpRequest req) throws Exception {
29
      // 处理数据
30
        Date date = new Date(System.currentTimeMillis());
31
          String uri = req.uri();
32
          Map<String,String> data = new HashMap<>();
33
          String protocal = req.protocolVersion().text(); //获取HTTP协议版本
34
          String content = req.content().toString(CharsetUtil.UTF_8); //获取HTTP协议版本
35
          System.out.println("request uri:" + uri);
36
          System.out.println("request content:" + content);
37
          boolean match = false;
38
          if(uri.contains("J")) {
39
            match = true;
40
          }
41
          data.put("match", String.valueOf(match));
42
          data.put("protocal", protocal);
43
          data.put("uri", uri);
44
          data.put("time", date.toString());
45
          data.put("content", content);
46
          System.getProperty("HOST");
47
          String responsedata = "{";
48
          Set<String> keySet = data.keySet();
49
          int size = data.size();
50
          for (String key : keySet) {
51
            size --;
52
            responsedata = responsedata + "\"" + key  + "\":" + "\"" + data.get(key) + (size == 0? "\"}" : "\",");
53
      }
54

55
          // 创建http响应
56
          FullHttpResponse response = new DefaultFullHttpResponse(
57
                                          HttpVersion.HTTP_1_1,
58
                                          HttpResponseStatus.OK,
59
                                          Unpooled.copiedBuffer(responsedata, CharsetUtil.UTF_8));
60
         // 设置头信息
61
          response.headers().set(HttpHeaderNames.CONTENT_TYPE, "application/json; charset=UTF-8");
62
         // 将处理后的数据 write到客户端、
63
          ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);
64
      }
65

66
}