后端新手如何从 0 到 1 打造一款 Apache APISIX 插件

在过去的几个月，社区用户为 Apache APISIX 添加了许多插件，丰富了 Apache APISIX 的生态。从使用者的角度而言，更多样化的插件出现无疑是一件好事，它们在完善 Apache APISIX 高性能和低延迟的基础之上，满足了使用者对于网关的更多期望，即 “一站式”和“多功能”。

社区的贡献者们是如何为 Apache APISIX 开发插件的呢？Apache APISIX 博客上的文章似乎都没有详细讲述过开发插件的流程。那么这次我们换一个视角，从插件开发者的角度出发，一起来看看一款插件诞生的全过程吧！

本篇文章记录了一个没有后端经验的前端工程师开发 file-logger 插件的过程。在详细说明实现过程之前，先向大家简单介绍下 file-logger 的功能。

file-logger 支持使用 Apache APISIX 插件元数据生成自定义的日志格式，用户可以通过 file-logger 插件将 JSON 格式的请求和响应数据附加到日志文件中，也可以将 Log 数据流推送到指定位置。

试想，在监控某一个路由的访问日志时，很多时候我们关注的不仅是某些请求和响应数据的值，还希望将日志数据单独写入到指定的文件中。这时就可以使用 file-logger 插件来帮忙实现这些需求。

不支持在 Docs 外粘贴 block

具体实现过程中我们可以通过 file-logger 将日志数据单独写入指定的日志文件，简化监控和调试的过程。

开发实现过程

介绍完 file-logger 的功能之后，大家也算对这个插件有了更多的认识。下面为大家详细讲解一下，没有服务端经验的我是如何从 0 开始为 Apache APISIX 完成该插件并添加相应测试的。

确定插件名称及优先级

打开 Apache APISIX 插件开发指南，按照先后顺序需要确定以下几项：

确定插件分类。
确定插件优先级，并更新 conf/config-default.yaml 文件。

因为此次开发的 file-logger 属于日志类型的插件，所以我参考了Apache APISIX 已有的日志插件的名称和排序，将 file-logger 放到了这里：

咨询了其他插件的作者和社区的热心成员之后，最终确认了该插件的名称 file-logger 和优先级 399。

需要注意，插件的优先级与执行顺序有关，优先级的值越大，执行越靠前。而插件名称的排序与执行顺序无关。

创建最小可执行插件文件

确认好插件名称和优先级后，便可在 apisix/plugins/ 目录下创建我们的插件代码文件，这里有两点需要注意下：

如果是直接在 apisix/plugins/ 目录下直接创建插件代码文件，就无需更改 Makefile 文件。
如果你的插件有新建自己的代码目录，那么就需要更新 Makefile 文件，详细步骤可参考 Apache APISIX 插件开发指南。
下面我们在 apisix/plugins/ 目录下创建 file-logger.lua 文件。
然后根据官方给出的 example-plugin 的例子做参考，来完成一个初始化版本。

-- 在头部引入我们所需要的模块
local core         =   require("apisix.core")
local plugin       =   require("apisix.plugin")
local ngx          =   ngx

-- 声明插件名称
local plugin_name = "file-logger"

-- 定义插件 schema 格式
local schema = {
    type = "object",
    properties = {
        path = {
            type = "string"
        },
    },
    required = {"path"}
}

-- 插件元数据 schema
local metadata_schema = {
    type = "object",
    properties = {
        log_format = log_util.metadata_schema_log_format
    }
}


local _M = {
    version = 0.1,
    priority = 399,
    name = plugin_name,
    schema = schema,
    metadata_schema = metadata_schema
}

-- 检查插件配置是否正确
function _M.check_schema(conf, schema_type)
    if schema_type == core.schema.TYPE_METADATA then
        return core.schema.check(metadata_schema, conf)
    end
    return core.schema.check(schema, conf)
end

-- 日志阶段
function _M.log(conf, ctx)
    core.log.warn("conf: ", core.json.encode(conf))
    core.log.warn("ctx: ", core.json.encode(ctx, true))
end


return _M

