cache 应用加速

云运维 2024-01-17 共饮一杯手机阅读

NGINX 向云原生演进，All in OpenNJet

需求

为了节省带宽、能够快速获取资源，在中间代理服务器上，通常会配置缓存。缓存机制的基本原理是将 Web 资源（如 HTML、CSS、JavaScript、图像等）保存在客户端或中间代理服务器上，以便在后续请求中直接使用该缓存副本，而不必重新获取资源。当客户端或代理服务器收到对资源的请求时，它们首先检查缓存，如果存在有效的缓存副本，可以直接返回缓存的副本，从而避免请求的发送和服务器端的处理过程。

但是上述的缓存机制仍然存在一定的问题，第一次访问资源是没有缓存的，所以首先要跟服务器通信，然后下载资源，如果带宽有限而且资源很大的情况（比如视频文件），客户端就会长时间处于下载阶段，效率低下。针对这种情况，我们就需要实现 cache 应用加速的功能。

cache 应用加速由 Web 管理员提前通过下发配置到代理服务器，由代理服务器提前下载资源并进行缓存，这样当客户端首次访问的时候也能够直接从缓存中获取资源，避免等待。

下面假设一种场景进行详细说明：

比如某银行总部上传了一个很大的文件，各银行分部第二天就需要使用这个文件，当银行分部员工下载这个文件的时候，由于带宽有限或者带宽资源紧张就可能导致该员工一直等待下载文件中，从而影响客户的办理进度。

基于该场景，现有 cache 缓存功能时序图如下：

而使用cache应用加速功能后，时序图如下：

方案

消息持久化

通过在 ctrl 进程中开启一个 cache 动态 API 入口，分别实现添加、删除配置接口以及动态获取进度接口

dyn_http_cache_module

Bash location /cache { cache_quick_api; }

消息持久化：

采用与健康检查类似的持久化方式，使用 kv_getkv_set 进行存取

reload：

reload 重启之后通过 kv_get 获取所有 cache 配置进行处理

前提：

需要 http 层配置 proxy_cache_path（zone下面以cache作为示例）

需要 http 层配置 map $purge_method （支持通过PURGE方法删除）

Bash proxy_cache_path /data/njet/cache levels=1:2 keys_zone=cache:10m purger=on max_size=20g inactive=30m; map requestmethod request_method requestmethod purge_method{ PURGE 1; default 0; }

proxy_cache_path参数说明：

参数	说明
/data/njet/cache	缓存文件存放本地磁盘位置
levels=1:2	最多三级存放
keys_zone=cache:10m	缓存使用的共享内存名称以及大小
purger=on	是否支持purge清除
max_size=20g	最大 cache 空间
inactive=30m	缓存资源不活跃时间，超过该时间没被访问，该资源就会被清理

关于缓存是否缓存以及缓存时间：

被代理服务器上需要通知代理服务器缓存内容的时间，否则代理服务器不会对内容进行缓存，通过X-Accel-Expires，expires，Cache-Control “max-age=”其中一个参数指定时间。如果代理服务器上配置了proxy_cache_valid的时间，那么被代理服务器可以不指定缓存内容的时间。

下面的示例配置，代理缓存时间主要由两个参数来控制

proxy_cache_path指令后面的inactive 表示不活跃时间，在该时间内资源没有被访问就会被清理

proxy_cache_valid 指令后面的时间表示最长缓存时间，在满足上面inactive时间内保持访问，也最多到这个最长缓存时间有效

比如要缓存一周，可使用下面的配置：

http { proxy_cache_path /data/njet/cache levels=1:2 keys_zone=cache:10m purger=on max_size=20g inactive=7d; map requestmethod request_method requestmethod purge_method{ PURGE 1; default 0; } server { listen 80; proxy_cache_valid any 7d; } server { listen 443 ssl; proxy_cache_valid any 7d; ssl_protocols TLSv1 TLSv1.1 TLSv1.2 TLSv1.3; ssl_ciphers AES128-SHA:AES256-SHA:RC4-SHA:DES-CBC3-SHA:RC4-MD5; ssl_certificate /etc/vsftpd/.sslkey/vsftpd.pem; ssl_certificate_key /etc/vsftpd/.sslkey/vsftpd.pem; } }

API 接口

添加 cache 加速配置

PUT http://192.168.40.136:8081/cache

往特定server下添加特定的资源location，通过调用动态location 添加接口实现

比如往80端口，servername为www.a.com下添加一个/music.mp4 location

