limit-conn

描述

limit-conn 插件用于限制客户端对单个服务的并发请求数。当客户端对路由的并发请求数达到限制时，可以返回自定义的状态码和响应信息。

属性

名称类型必选项默认值有效值描述
conninteger是conn > 0允许的最大并发请求数。超过 conn 的限制、但是低于 conn + burst 的请求，将被延迟处理。
burstinteger是burst >= 0每秒允许被延迟处理的额外并发请求数。
default_conn_delaynumber是default_conn_delay > 0默认的典型连接（或请求）的处理延迟时间。
only_use_default_delayboolean否false[true,false]延迟时间的严格模式。当设置为 true 时，将会严格按照设置的 default_conn_delay 时间来进行延迟处理。
key_typestring否“var”[“var”, “var_combination”]key 的类型。
keystring是用来做请求计数的依据。如果 key_type 为 “var”，那么 key 会被当作变量名称，如 remote_addr 和 consumer_name；如果 key_type 为 “var_combination”，那么 key 会当作变量组合，如 $remote_addr $consumer_name；如果 key 的值为空，$remote_addr 会被作为默认 key。
rejected_codestring否503[200,…,599]当请求数超过 conn + burst 阈值时，返回的 HTTP 状态码。
rejected_msgstring否非空当请求数超过 conn + burst 阈值时，返回的信息。
allow_degradationboolean否false当设置为 true 时，启用插件降级并自动允许请求继续。
policystring否“local”[“local”, “redis”, “redis-cluster”]用于检索和增加限制计数的策略。当设置为 local 时，计数器被以内存方式保存在节点本地；当设置为 redis 时，计数器保存在 Redis 服务节点上，从而可以跨节点共享结果，通常用它来完成全局限速；当设置为 redis-cluster 时，使用 Redis 集群而不是单个实例。
redis_hoststring否当使用 redis 限速策略时，Redis 服务节点的地址。当 policy 属性设置为 redis 时必选。
redis_portinteger否6379[1,…]当使用 redis 限速策略时，Redis 服务节点的端口。
redis_usernamestring否若使用 Redis ACL 进行身份验证（适用于 Redis 版本 >=6.0），则需要提供 Redis 用户名。若使用 Redis legacy 方式 requirepass 进行身份验证，则只需将密码配置在 redis_password。当 policy 设置为 redis 时使用。
redis_passwordstring否当使用 redis 或者 redis-cluster 限速策略时，Redis 服务节点的密码。
redis_sslboolean否false当使用 redis 限速策略时，如果设置为 true，则使用 SSL 连接到 redis
redis_ssl_verifyboolean否false当使用 redis 限速策略时，如果设置为 true，则验证服务器 SSL 证书的有效性，具体请参考 tcpsock:sslhandshake.
redis_databaseinteger否0redis_database >= 0当使用 redis 限速策略时，Redis 服务节点中使用的 database，并且只针对非 Redis 集群模式（单实例模式或者提供单入口的 Redis 公有云服务）生效。
redis_timeoutinteger否1000[1,…]当 policy 设置为 redis 或 redis-cluster 时，Redis 服务节点的超时时间（以毫秒为单位）。
redis_cluster_nodesarray否当使用 redis-cluster 限速策略时，Redis 集群服务节点的地址列表（至少需要两个地址）。当 policy 属性设置为 redis-cluster 时必选。
redis_cluster_namestring否当使用 redis-cluster 限速策略时，Redis 集群服务节点的名称。当 policy 设置为 redis-cluster 时必选。
redis_cluster_sslboolean否false当使用 redis-cluster 限速策略时，如果设置为 true，则使用 SSL 连接到 redis-cluster
redis_cluster_ssl_verifyboolean否false当使用 redis-cluster 限速策略时，如果设置为 true，则验证服务器 SSL 证书的有效性

启用插件

以下示例展示了如何在指定路由上启用 limit-conn 插件，并设置 key_type 为 "var"：

limit-conn - 图1note

您可以这样从 config.yaml 中获取 admin_key 并存入环境变量：

  1. admin_key=$(yq '.deployment.admin.admin_key[0].key' conf/config.yaml | sed 's/"//g')
  1. curl http://127.0.0.1:9180/apisix/admin/routes/1 \
  2. -H "X-API-KEY: $admin_key" -X PUT -d '
  3. {
  4.     "methods": ["GET"],
  5.     "uri": "/index.html",
  6.     "id": 1,
  7.     "plugins": {
  8.         "limit-conn": {
  9.             "conn": 1,
  10.             "burst": 0,
  11.             "default_conn_delay": 0.1,
  12.             "rejected_code": 503,
  13.             "key_type": "var",
  14.             "key": "remote_addr"
  15.         }
  16.     },
  17.     "upstream": {
  18.         "type": "roundrobin",
  19.         "nodes": {
  20.             "127.0.0.1:1980": 1
  21.         }
  22.     }
  23. }'