通过 example-plugin 的例子完成了一个最小的可用插件文件后，便可通过 core.log.warn(core.json.encode(conf)) 和 core.log.warn("ctx: ", core.json.encode(ctx, true)) 将插件的配置数据和请求相关的数据信息输出到 error.log 文件中去。

启用插件并测试

下面通过创建一条测试路由，来测试插件是否能成功将我们为其配置的插件数据和请求相关的数据信息，打印到错误日志文件中去。

在本地准备一个测试上游（本文中使用的测试上游是我在本地创建的 127.0.0.1:3030/api/hello ）。
通过 curl 命令创建一条路由并启用我们新增的插件。

curl http://127.0.0.1:9080/apisix/admin/routes/1 -H 'X-API-KEY: edd1c9f034335f136f87ad84b625c8f1' -X PUT -d '
{
  "plugins": {
    "file-logger": {
      "path": "logs/file.log"
    }
  },
  "upstream": {
    "type": "roundrobin",
    "nodes": {
      "127.0.0.1:3030": 1
    }
  },
  "uri": "/api/hello"
}'

接着就会看到一个 200 的状态码，表明已成功创建了路由。

运行 curl 命令向该路由发送请求，测试 file-logeer 插件是否已经启动。

$ curl -i http://127.0.0.1:9080/api/hello
HTTP/1.1 200 OK
...
hello, world

在 logs/error.log 文件中会有一条这样的记录：

可以看到，在 conf 参数中我们为插件配置的 path: logs/file.log 已经成功的保存了。到此我们已经成功创建了一个最小可用的插件，在日志阶段打印了 conf 和 ctx 参数的数据。

之后，我们可以直接在该 file-logger.lua 插件代码文件中，为它编写核心功能。这里我们可以直接运行 apisix reload 命令来重新加载最新的插件代码，而无需重启 Apache APISIX。

为 file-logger 插件编写核心功能

file-logger 插件的主要功能是写日志数据。在经过询问和查阅资料后，我了解到 Lua 的 IO 库：https://www.tutorialspoint.co...，于是确认了该插件的功能逻辑大致为以下几步：

每次接受请求之后，将日志数据输出到插件配置的
```
path
```
1. 首先，在日志阶段通过 conf 拿到 file-logger 中 path 的值。
2. 然后，通过 Lua IO 库来完成文件创建、打开、写、刷新缓存、关闭的操作。
处理打开文件失败、创建文件失败等错误。

local function write_file_data(conf, log_message)
    local msg, err = core.json.encode(log_message)
    if err then
        return core.log.error("message json serialization failed, error info : ", err)
    end

    local file, err = io_open(conf.path, 'a+')

    if not file then
        core.log.error("failed to open file: ", conf.path, ", error info: ", err)
    else
        local ok, err = file:write(msg, '\n')
        if not ok then
            core.log.error("failed to write file: ", conf.path, ", error info: ", err)
        else
            file:flush()
        end
        file:close()
    end
end

参考 http-logger 插件源码，完成了将日记数据传给写日志数据的方法和 metadata 的一些判断和处理。

function _M.log(conf, ctx)
    local metadata = plugin.plugin_metadata(plugin_name)
    local entry

    if metadata and metadata.value.log_format
        and core.table.nkeys(metadata.value.log_format) > 0
    then
        entry = log_util.get_custom_format_log(ctx, metadata.value.log_format)
    else
        entry = log_util.get_full_log(ngx, conf)
    end

    write_file_data(conf, entry)
end

验证及添加测试

验证收集日志记录

因为在创建测试路由时已经启用了 file-logger 插件，并且配置了 path 为 logs/file.log，所以此时我们只需给测试路由发送请求，以验证日志收集的结果：

curl -i http://127.0.0.1:9080/api/hello

在对应的 logs/file.log 中我们可以看到每条记录都是以 JSON 的格式保存下来。将其中一条数据格式化之后如下所示：

