前言
大家好，我是老马。很高兴遇到你。
我们为 java 开发者实现了 java 版本的 nginx
如果你想知道 servlet 如何处理的，可以参考我的另一个项目：
手写从零实现简易版 tomcat minicat
手写 nginx 系列
如果你对 nginx 原理感兴趣，可以阅读：
从零手写实现 nginx-01-为什么不能有 java 版本的 nginx?
从零手写实现 nginx-03-nginx 基于 Netty 实现
从零手写实现 nginx-04-基于 netty http 出入参优化处理
从零手写实现 nginx-05-MIME类型（Multipurpose Internet Mail Extensions，多用途互联网邮件扩展类型）
从零手写实现 nginx-12-keep-alive 连接复用
从零手写实现 nginx-13-nginx.conf 配置文件介绍
从零手写实现 nginx-14-nginx.conf 和 hocon 格式有关系吗？
从零手写实现 nginx-15-nginx.conf 如何通过 java 解析处理？
从零手写实现 nginx-16-nginx 支持配置多个 server
从零手写实现 nginx-18-nginx 请求头+响应头操作
从零手写实现 nginx-20-nginx 占位符 placeholder
从零手写实现 nginx-21-nginx modules 模块信息概览
从零手写实现 nginx-22-nginx modules 分模块加载优化
从零手写实现 nginx-23-nginx cookie 的操作处理
从零手写实现 nginx-26-nginx rewrite 指令
从零手写实现 nginx-27-nginx return 指令
从零手写实现 nginx-28-nginx error_pages 指令
从零手写实现 nginx-29-nginx try_files 指令
从零手写实现 nginx-30-nginx proxy_pass upstream 指令
从零手写实现 nginx-31-nginx load-balance 负载均衡
从零手写实现 nginx-32-nginx load-balance 算法 java 实现
从零手写实现 nginx-33-nginx http proxy_pass 测试验证
从零手写实现 nginx-34-proxy_pass 配置加载处理
从零手写实现 nginx-35-proxy_pass netty 如何实现？
前言
大家好，我是老马。
这一节我们将配置的加载，拆分为不同的模块加载处理，便于后续拓展。
核心实现
[java]
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54/**
* 细化为不同的组件读取
*
* @since 0.18.0
* @author 老马啸西风
*/
public class NginxUserConfigLoaderConfigComponentFile extends AbstractNginxUserConfigLoader {
private final String filePath;
public NginxUserConfigLoaderConfigComponentFile(String filePath) {
this.filePath = filePath;
}
@Override
protected NginxUserConfig doLoad() {
NgxConfig conf = null;
try {
conf = NgxConfig.read(filePath);
NginxUserConfigBs configBs = NginxUserConfigBs.newInstance();
//1. basic
INginxUserMainConfigLoad mainConfigLoad = new NginxUserMainConfigLoadFile(conf);
NginxUserMainConfig mainConfig = mainConfigLoad.load();
configBs.mainConfig(mainConfig);
//2. events
INginxUserEventsConfigLoad eventsConfigLoad = new NginxUserEventsConfigLoadFile(conf);
NginxUserEventsConfig eventsConfig = new NginxUserEventsConfig();
configBs.eventsConfig(eventsConfig);
//3. server 信息
// 首先获取 block
List<NgxEntry> servers = conf.findAll(NgxConfig.BLOCK, "http", "server"); // 示例3
if(CollectionUtil.isNotEmpty(servers)) {
for (NgxEntry entry : servers) {
// 每一个 server 的处理
NgxBlock ngxBlock = (NgxBlock) entry;
final INginxUserServerConfigLoad serverConfigLoad = new NginxUserServerConfigLoadFile(conf, ngxBlock);
NginxUserServerConfig serverConfig = serverConfigLoad.load();
configBs.addServerConfig(serverConfig);
}
}
// 返回
return configBs.build();
} catch (IOException e) {
throw new RuntimeException(e);
}
}
}
然后每一个模块，都有对应的子实现。
我们以 server 为例。
NginxUserServerConfigLoadFile
[java]
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102package com.github.houbb.nginx4j.config.load.component.impl;
import com.github.houbb.heaven.util.lang.StringUtil;
import com.github.houbb.heaven.util.util.CollectionUtil;
import com.github.houbb.nginx4j.bs.NginxUserServerConfigBs;
import com.github.houbb.nginx4j.config.NginxCommonConfigParam;
import com.github.houbb.nginx4j.config.NginxUserServerConfig;
import com.github.houbb.nginx4j.config.NginxUserServerLocationConfig;
import com.github.houbb.nginx4j.config.load.component.INginxUserServerConfigLoad;
import com.github.houbb.nginx4j.config.load.component.INginxUserServerLocationConfigLoad;
import com.github.houbb.nginx4j.constant.NginxLocationPathTypeEnum;
import com.github.houbb.nginx4j.constant.NginxUserServerConfigDefaultConst;
import com.github.odiszapc.nginxparser.NgxBlock;
import com.github.odiszapc.nginxparser.NgxConfig;
import com.github.odiszapc.nginxparser.NgxEntry;
import com.github.odiszapc.nginxparser.NgxParam;
import java.util.*;
/**
* @since 0.18.0
*/
public class NginxUserServerConfigLoadFile implements INginxUserServerConfigLoad {
private final NgxConfig conf;
private final NgxBlock serverBlock;
public NginxUserServerConfigLoadFile(NgxConfig conf, NgxBlock serverBlock) {
this.conf = conf;
this.serverBlock = serverBlock;
}
@Override
public NginxUserServerConfig load() {
NginxUserServerConfigBs serverConfigBs = NginxUserServerConfigBs.newInstance();
String name = serverBlock.getName();
int httpServerPort = getHttpServerListen(conf, serverBlock);
String httpServerName = getHttpServerName(conf, serverBlock);
String httpServerRoot = getHttpServerRoot(conf, serverBlock);
List<String> httpIndexList = getHttpServerIndexList(conf, serverBlock);
// sendfile on;
String sendFile = getHttpServerSendFile(conf, serverBlock);
//gzip
String gzip = getHttpServerGzip(conf, serverBlock);
long gzipMinLen = getHttpServerGzipMinLen(conf, serverBlock);
List<String> gzipTypes = getHttpServerGzipTypes(conf, serverBlock);
// 添加 location
List<NginxUserServerLocationConfig> locationConfigList = getHttpServerLocationList(conf, serverBlock);
NginxUserServerLocationConfig defaultLocationConfig = getDefaultLocationConfig(locationConfigList);
serverConfigBs.httpServerName(httpServerName)
.httpServerListen(httpServerPort)
.httpServerRoot(httpServerRoot)
.httpServerIndexList(httpIndexList)
.sendFile(sendFile)
.gzip(gzip)
.gzipMinLength(gzipMinLen)
.gzipTypes(gzipTypes)
.locationConfigList(locationConfigList)
.defaultLocationConfig(defaultLocationConfig);
return serverConfigBs.build();
}
// 各种实现
private List<NginxUserServerLocationConfig> getHttpServerLocationList(final NgxConfig conf, final NgxBlock serverBlock) {
List<NginxUserServerLocationConfig> resultList = new ArrayList<>();
// value
List<NgxEntry> entryList = serverBlock.findAll(NgxBlock.class, "location");
if(CollectionUtil.isNotEmpty(entryList)) {
for(NgxEntry entry : entryList) {
NgxBlock ngxBlock = (NgxBlock) entry;
// 参数
// location 的处理
final INginxUserServerLocationConfigLoad locationConfigLoad = new NginxUserServerLocationConfigLoadFile(conf, ngxBlock);
NginxUserServerLocationConfig locationConfig = locationConfigLoad.load();
resultList.add(locationConfig);
}
}
// 排序。按照匹配的优先级，从高到底排序
if(CollectionUtil.isNotEmpty(resultList)) {
Collections.sort(resultList, new Comparator<NginxUserServerLocationConfig>() {
@Override
public int compare(NginxUserServerLocationConfig o1, NginxUserServerLocationConfig o2) {
return o1.getTypeEnum().getOrder() - o2.getTypeEnum().getOrder();
}
});
}
return resultList;
}
}
因为 server 中，又涉及到 location 子模块，这里继续让 NginxUserServerLocationConfigLoadFile 来处理具体的逻辑。
小结
模块的加载拆分为不同的模块加载后，我们暂时实现了其中的部分。
后续有时间再实现更多的配置信息。
我是老马，期待与你的下次重逢。
开源地址
为了便于大家学习，已经将 nginx 开源
