带你玩玩接口网关

local openresty_args = [[openresty  -p ]] .. apisix_home .. [[ -c ]]                       .. apisix_home .. [[/conf/nginx.conf]]function _M.start(...)    init(...)    init_etcd(...)
    local cmd = openresty_args    -- print(cmd)    os.execute(cmd)end

local function load_plugin(name, plugins_list, is_stream_plugin)    local pkg_name = "apisix.plugins." .. name    if is_stream_plugin then        pkg_name = "apisix.stream.plugins." .. name    end    pkg_loaded[pkg_name] = nil
    local ok, plugin = pcall(require, pkg_name)    if not ok then        core.log.error("failed to load plugin [", name, "] err: ", plugin)        return    end
    if not plugin.priority then        core.log.error("invalid plugin [", name,                        "], missing field: priority")        return    end
    if not plugin.version then        core.log.error("invalid plugin [", name, "] missing field: version")        return    end
    plugin.name = name    core.table.insert(plugins_list, plugin)
    if plugin.init then        plugin.init()    end
    returnend

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

local schema = {    type = "object",    properties = {        rate  = {type = "number", minimum = 0},        burst = {type = "number",  minimum = 0},        key   = {type = "string",            enum = {"remote_addr", "server_addr", "http_x_real_ip",                    "http_x_forwarded_for"},        },        rejected_code = {type = "integer", minimum = 200},    },    required  = {"rate", "burst", "key", "rejected_code"}}function _M.check_schema(conf)    local ok, err = core.schema.check(schema, conf)    if not ok then        return false, err    end
    return trueend

function _M.rewrite(conf, ctx)    -- TODOend
function _M.access(conf, ctx)    -- TODOend
function _M.balancer(conf, ctx)    -- TODOend

local function create_limit_obj(conf)    core.log.info("create new limit-req plugin instance")    -- 实例化限流库    return limit_req_new("plugin-limit-req", conf.rate, conf.burst)end
function _M.access(conf, ctx)    -- 实例化限流库并将对象缓存    local lim, err = core.lrucache.plugin_ctx(plugin_name, ctx,                                               create_limit_obj, conf)    if not lim then        core.log.error("failed to instantiate a resty.limit.req object: ", err)        return 500    end
    local key = (ctx.var[conf.key] or "") .. ctx.conf_type .. ctx.conf_version    core.log.info("limit key: ", key)
    -- 调用限流并返回是否触发    local delay, err = lim:incoming(key, true)    if not delay then        -- 超过阈值，就返回指定的状态码        if err == "rejected" then            return conf.rejected_code        end
        core.log.error("failed to limit req: ", err)        return 500    end
    -- 达到并发数，缓冲队列延迟处理    if delay >= 0.001 then        sleep(delay)    endend

function init()    -- TODOend
function header_filter(conf, ctx)    -- TODOend
function body_filter(conf, ctx)    -- TODOend
function log(conf, ctx)    -- TODOend

local radix = require("resty.radixtree")local rx = radix.new({    {         paths        = "/aa",        hosts        = "foo.com",        method       = {"GET", "POST"},        remote_addrs = "127.0.0.1",        metadata     = "1",    },    {         paths        = "/bb*",        hosts        = {"*.bar.com", "gloo.com"},        method       = {"GET", "POST", "PUT"},        remote_addrs = "fe80:fe80::/64",        vars         = {"arg_name", "jack"},        metadata     = "2",    }})ngx.say(rx:match("/aa", {    host = "foo.com",    method = "GET",    remote_addr = "127.0.0.1"}))

THE END