{
    "server":{
        "hostname":"....",
        "version":"2.11.0"
    },
    "client_ip":"127.0.0.1",
    "upstream":"127.0.0.1:3030",
    "route_id":"1",
    "start_time":1641285122961,
    "latency":13.999938964844,
    "response":{
        "status":200,
        "size":252,
        "headers":{
            "server":"APISIX\/2.11.0",
            "content-type":"application\/json; charset=utf-8",
            "date":"Tue, 04 Jan 2022 08:32:02 GMT",
            "vary":"Accept-Encoding",
            "content-length":"19",
            "connection":"close",
            "etag":"\"13-5j0ZZR0tI549fSRsYxl8c9vAU78\""
        }
    },
    "service_id":"",
    "request":{
        "querystring":{

        },
        "size":87,
        "method":"GET",
        "headers":{
            "host":"127.0.0.1:9080",
            "accept":"*\/*",
            "user-agent":"curl\/7.77.0"
        },
        "url":"http:\/\/127.0.0.1:9080\/api\/hello",
        "uri":"\/api\/hello"
    }
}

至此验证收集日志记录的环节结束了，验证结果说明插件成功启动并返回了应有的数据

为插件添加测试

对于 add_block_preprocessor 部分的代码，由于我本人没有学过 Perl ，所以在刚开始编写时比较困惑。在询问之后才了解到它的正确使用方式：如果我们在数据部分没有编写相关的 request 断言和 no_error_log 断言时，那么默认断言如下：

--- request
GET /t
--- no_error_log
[error]

综合参考了一些其他的日志测试文件以后，我在 t/plugin/ 目录下创建 file-logger.t 文件。

每一份测试文件都由 __DATA__ 分为序言部分和数据部分。由于目前官网测试相关文档没有明确归档分类，更多具体内容可参考文末的相关资料。下面我为大家列出参考相关资料后完成的其中一个测试用例：

use t::APISIX 'no_plan';

no_long_string();
no_root_location();

add_block_preprocessor(sub {
    my ($block) = @_;

    if (! $block->request) {
        $block->set_value("request", "GET /t");
    }

    if (! $block->no_error_log && ! $block->error_log) {
        $block->set_value("no_error_log", "[error]");
    }
});


run_tests;

__DATA__

=== TEST 1: sanity
--- config
    location /t {
        content_by_lua_block {
            local configs = {
                -- full configuration
                {
                    path = "file.log"
                },
                -- property "path" is required
                {
                    path = nil
                }
            }

            local plugin = require("apisix.plugins.file-logger")

            for i = 1, #configs do
                ok, err = plugin.check_schema(configs[i])
                if err then
                    ngx.say(err)
                else
                    ngx.say("done")
                end
            end
        }
    }
--- response_body_like
done
property "path" is required

至此插件添加测试环节结束。

以上就是我作为一个后端新手，从 0 开始实现一款 Apache APISIX 插件的全过程。在开发插件的过程中确实碰到了很多坑，比较幸运的是 Apache APISIX 社区里面有很多热心的大佬帮我解惑，使得 file-logger 插件的开发和测试全程都比较顺畅。如果你对这个插件感兴趣，或想要查看插件详情，可以参考 Apache APISIX 官方文档。

目前，Apache APISIX 也在开发其他插件以支持集成更多服务，如果您对此感兴趣，欢迎随时在 GitHub Discussion 中发起讨论，也可通过邮件列表进行交流讨论。

后端新手如何从 0 到 1 打造一款 Apache APISIX 插件

后端新手如何从 0 到 1 打造一款 Apache APISIX 插件

开发实现过程

确定插件名称及优先级

创建最小可执行插件文件

启用插件并测试

为 file-logger 插件编写核心功能

验证及添加测试

验证收集日志记录

为插件添加测试

Recommend

腾讯音乐知识图谱搜索实践

给面试加点硬菜：延迟任务场景，该如何提高吞吐量和时效性！

Go语言中fmt.Println(true)的结果一定是true么？

成为第一没有捷径：AI新势力MindSpore成长秘籍 | 源创者说专访开源专家胡晓曼

Keycloak弃用大多数Keycloak适配器，包括Spring Security和Spring Boot

搭建 VuePress 博客，你可能会用到的一些插件

pickle 和 savez_compressed 压缩体积对比

XTask 一个拓展性极强的Android任务执行框架

GitHub - tulir/gomuks: A terminal based Matrix client written in Go.

FRP 内网穿透、反向代理

About Joyk