server { listen 80； server_name www.a.com; location /music.mp4 { proxy_pass https://localhost:8002; proxy_cache cache; proxy_cache_purge 1; } }

动态location api 添加location格式如下

{ "type": "add", "addr_port": "0.0.0.0:80", "server_name": "www.a.com", "locations": [ { "location_rule": "=", "location_name": "/music.mp4", "location_body": "return 200 ok", "proxy_pass": "https://backend1" } ] }

cache api 收到该请求后，组装动态location api需要的格式如下：

{ "type": "add", "addr_port": "0.0.0.0:80", "server_name": "www.a.com", "locations": [ { "location_rule": "=", "location_name": "/music.mp4", "location_body": "proxy_cache cache; proxy_cache_purge $purge_method", "proxy_pass": "http://backend1" } ] }

启动一个访问该资源location的事件，在该事件中创建对该资源的http连接，维护读写时间，读取的数据丢弃即可

调用njt_event_connect_peer创建一个peer_connection，如果是ssl，需要再调用njt_http_hc_ssl_init_connection

然后设置该connection的读写handler

peer_connection->write->handler= njt_http_cache_write_handler;

peer_connection->read->handler= njt_http_cache_read_handler;

write handler 组装http报文发送

read handler 接收数据并丢弃，同时维护数据下载的元数据

维护资源的下载情况

根据http response 的content_length作为资源总大小，试试读取返回的资源大小累计作为已下载大小

request:

{ "type": "add", "location_name": "/music.mp4", #代理的server类型与backend_server的类型一致 #http 固定使用80端口 #https 固定使用443端口 "backend_server":"https://192.168.40.136:8090" }

参数	类型	必填	取值	说明
type	string	是	add
location_name	string	是	location 名字
backend_server	string	是	http://{ip}:{port} 或者https://{ip}:{port}	#代理的server类型与backend_server的类型一致 #http 固定使用80端口 #https 固定使用443端口

response：

Bash { "code": 0, #0:success 非0: error "msg": "success" }

删除 cache 加速配置

根据输入的信息组装动态删除location结构，调用删除location api删除该资源

根据输入的信息从动态hash结构查找资源，将其删除

PUT http://192.168.40.136:8081/cache

删除cache配置如下，与动态删除location接口一致

{ "type": "del", #location_name 与backend_server字段要与add cache配置时一致 "location_name": "/music.mp4", "backend_server":"https://192.168.40.136:8090" }

参数	类型	必填	取值
type	string	是	del
location_name	string	是	location 名字
backend_server	string	是	http://{ip}:{port} 或者https://{ip}:{port}

response：

{ "code": 0, #0:success 非0: error "msg": "success" }

查询特定 cache 下载进度

根据输入的信息从动态hash结构查找资源，根据目前已下载大小和总大小，计算出下载进度

PUT http://192.168.40.136:8081/cache

request：

{ "type": "download_status", #location_name 与backend_server字段要与add cache配置时一致 "location_name": "/music.mp4", "backend_server":"https://192.168.40.136:8090" }

参数	类型	必填	取值
type	string	是	download_status
location_name	string	是	location 名字
backend_server	string	是	http://{ip}:{port} 或者https://{ip}:{port}

response：

{ "code": 0, #0:success 非0: error "msg": "download_ratio: 0" #0-100, 百分比 }

查询所有 cache 配置

查询所有cache加速配置

GET http://192.168.40.136:8081/cache

response：

{ "caches": [ { "location_name": "/music.mp4", "backend_server":"https://192.168.40.136:8090", "status": "success", "download_ratio": 100 }, { "location_name": "/music2.mp4", "backend_server":"http://192.168.40.136:8091", "status": " add dyn location error", "download_ratio": 0 } ] }

测试

配置示例

njet.conf

... http { ... proxy_cache_path /root/bug/njet1.0/cache levels=1:2 keys_zone=cache_quick:10m purger=on max_size=20g inactive=7d; map requestmethod request_method requestmethod purge_method{ PURGE 1; default 0; } #用于http cache加速测试 server { listen 80; proxy_cache_valid any 7d; #缓存7天，注意上面proxy_cache_path后inactive也设置为7天 } #用于https cache加速测试 server { listen 443 ssl; proxy_cache_valid any 7d; ssl_protocols TLSv1 TLSv1.1 TLSv1.2 TLSv1.3; ssl_ciphers AES128-SHA:AES256-SHA:RC4-SHA:DES-CBC3-SHA:RC4-MD5; ssl_certificate /etc/vsftpd/.sslkey/vsftpd.pem; ssl_certificate_key /etc/vsftpd/.sslkey/vsftpd.pem; } }

njet_ctrl.conf

... load_module modules/njt_http_cache_quick_module.so; #加载cache加速模块so ... http { dyn_sendmsg_conf conf/iot-ctrl.conf; access_log logs/access_ctrl.log combined; #register config=conf/register.json server=127.0.0.1 port=8081 location=/adc; include mime.types; lua_package_path "/root/project/njet/njet_main/work/work/etc/njet/lualib/lib/?.lua;$prefix/scripts/?.lua;;"; server { listen 8081; #配置cache加速开关location location /cache { cache_quick_api; } } }