前端开发之动态管理Nginx集群的方法( 四 ) _Nginx集群

query = query,
headers = headers,
})
end
local function http_request_chunk(self, http_cli)
local endpoint, err = choose_endpoint(self)
ok, err = http_cli:connect({
scheme = endpoint.scheme,
host = endpoint.host,
port = endpoint.port,
ssl_verify = self.ssl_verify,
ssl_cert_path = self.ssl_cert_path,
ssl_key_path = self.ssl_key_path,
})
return endpoint, err
end
可见，APISIX 在每个 worker 进程中，通过 ngx.timer.at 和 lua-resty-etcd 库反复请求 etcd，以此保证每个 Worker 进程中都含有最新的配置。
APISIX 配置与插件的远程变更接下来，我们看看怎样远程修改 etcd 中的配置。
我们当然可以直接通过 gRPC 接口修改 etcd 中相应 key 的内容，再基于上述的 watch 机制使得 Nginx 集群自动更新配置。然而，这样做的风险很大，因为配置请求没有经过校验，进面导致配置数据与 Nginx 集群不匹配！
通过 Nginx 的/apisix/admin/接口修改配置APISIX 提供了这么一种机制：访问任意 1 个 Nginx 节点，通过其 Worker 进程中的 Lua 代码校验请求成功后，再由/v3/dv/put 接口写入 etcd 中。下面我们来看看 APISIX 是怎么实现的。
首先，make run 生成的 nginx.conf 会自动监听 9080 端口（可通过 config.yaml 中 apisix.node_listen 配置修改），当 apisix.enable_admin 设置为 true 时，nginx.conf 就会生成以下配置：
server {
listen 9080 default_server reuseport;
location /apisix/admin {
content_by_lua_block {
apisix.http_admin()
}
}
}
这样，Nginx 接收到的/apisix/admin 请求将被 http_admin 函数处理：
-- /apisix/init.lua文件
function _M.http_admin()
local ok = router:dispatch(get_var("uri"), {method = get_method()})
end
admin 接口能够处理的 API ，其中，当 method 方法与 URI 不同时，dispatch 会执行不同的处理函数，其依据如下：
-- /apisix/admin/init.lua文件
local uri_route = {
{
paths = [[/apisix/admin/*]],
methods = {"GET", "PUT", "POST", "DELETE", "PATCH"},
handler = run,
},
{
paths = [[/apisix/admin/stream_routes/*]],
methods = {"GET", "PUT", "POST", "DELETE", "PATCH"},
handler = run_stream,
},
{
paths = [[/apisix/admin/plugins/list]],
methods = {"GET"},
handler = get_plugins_list,
},
{
paths = reload_event,
methods = {"PUT"},
handler = post_reload_plugins,
},
}
比如，当通过/apisix/admin/upstreams/1 和 PUT 方法创建 1 个 Upstream 上游时：
$ curl "http://127.0.0.1:9080/apisix/admin/upstreams/1" -H "X-API-KEY: edd1c9f034335f136f87ad84b625c8f1" -X PUT -d '
> {
> "type": "roundrobin",
> "nodes": {
> "httpbin.org:80": 1
> }
> }'
{"action":"set","node":{"key":"/apisix/upstreams/1","value":{"hash_on":"vars","nodes":{"httpbin.org:80":1},"create_time":1627982128,"update_time":1627982128,"scheme":"http","type":"roundrobin","pass_host":"pass","id":"1"}}}
你会在 error.log 中会看到如下日志（想看到这行日志，必须将 config.yaml 中的 nginx_config.error_log_level 设为 INFO）：
2021/08/03 17:15:28 [info] 16437#16437: *23572 [lua] init.lua:130: handler(): uri: ["","apisix","admin","upstreams","1"], client: 127.0.0.1, server: _, request: "PUT /apisix/admin/upstreams/1 HTTP/1.1", host: "127.0.0.1:9080"
这行日志实际是由/apisix/admin/init.lua 中的 run 函数打印的，它的执行依据是上面的 uri_route 字典。我们看下 run 函数的内容：
-- /apisix/admin/init.lua文件
local function run()
local uri_segs = core.utils.split_uri(ngx.var.uri)
core.log.info("uri: ", core.json.delay_encode(uri_segs))
local seg_res, seg_id = uri_segs[4], uri_segs[5]
local seg_sub_path = core.table.concat(uri_segs, "/", 6)
local resource = resources[seg_res]
local code, data = https://www.isolves.com/it/cxkf/qd/2022-01-14/resource[method](seg_id, req_body, seg_sub_path,
uri_args)
end
这里 resource[method]函数又被做了 1 次抽象，它是由 resources 字典决定的：
-- /apisix/admin/init.lua文件
local resources = {
routes = require("apisix.admin.routes"),
services = require("apisix.admin.services"),

前端开发之动态管理Nginx集群的方法( 四 )

推荐阅读

机情问答：诺基亚笔电会登陆国内？肯德基发游戏主机？

吃货老崔|缘分桃花相亲信爱，爱情终究会出现的四大生肖，未来半个月

王华贤|王华贤：陌上人如玉，公子世无双

惠英红|众星分享微博之夜候场状态：惠英红宋佳打牌，王鹤棣檀健次合影

怎么根据自己的体型选汉服呢胸大穿什么样的汉服

小幺精时尚手记@凭什么她一个妆容就可以轻松上热搜？而你只能做个柠檬精？

干红茶香气特点,云南红茶销售价格

小阿说财经■区块链融资数量遥遥领先，2019年全球金融科技融资总额超2619亿

好消息！在农村这三个费用将取消，村干部如果来收可以直接拒绝

电竞花生|九连胜后还有3场比赛，教练月光食言，不让梦泪上场的理由很真实！

流量用超了怎么补救(流量超出怎么补救)

搞笑奇葩菌|要不要把旁边的姑娘轰出去，吃个饭太恶心人了，老大

曝许雅钧知太多秘密，深夜晕倒偏瘫进ICU，小s表情诡异与光头赴韩

为啥昨天早上测出来一深一浅今天早上测就是白板

|规模以上工业增加值同比增长4.8%

川渝68所高校成立艺术联盟将打造“成渝艺术走廊”

澎湃新闻|沪暴雨路滑，三辆集卡车高速上连环追尾

椒盐排骨

什么是政和工夫红茶政和工夫茶历史泡法特征

【陈数】陈数真是优雅女人的典范，一袭白色西装配百褶裙，美得不像中年人