前言
动机
最近在学习Netty框架，发现Netty是支持Http协议的。加上以前看过Spring-MVC的源码，就想着二者能不能结合一下，整一个简易的web框架（PS：其实不是整，是抄）
效果
项目地址：terabithia
0.3版本使用效果如下，其实就是Spring-MVC的Controller的写法
@RestController
@RequestMapping(value = "/hello")
public class HelloController {
/**
* request url:/hello/testGet?strParam=test&intParam=1&floatParam=2&doubleParam=3
*/
@RequestMapping(value = "/testGet", method = {RequestMethod.GET})
public Object testGet(ParamWrapperRequest request, String strParam, Integer intParam, Float floatParam, Double doubleParam) throws Exception{
System.out.println(request.getParameterNames());
// 获取参数
System.out.println("strParam:" + strParam);
System.out.println("intParam:" + intParam);
System.out.println("floatParam:" + floatParam);
System.out.println("doubleParam:" + doubleParam);
System.out.println("testGet");
return request.getParameterMap();
}
}
前置条件
以下列出各个版本需要掌握的知识：
- 0.1版本：Netty
- 0.2版本：Netty
- 0.3版本：Netty + Spring-MVC
0.1版本
0.1版本就是Netty原生API对Http协议的支持
如何实现
HttpServer初始化Netty服务， HttpServerCodec和 HttpObjectAggregator提供了对Http的支持， HttpServerHandler处理业务逻辑。
public class HttpServer {
private static final int PORT = 8080;
public static void main(String[] args) {
final EventLoopGroup bossGroup = new NioEventLoopGroup(1);
final EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
final ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup)
// 临时存放已完成三次握手的请求的队列
.option(ChannelOption.SO_BACKLOG, 1024)
.channel(NioServerSocketChannel.class)
.childHandler(new ChannelInitializer() {
@Override
protected void initChannel(SocketChannel ch) throws Exception {
ch.pipeline()
.addLast(new HttpServerCodec())
//把多个消息转换为一个单一的FullHttpRequest或是FullHttpResponse
.addLast(new HttpObjectAggregator(65536))
.addLast(new HttpServerHandler());
}
});
final Channel ch = b.bind(PORT).sync().channel();
ch.closeFuture().sync();
} catch (Exception e) {
e.printStackTrace();
} finally {
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}
}
public class HttpServerHandler extends SimpleChannelInboundHandler {
@Override
protected void channelRead0(ChannelHandlerContext ctx, FullHttpRequest msg) throws Exception {
// 业务逻辑处理。。。
String result = "hello world";
FullHttpResponse response = new DefaultFullHttpResponse(HTTP_1_1, HttpResponseStatus.OK);
response.headers().set(CONTENT_TYPE, "text/plain; charset=UTF-8");
response.content().writeBytes(result.getBytes(StandardCharsets.UTF_8));
response.headers().setInt(CONTENT_LENGTH, response.content().readableBytes());
response.headers().set(CONNECTION, CLOSE);
ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);
}
}
局限性
无法专注于业务处理，HttpServerHandler需要处理Netty的API和业务逻辑
0.2版本
0.1版本在同一个Handler中处理业务和网络是不合适的，想办法将HttpServerHandler解耦， 划分Handler和Controller。Handler处理Netty API，Controller处理业务逻辑。
如何实现
此版本不讲代码，讲思路（PS：主要是我懒得写）
- HttpServerHandler处理Netty API，转发请求到Controller以及处理Controller的返回值
- 获取请求uri，根据uri找到相对应的Controller以及方法
- 调用Controller的方法
- 处理Controller的返回值，封装成HttpResponse返回
- Controller处理业务逻辑，怎么在Spring-MVC用Controller，在这里就怎么用 Controller的主要问题是如何根据uri找到相对应的Controller以及方法，下面给出两种思路：
- 自定义接口方式，并有Map存放uri与Controller的关系
// 表示是Controller的接口
public interface Action {
Object doAction(FullHttpRequest request);
}
// 业务Controller
public class HelloAction implements Action{
@Override
public Object doAction(FullHttpRequest request) {
// 业务逻辑处理
return null;
}
}
// 使用Map存放uri与Controller的关系
Map actionMap = new ConcurrentHashMap<>();
actionMap.put("/hello", new HelloAction());
// 而在HttpServerHandler调用就更简单了，不用反射
actionMap.get(uri).doAction(request);
- 自定义注解方式
// 表示是Controller的注解
@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
public @interface RequestMapping {
String value() default "";
}
// 业务Controller
@RequestMapping("/hello")
public class HelloController {
@RequestMapping("/index")
public FullHttpResponse index(FullHttpRequest request) {
return null;
}
}
/*
* 而在HttpServerHandler调用
*/
Class clazz = obj.getClass();
// 获取类上的注解
RequestMapping mapping = clazz.getAnnotation(RequestMapping.class);
if (mapping != null) {
String mappingUri = mapping.value();
// 获取controller的所有方法
for (Method actionMethod : clazz.getMethods()) {
// 获取方法上的注解
RequestMapping subMapping = actionMethod.getAnnotation(RequestMapping.class);
if (subMapping != null) {
String subMappingUri = subMapping.value();
// 如果uri符合注解规则，则反射调用方法
if (uri.equalsIgnoreCase(mappingUri + subMappingUri)) {
return (FullHttpResponse) actionMethod.invoke(obj, request);
}
}
}
}
局限性
没有一般web框架的过滤器，参数处理，返回值处理等。业务代码仍然深度依赖Netty API
0.3版本
结构
依赖：Netty + SpringBoot
处理流程图如下：
思路
下文说的Handler就是Controller
- 先说说为什么依赖SpringBoot，因为代码抄的是Spring-MVC的，而且SpringBoot提供的容器API真的很方便。
- 调度器：作为一个业务框架，需要业务逻辑对底层的依赖，也就是要满足大部分业务处理不会用到Netty的API，也就是Netty专注于接收和响应HTTP请求
- HandlerMapping：存储了请求路径与HandlerMethod的关系，可以通过uri定位到对应的Controller的方法
- HandlerMethod：存储了Controller和业务处理方法的信息
- ArgumentResolver：负责将请求参数转换成业务处理方法所需的参数（PS：Spring的DataBinder是个好东西）
- ReturnValueHandler：负责返回值的转换，比如将Map转成JSON
实现
实现有太多东西讲了，文章讲不完。我抄了一个简化版的Spring-MVC，就在文章开头的项目地址，感兴趣的自行去看吧。
Original: https://www.cnblogs.com/konghuanxi/p/16396875.html
Author: 王谷雨
Title: Netty-如何写一个Http服务器
原创文章受到原创版权保护。转载请注明出处：https://www.johngo689.com/583258/
转载文章受原作者版权保护。转载请注明原作者出处！