从零手写实现 nginx-16-nginx.conf 支持配置多个 server

2024-06-10 16:44

本文主要是介绍从零手写实现 nginx-16-nginx.conf 支持配置多个 server,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

前言

大家好,我是老马。很高兴遇到你。

我们为 java 开发者实现了 java 版本的 nginx

https://github.com/houbb/nginx4j

如果你想知道 servlet 如何处理的,可以参考我的另一个项目:

手写从零实现简易版 tomcat minicat

手写 nginx 系列

如果你对 nginx 原理感兴趣,可以阅读:

从零手写实现 nginx-01-为什么不能有 java 版本的 nginx?

从零手写实现 nginx-02-nginx 的核心能力

从零手写实现 nginx-03-nginx 基于 Netty 实现

从零手写实现 nginx-04-基于 netty http 出入参优化处理

从零手写实现 nginx-05-MIME类型(Multipurpose Internet Mail Extensions,多用途互联网邮件扩展类型)

从零手写实现 nginx-06-文件夹自动索引

从零手写实现 nginx-07-大文件下载

从零手写实现 nginx-08-范围查询

从零手写实现 nginx-09-文件压缩

从零手写实现 nginx-10-sendfile 零拷贝

从零手写实现 nginx-11-file+range 合并

从零手写实现 nginx-12-keep-alive 连接复用

从零手写实现 nginx-13-nginx.conf 配置文件介绍

从零手写实现 nginx-14-nginx.conf 和 hocon 格式有关系吗?

从零手写实现 nginx-15-nginx.conf 如何通过 java 解析处理?

从零手写实现 nginx-16-nginx 支持配置多个 server

从零手写实现 nginx-17-nginx 默认配置优化

从零手写实现 nginx-18-nginx 请求头+响应头操作

从零手写实现 nginx-19-nginx cors

从零手写实现 nginx-20-nginx 占位符 placeholder

目标

这一节我们带着这几个问题来学习:

1)nginx.conf 配置的时候支持配置多个 server 模块吗?为什么要支持?

2)不同的 server 模块,监听端口必须相同吗?如果不同,nginx 又如何匹配区分呢?

3) 不同的 server 模块,代码启动要如何调整?

4) 实现的核心思路+代码是什么样的

nginx.conf 配置的时候支持配置多个 server 模块吗?为什么要支持?

在 Nginx 配置文件 (nginx.conf) 中,确实支持配置多个 server 模块。

这种支持是为了满足以下几个需求:

1. 多域名支持

多个 server 模块允许 Nginx 处理多个域名或子域名。

例如,你可以为 example.comsub.example.com 分别配置不同的服务器块:

http {server {listen 80;server_name example.com;location / {root /var/www/example.com;}}server {listen 80;server_name sub.example.com;location / {root /var/www/sub.example.com;}}
}

2. 不同端口支持

你可以为不同的服务配置不同的端口。

例如,一个站点可以运行在端口 80(HTTP),另一个站点可以运行在端口 443(HTTPS):

http {server {listen 80;server_name example.com;location / {root /var/www/example.com;}}server {listen 443 ssl;server_name example.com;ssl_certificate /etc/nginx/ssl/example.com.crt;ssl_certificate_key /etc/nginx/ssl/example.com.key;location / {root /var/www/example.com;}}
}

3. 不同配置需求

每个 server 模块可以有自己的配置,例如不同的日志文件、错误页、访问控制策略等:

http {server {listen 80;server_name example1.com;access_log /var/log/nginx/example1_access.log;error_log /var/log/nginx/example1_error.log;location / {root /var/www/example1.com;}}server {listen 80;server_name example2.com;access_log /var/log/nginx/example2_access.log;error_log /var/log/nginx/example2_error.log;location / {root /var/www/example2.com;}}
}

4. 反向代理和负载均衡

Nginx 常用作反向代理服务器,可以将请求转发到不同的后端服务器。

每个 server 模块可以有不同的反向代理配置:

http {upstream backend1 {server 127.0.0.1:8080;server 127.0.0.1:8081;}upstream backend2 {server 127.0.0.1:9090;server 127.0.0.1:9091;}server {listen 80;server_name api.example.com;location / {proxy_pass http://backend1;}}server {listen 80;server_name web.example.com;location / {proxy_pass http://backend2;}}
}

为什么要支持多个 server 模块?

  1. 灵活性:不同的站点或服务可以有不同的配置,满足不同的需求。
  2. 扩展性:可以轻松地添加或修改配置而不影响其他站点或服务。
  3. 维护性:分离配置使得每个站点的配置文件更加简洁和易于维护。
  4. 安全性:不同站点可以有不同的安全配置,降低风险。

综上所述,Nginx 支持多个 server 模块,使其能够灵活地管理和配置多个站点和服务,满足各种不同的需求。

不同的 server 模块,监听端口必须相同吗?如果端口相同,nginx 又如何匹配区分呢?

监听端口不同

不同的 server 模块并不需要监听相同的端口。

实际上,配置不同的 server 模块监听不同的端口是一个常见的需求。

例如,一个站点可以运行在端口 80(HTTP),另一个站点可以运行在端口 443(HTTPS),或者其他自定义端口。

以下是一个简单的示例:

http {server {listen 80;server_name example.com;location / {root /var/www/example.com;}}server {listen 8080;server_name example.com;location / {root /var/www/example.com;}}
}

在这个示例中,example.com 同时监听了端口 80 和 8080。

如果端口相同,Nginx 如何匹配和区分?

当多个 server 模块监听相同的端口时,Nginx 使用 server_namelocation 来匹配和区分请求。

匹配流程如下:

  1. 根据 server_name 进行匹配:当一个请求到达 Nginx 时,Nginx 首先根据请求头中的 Host 字段与配置中的 server_name 进行匹配。server_name 可以是具体的域名、通配符(例如 *.example.com)、正则表达式等。

  2. 默认服务器:如果没有匹配到 server_name,Nginx 会选择一个默认的 server 模块处理请求。默认服务器是第一个定义的 server 模块,或者在 listen 指令中显式指定 default_server

例如:

http {server {listen 80 default_server;server_name default.example.com;location / {root /var/www/default;}}server {listen 80;server_name example.com;location / {root /var/www/example;}}server {listen 80;server_name another.example.com;location / {root /var/www/another;}}
}

在这个配置中:

  • 请求 example.com 会匹配第二个 server 模块。
  • 请求 another.example.com 会匹配第三个 server 模块。
  • 任何其他没有明确匹配到的请求将会被第一个 server 模块(默认服务器)处理。

更详细的匹配机制

当多个 server 模块的 server_name 都能匹配到一个请求时,Nginx 会选择最具体的匹配。

例如:

http {server {listen 80;server_name *.example.com;location / {root /var/www/wildcard;}}server {listen 80;server_name www.example.com;location / {root /var/www/www;}}
}

对于请求 www.example.com,Nginx 会选择第二个 server 模块,因为它比通配符匹配更具体。

正则表达式匹配

Nginx 还支持使用正则表达式进行 server_name 匹配,这种匹配方式的优先级最低,只在前面的精确匹配和通配符匹配失败后才会被使用:

http {server {listen 80;server_name ~^www\d+\.example\.com$;location / {root /var/www/regex;}}
}

在这个例子中,www1.example.comwww2.example.com 都会匹配到这个 server 模块。

综上所述,当多个 server 模块监听相同端口时,Nginx 会通过 server_name 和匹配规则来区分不同的请求,从而将请求路由到正确的 server 模块。

多个 server 端口启动的方式调整

单个 server 启动

因为单个 server 我们只需要监听一个端口,启动的核心代码如下:

// @author: 老马啸西风
// 服务器监听的端口号
String host = InnerNetUtil.getHost();EventLoopGroup bossGroup = new NioEventLoopGroup();
//worker 线程池的数量默认为 CPU 核心数的两倍
EventLoopGroup workerGroup = new NioEventLoopGroup();try {final String httpServerPrefix = String.format("http://%s:%s/", host, port);nginxConfig.setHttpServerPrefix(httpServerPrefix);ServerBootstrap serverBootstrap = new ServerBootstrap();serverBootstrap.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {// 配置}}).option(ChannelOption.SO_BACKLOG, 128).childOption(ChannelOption.SO_KEEPALIVE, true);// Bind and start to accept incoming connections.ChannelFuture future = serverBootstrap.bind(port).sync();log.info("[Nginx4j] listen on {}", httpServerPrefix);// Wait until the server socket is closed.future.channel().closeFuture().sync();
} catch (InterruptedException e) {log.error("[Nginx4j] start meet ex", e);throw new Nginx4jException(e);
} finally {workerGroup.shutdownGracefully();bossGroup.shutdownGracefully();log.info("[Nginx4j] shutdownGracefully", host, port);
}

多个 server port 启动时

如果有不同的监听端口,那么就要调整为:

Set<Integer> httpServerPortSet = nginxConfig.getNginxUserConfig().getServerPortSet();
// 需要验证这里是否支持多个?
for(Integer port : httpServerPortSet) {// 单个启动
}

但是这段代码实际上会卡主,因为 Netty 只会启动并阻塞在第一个端口上,因为 future.channel().closeFuture().sync() 会阻塞当前线程,直到通道关闭。

这意味着在第一个端口启动并阻塞后,后续的端口启动代码将永远不会执行。

引入线程池

为了让多个 port 服务正常启动,我们引入线程池。

//@author: 老马啸西风
@Override
public void start() {Set<Integer> httpServerPortSet = nginxConfig.getNginxUserConfig().getServerPortSet();ExecutorService executorService = Executors.newFixedThreadPool(httpServerPortSet.size());// 需要验证这里是否支持多个?for (final Integer port : httpServerPortSet) {executorService.submit(new Runnable() {@Overridepublic void run() {log.info(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>> START port={}", port);singleStart(port);log.info(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>> END port={}", port);}});}
}

配置的过滤

因为配置的时候,可以按照不同的 port

比如下面这样:

# nginx.conf# 定义运行Nginx的用户和组
user nginx;# 主进程的PID文件存放位置
pid /var/run/nginx.pid;# 事件模块配置
events {worker_connections 1024;  # 每个工作进程的最大连接数
}# HTTP模块配置
http {include /etc/nginx/mime.types;  # MIME类型配置文件default_type application/octet-stream;  # 默认的MIME类型# 文件传输设置sendfile on;  # 开启高效文件传输# Keepalive超时设置keepalive_timeout 65;# 定义服务器块server {listen 8080;server_name 192.168.1.12:8080;  # 服务器域名# 单独为这个 server 启用 sendfilesendfile on;# 静态文件的根目录root D:\data\nginx4j;  # 静态文件存放的根目录index index.html index.htm;  # 默认首页# 如果需要为这个 server 单独配置 gzip,可以覆盖全局配置gzip on;gzip_types text/plain text/css application/json application/javascript text/xml application/xml application/xml+rss text/javascript;# 定义location块,处理对根目录的请求location / {try_files $uri $uri/ =404;  # 尝试提供请求的文件,如果不存在则404}}# 定义服务器块2server {listen 8081;server_name 192.168.1.12:8081;  # 服务器域名# 单独为这个 server 启用 sendfilesendfile on;# 静态文件的根目录root D:\data\nginx4j;  # 静态文件存放的根目录index index.txt; # 默认首页}}

我们在初始化的时候,按照 port 过滤分组

protected NginxConfig buildCurrentNginxConfig(NginxConfig nginxConfig,final int port,final String httpServerPrefix) {NginxConfig currentNginxConfig = new NginxConfig();// 省略基础属性// 按照端口号过滤List<NginxUserServerConfig> userServerConfigs = nginxConfig.getNginxUserConfig().getServerConfigList();// 过滤出 port 的列表并按 hostName 分组Map<String, List<NginxUserServerConfig>> groupedByHostName = new HashMap<>();if (CollectionUtil.isNotEmpty(userServerConfigs)) {groupedByHostName = userServerConfigs.stream().filter(userConfig -> userConfig.getHttpServerListen() == port).collect(Collectors.groupingBy(NginxUserServerConfig::getHttpServerName));}currentUserConfig.setCurrentServerConfigMap(groupedByHostName);currentNginxConfig.setNginxUserConfig(currentUserConfig);log.info("[Netty] Server start port={}, groupedByHostName={}", port, groupedByHostName);return currentNginxConfig;
}

使用

我们启动后设置了对应的配置,在请求过来时,可以根据请求信息直接匹配

/*** 按照 hostName 匹配** TODO: 这个匹配策略可以单独独立出来,后续可以拓展。* 比如最佳的 URL 匹配等等。** @param hostName hostName* @return 结果*/
public NginxUserServerConfig getNginxUserServerConfig(String hostName) {final Map<String, List<NginxUserServerConfig>> serverConfigMap = nginxConfig.getNginxUserConfig().getCurrentServerConfigMap();List<NginxUserServerConfig> serverConfigList = serverConfigMap.get(hostName);// 返回自定义if(CollectionUtil.isNotEmpty(serverConfigList)) {return serverConfigList.get(0);}// 默认的配置List<NginxUserServerConfig> currentDefineserverConfigList = serverConfigMap.get(NginxConst.DEFAULT_SERVER);if(CollectionUtil.isNotEmpty(currentDefineserverConfigList)) {return currentDefineserverConfigList.get(0);}// 全局默认return nginxConfig.getNginxUserConfig().getDefaultUserServerConfig();
}

当然,这里的实现比较简陋。

后续可以对这里进行拓展。

小结

我们可以发现 nginx 设计的非常灵活+强大。

值得我们深入学习其背后的思想+理念。

这篇关于从零手写实现 nginx-16-nginx.conf 支持配置多个 server的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1048708

相关文章

基于Python实现高效PPT转图片工具

《基于Python实现高效PPT转图片工具》在日常工作中,PPT是我们常用的演示工具,但有时候我们需要将PPT的内容提取为图片格式以便于展示或保存,所以本文将用Python实现PPT转PNG工具,希望... 目录1. 概述2. 功能使用2.1 安装依赖2.2 使用步骤2.3 代码实现2.4 GUI界面3.效

MySQL更新某个字段拼接固定字符串的实现

《MySQL更新某个字段拼接固定字符串的实现》在MySQL中,我们经常需要对数据库中的某个字段进行更新操作,本文就来介绍一下MySQL更新某个字段拼接固定字符串的实现,感兴趣的可以了解一下... 目录1. 查看字段当前值2. 更新字段拼接固定字符串3. 验证更新结果mysql更新某个字段拼接固定字符串 -

java实现延迟/超时/定时问题

《java实现延迟/超时/定时问题》:本文主要介绍java实现延迟/超时/定时问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Java实现延迟/超时/定时java 每间隔5秒执行一次,一共执行5次然后结束scheduleAtFixedRate 和 schedu

Java Optional避免空指针异常的实现

《JavaOptional避免空指针异常的实现》空指针异常一直是困扰开发者的常见问题之一,本文主要介绍了JavaOptional避免空指针异常的实现,帮助开发者编写更健壮、可读性更高的代码,减少因... 目录一、Optional 概述二、Optional 的创建三、Optional 的常用方法四、Optio

python连接本地SQL server详细图文教程

《python连接本地SQLserver详细图文教程》在数据分析领域,经常需要从数据库中获取数据进行分析和处理,下面:本文主要介绍python连接本地SQLserver的相关资料,文中通过代码... 目录一.设置本地账号1.新建用户2.开启双重验证3,开启TCP/IP本地服务二js.python连接实例1.

在Android平台上实现消息推送功能

《在Android平台上实现消息推送功能》随着移动互联网应用的飞速发展,消息推送已成为移动应用中不可或缺的功能,在Android平台上,实现消息推送涉及到服务端的消息发送、客户端的消息接收、通知渠道(... 目录一、项目概述二、相关知识介绍2.1 消息推送的基本原理2.2 Firebase Cloud Me

Spring Boot项目中结合MyBatis实现MySQL的自动主从切换功能

《SpringBoot项目中结合MyBatis实现MySQL的自动主从切换功能》:本文主要介绍SpringBoot项目中结合MyBatis实现MySQL的自动主从切换功能,本文分步骤给大家介绍的... 目录原理解析1. mysql主从复制(Master-Slave Replication)2. 读写分离3.

Redis实现延迟任务的三种方法详解

《Redis实现延迟任务的三种方法详解》延迟任务(DelayedTask)是指在未来的某个时间点,执行相应的任务,本文为大家整理了三种常见的实现方法,感兴趣的小伙伴可以参考一下... 目录1.前言2.Redis如何实现延迟任务3.代码实现3.1. 过期键通知事件实现3.2. 使用ZSet实现延迟任务3.3

基于Python和MoviePy实现照片管理和视频合成工具

《基于Python和MoviePy实现照片管理和视频合成工具》在这篇博客中,我们将详细剖析一个基于Python的图形界面应用程序,该程序使用wxPython构建用户界面,并结合MoviePy、Pill... 目录引言项目概述代码结构分析1. 导入和依赖2. 主类:PhotoManager初始化方法:__in

springboot filter实现请求响应全链路拦截

《springbootfilter实现请求响应全链路拦截》这篇文章主要为大家详细介绍了SpringBoot如何结合Filter同时拦截请求和响应,从而实现​​日志采集自动化,感兴趣的小伙伴可以跟随小... 目录一、为什么你需要这个过滤器?​​​二、核心实现:一个Filter搞定双向数据流​​​​三、完整代码