你也可以设置 key_type 为 "var_combination"：

  1. curl http://127.0.0.1:9180/apisix/admin/routes/1 \
  2. -H "X-API-KEY: $admin_key" -X PUT -d '
  3. {
  4.     "methods": ["GET"],
  5.     "uri": "/index.html",
  6.     "id": 1,
  7.     "plugins": {
  8.         "limit-conn": {
  9.             "conn": 1,
  10.             "burst": 0,
  11.             "default_conn_delay": 0.1,
  12.             "rejected_code": 503,
  13.             "key_type": "var_combination",
  14.             "key": "$consumer_name $remote_addr"
  15.         }
  16.     },
  17.     "upstream": {
  18.         "type": "roundrobin",
  19.         "nodes": {
  20.             "127.0.0.1:1980": 1
  21.         }
  22.     }
  23. }'

测试插件

按上述配置启用插件后，在这条路由资源上，APISIX 将只允许一个连接；当有更多连接进入时，APISIX 会直接返回 503 HTTP 状态码，拒绝连接。

  1. curl -i http://127.0.0.1:9080/index.html?sleep=20 &
  3. curl -i http://127.0.0.1:9080/index.html?sleep=20
  1. <html>
  2. <head><title>503 Service Temporarily Unavailable</title></head>
  3. <body>
  4. <center><h1>503 Service Temporarily Unavailable</h1></center>
  5. <hr><center>openresty</center>
  6. </body>
  7. </html>

删除插件

当你需要删除该插件时，可以通过以下命令删除相应的 JSON 配置，APISIX 将会自动重新加载相关配置，无需重启服务：

  1. curl http://127.0.0.1:9180/apisix/admin/routes/1 \
  2. -H "X-API-KEY: $admin_key" -X PUT -d '
  3. {
  4.     "methods": ["GET"],
  5.     "uri": "/index.html",
  6.     "upstream": {
  7.         "type": "roundrobin",
  8.         "nodes": {
  9.             "127.0.0.1:1980": 1
  10.         }
  11.     }
  12. }'

应用场景示例

限制 WebSocket 连接的并发数

Apache APISIX 支持 WebSocket 代理，我们可以使用 limit-conn 插件限制 WebSocket 连接的并发数。

  1. 创建路由并启用 WebSocket 代理和 limit-conn 插件。

    1. curl http://127.0.0.1:9180/apisix/admin/routes/1 \
    2. -H "X-API-KEY: $admin_key" -X PUT -d '
    3. {
    4.     "uri": "/ws",
    5.     "enable_websocket": true,
    6.     "plugins": {
    7.         "limit-conn": {
    8.             "conn": 1,
    9.             "burst": 0,
    10.             "default_conn_delay": 0.1,
    11.             "rejected_code": 503,
    12.             "key_type": "var",
    13.             "key": "remote_addr"
    14.         }
    15.     },
    16.     "upstream": {
    17.         "type": "roundrobin",
    18.         "nodes": {
    19.             "127.0.0.1:1980": 1
    20.         }
    21.     }
    22. }'

    上述路由在 /ws 上开启了 WebSocket 代理，并限制了 WebSocket 连接并发数为 1。

    当 WebSocket 连接并发数超过 1 时，APISIX 将会拒绝请求，并返回 HTTP 状态码 503。

  2. 发起 WebSocket 请求，返回 101 HTTP 状态码表示连接建立成功。

    1. curl --include \
    2.     --no-buffer \
    3.     --header "Connection: Upgrade" \
    4.     --header "Upgrade: websocket" \
    5.     --header "Sec-WebSocket-Key: x3JJHMbDL1EzLkh9GBhXDw==" \
    6.     --header "Sec-WebSocket-Version: 13" \
    7.     --http1.1 \
    8.     http://127.0.0.1:9080/ws
    1. HTTP/1.1 101 Switching Protocols

  3. 在另一个终端中再次发起 WebSocket 请求，返回 503 HTTP 状态码表示请求将被拒绝。

    1. HTTP/1.1 503 Service Temporarily Unavailable
    2. ···
    3. <html>
    4. <head><title>503 Service Temporarily Unavailable</title></head>
    5. <body>
    6. <center><h1>503 Service Temporarily Unavailable</h1></center>
    7. <hr><center>openresty</center>
    8. </body>
    9. </html>