- 基于Netty实现的servlet容器, 可以替代tomcat或jetty. (jdk1.8+)
- 解决Netty在EventLoop线程里写繁忙后不返回数据的BUG.
- 解决Netty的Http遇到请求参数携带%号会报错的问题.
- 从19年开始，一直跑在作者公司某产线的线上环境运行.
-
1.针对spring项目# 可以替代tomcat或jetty. 导包后一个@EnableNettyEmbedded注解即用.
-
2.针对非spring项目# 本项目可以只依赖一个netty（举个使用servlet的例子）
StartupServer server = new StartupServer(80); ServletContext servletContext = new ServletContext(); servletContext.setDocBase("D://static", "/webapp"); servletContext.addServlet("myServlet", new MyHttpServlet()).addMapping("/test"); server.addProtocol(new HttpServletProtocol(servletContext)); server.start(); -
3.支持# http请求聚合, 然后用 select * from id in (httpRequestList).
示例代码：com.github.netty.http.example.HttpGroupByApiController.java
-
4.支持# h2c (注: 不建议用h2,h2c当rpc, 原因在文档最底部有说明)
-
5.支持# 异步零拷贝。sendFile, mmap.
示例代码：com.github.netty.http.example.HttpZeroCopyController.java ((NettyOutputStream)servletResponse.getOutputStream()).write(new File("c://123.txt")); ((NettyOutputStream)servletResponse.getOutputStream()).write(MappedByteBuffer); com.github.netty.protocol.servlet.DefaultServlet#sendFile -
6.性能# HttpServlet比tomcat的NIO2高出25%/TPS。
1. Netty的池化内存,减少了GC对CPU的消耗 2. Tomcat的NIO2, 注册OP_WRITE后,tomcat会阻塞用户线程等待, 并没有释放线程. 3. 与tomcat不同,支持两种IO模型,可供用户选择
作者邮箱 : 842156727@qq.com
github地址 : https://github.com/wangzihaogithub/netty-servlet
1.支持异步http请求聚合, 然后用 select * from id in (httpRequestList).
示例：https://github.com/wangzihaogithub/spring-boot-protocol# com.github.netty.http.example.HttpGroupByApiController.java
2.支持异步零拷贝。sendFile, mmap.
示例：https://github.com/wangzihaogithub/spring-boot-protocol# com.github.netty.http.example.HttpZeroCopyController.java
测试信息 : 笔记本[4g内存,4代I5(4核cpu) ], JVM参数 : -Xms300m -Xmn300m -Xmx500m -XX:+PrintGCDetails
1.单体应用,连接复用qps=10000+ , tomcat=8000+
2.单体应用,连接不复用qps达到5100+, tomcat=4600+
<!-- https://github.com/wangzihaogithub/spring-boot-protocol -->
<!-- https://mvnrepository.com/artifact/com.github.wangzihaogithub/spring-boot-protocol -->
<dependency>
<groupId>com.github.wangzihaogithub</groupId>
<artifactId>spring-boot-protocol</artifactId>
<version>2.3.18</version>
</dependency>
<!-- https://github.com/wangzihaogithub/netty-servlet -->
<!-- https://mvnrepository.com/artifact/com.github.wangzihaogithub/netty-servlet -->
<dependency>
<groupId>com.github.wangzihaogithub</groupId>
<artifactId>netty-servlet</artifactId>
<version>2.3.18</version>
</dependency>public class HttpBootstrap {
public static void main(String[] args) {
StartupServer server = new StartupServer(80);
server.addProtocol(newHttpProtocol());
server.start();
}
private static HttpServletProtocol newHttpProtocol() {
ServletContext servletContext = new ServletContext();
servletContext.setDocBase("D://demo", "/webapp"); // 静态资源文件夹(非必填,默认用临时目录)
servletContext.addServlet("myHttpServlet", new MyHttpServlet())
.addMapping("/test");
return new HttpServletProtocol(servletContext);
}
}
访问http://localhost:8080/test
页面显示 hi! doGet， 测试成功！
1.Servlet是一个接受Request实体类, 并填充Response实体类的过程. 整个过程是为了处理一次http交互, 这个过程分为5种类型( 参考DispatcherType )
注: 一次http交互, 可能会经历多次执行类型;
2.servlet中大部分类型, 都会遵守这样的流程: filterChain(N Filter) -> Servlet(1);
通过ServletRequest#getDispatcherType可以获得当前的执行类型.
3.执行类型逻辑如下
public enum javax.servlet.DispatcherType {
FORWARD (
执行: 根据url或name找到servlet, 并执行filterChain(N Filter) -> Servlet(1)
触发: 调用RequestDispatcher#forward
特性: 可以对request,Response进行任何操作
INCLUDE (
执行: 根据url或name找到servlet, 并执行 filterChain(N Filter) -> Servlet(1)
触发: 调用RequestDispatcher#include
特性: 不能修改Response的header, status code , 重置body. 只能写入body.
REQUEST(
执行: 根据url找到servlet, 并执行 filterChain(N Filter) -> Servlet(1)
触发: 收到客户端的请求后
特性: 可以对request,Response进行任何操作 (正常的流程)
ASYNC(
执行: 返回AsyncContext(本质是个装有tcp长连接的实体类)
触发: 调用ServletRequest#startAsync
特性: 无阻塞并同时释放了当前线程, 不会关闭tcp连接, 并且返回AsyncContext,
用户可以将AsyncContext装在集合中, 在定时任务或者单线程中操作AsyncContext同时批量处理大量的请求),
如果一直不调用AsyncContext#complete, 则客户端阻塞(如果不是异步客户端), 服务端非阻塞.
ERROR(
执行: 根据Response的status code 或 Exception 或 url找到servlet, 不执行Filter-> 执行Servlet(1)
触发: 出现连Filter都没有捕获的异常, ErrorPageManager#handleErrorPage. 注: spring是个Servlet, Servlet被Filter包裹
特性: 当的filter或者servlet都没有捕获异常, 那么会转发到错误页servlet去构造时错误页面的响应
备注: 当进入DispatcherType 执行流程后, 会被容器的try,catch代码包裹.
}
4.注意: 重定向(sendRedirect)的跳转是由客户端实现的, 并不由Servlet实现. Servlet只负责设置Response的status为302 与设置header的Location字段.