nginx 动态计算拦截非法访问ip

news/2025/3/6 2:03:41/

需求:在Nginx上实现一个动态拦截IP的方法,具体是当某个IP在1分钟内访问超过60次时,将其加入Redis并拦截,拦截时间默认1天。

技术选型:使用Nginx+Lua+Redis的方法。这种方案通过Lua脚本在Nginx处理请求时检查Redis中的黑名单,同时统计访问频率,超过阈值就封禁。这应该符合用户的需求。

需要结合Lua脚本和Redis的计数功能。安装OpenResty,配置Nginx的Lua模块,编写Lua脚本统计访问次数,使用Redis存储和过期键,以及设置拦截逻辑。连接池的使用,避免频繁连接Redis影响性能。

一、环境准备

  1. 安装OpenResty
    OpenResty集成了Nginx和Lua模块,支持直接运行Lua脚本:

    # Ubuntu/Debian
    sudo apt-get install openresty
    # CentOS
    yum install openresty
  2. 安装Redis服务

    sudo apt-get install redis-server  # Debian系
    sudo yum install redis             # RedHat系

二、Nginx配置

  1. 主配置文件(nginx.conf)
    http块中添加共享内存和Lua脚本路径:
    http {lua_package_path "/usr/local/openresty/lualib/?.lua;;";lua_shared_dict ip_limit 10m;  # 共享内存区server {listen 80;server_name _;location / {access_by_lua_file /usr/local/lua/ip_block.lua;  # 核心拦截脚本root /var/www/html;}}
    }

三、Lua脚本实现动态拦截

  1. 脚本路径
    创建Lua脚本:/usr/local/lua/ip_block.lua

  2. 脚本内容

    local redis = require "resty.redis"
    local red = redis:new()-- Redis连接参数
    local redis_host = "127.0.0.1"
    local redis_port = 6379
    local redis_timeout = 1000  -- 毫秒
    local redis_auth = nil       -- 无密码留空-- 拦截参数
    local block_time = 86400     -- 封禁时间(1天)
    local time_window = 60       -- 统计窗口(1分钟)
    local max_requests = 60     -- 最大请求数-- 获取客户端IP
    local function get_client_ip()local headers = ngx.req.get_headers()return headers["X-Real-IP"] or headers["x_forwarded_for"] or ngx.var.remote_addr
    end-- 连接Redis
    local function connect_redis()red:set_timeout(redis_timeout)local ok, err = red:connect(redis_host, redis_port)if not ok thenngx.log(ngx.ERR, "Redis连接失败: ", err)return nilendif redis_auth thenlocal ok, err = red:auth(redis_auth)if not ok then ngx.log(ngx.ERR, "Redis认证失败: ", err) endendreturn ok
    end-- 主逻辑
    local client_ip = get_client_ip()
    local counter_key = "limit:count:" .. client_ip
    local block_key = "limit:block:" .. client_ip-- 检查是否已封禁
    local is_blocked, err = red:get(block_key)
    if tonumber(is_blocked) == 1 thenngx.exit(ngx.HTTP_FORBIDDEN)  -- 直接返回403
    end-- 统计请求次数
    connect_redis()
    local current_count = red:incr(counter_key)
    if current_count == 1 thenred:expire(counter_key, time_window)  -- 首次设置过期时间
    end-- 触发封禁条件
    if current_count > max_requests thenred:setex(block_key, block_time, 1)   -- 封禁并设置1天过期red:del(counter_key)                  -- 删除计数器ngx.exit(ngx.HTTP_FORBIDDEN)
    end-- 释放Redis连接
    red:set_keepalive(10000, 100)

四、性能优化

  1. Redis连接池
    通过set_keepalive复用连接,避免频繁建立TCP连接

  • 共享内存缓存
    使用lua_shared_dict缓存高频访问IP,减少Redis查询压力

  1. 异步日志记录
    封禁操作异步写入日志文件,避免阻塞请求处理:

    ngx.timer.at(0, function()local log_msg = string.format("%s - IP %s blocked at %s", ngx.var.host, client_ip, ngx.localtime())local log_file = io.open("/var/log/nginx/blocked_ips.log", "a")log_file:write(log_msg, "\n")log_file:close()
    end)

五、验证与测试

  1. 手动触发封禁

    # 模拟高频请求
    ab -n 100 -c 10 http://your-domain.com/
    # 检查Redis
    redis-cli keys "limit:block:*"
  2. 自动解封验证
    等待24小时后检查封禁IP是否自动删除:

    redis-cli ttl "limit:block:1.2.3.4"  # 返回剩余秒数

六、扩展方案

  1. 分布式封禁
    在多台Nginx服务器间共享Redis黑名单,实现集群级拦截

  1. 可视化监控
    通过Grafana+Prometheus展示实时拦截数据:

    # 采集Redis指标
    prometheus-redis-exporter --redis.address=localhost:6379
  2. 动态调整阈值
    通过Redis Hash存储不同路径的拦截规则:

    local rule_key = "limit:rule:" .. ngx.var.uri
    local custom_rule = red:hget(rule_key, "max_requests")

引用说明

  • 核心拦截逻辑参考了Nginx+Lua+Redis的经典架构设计
  • Redis键过期机制确保自动解封
  • 性能优化方案借鉴了OpenResty最佳实践

http://www.ppmy.cn/news/1576957.html

相关文章

Java基础关键_017_集合(一)

目 录 一、概述 二、Collection 关系结构 1.概览 2.说明 三、Collection 接口 1.通用方法 (1)add(E e) (2)size() (3)addAll(Collection c) (4)contains(Object o) &#…

Github 2025-03-01 开源项目月报 Top19

根据Github Trendings的统计,本月(2025-03-01统计)共有19个项目上榜。根据开发语言中项目的数量,汇总情况如下: 开发语言项目数量Python项目9TypeScript项目6Jupyter Notebook项目2JavaScript项目2非开发语言项目1Svelte项目1Rust项目1Go项目1C++项目1Ollama: 本地大型语言模…

【mysql】mysql数据库数据导入、导出/备份还原操作

mysql数据库数据导入、导出 win10导入 例如文件名为 :book_management.sql.gz 进入文件所在目录,解压,用360解压工具解压就可以,用7z也行 配置mysql环境变量,在文件所在目录,开启cmd 输入,mysql -h IP地…

陕西省地标-DB61/T 1121-2018 政务服务中心建设和运营规范

揭秘陕西省智慧政务服务中心新标准:打造高效便捷的服务新体验 随着信息化时代的深入发展,智慧政务已成为提升政府服务效率、优化营商环境的重要举措。陕西省作为全国政务改革的先行者,近期颁布了《陕西省地标-DB61_T 1121-2018 政务服务中心…

【力扣】5.最长回文子串

AC截图 题目 思路 初始化DP表: 创建一个大小为 n x n 的二维布尔数组 dp,其中 dp[i][j] 表示字符串 s 从第 i 个字符到第 j 个字符的子串是否为回文。 初始化所有长度为1的子串为回文,即 dp[i][i] true。 处理长度为2的子串: …

嵌入式学习-EXTI外部中断

STM32 是一种基于 ARM Cortex-M 内核的微控制器系列,广泛应用于嵌入式系统开发。中断(Interrupt)是 STM32 中一个非常重要的功能,它允许微控制器在执行主程序的同时,响应外部事件或内部事件的请求,从而实现…

Spark核心之06:知识点梳理

spark知识点梳理 spark_〇一 1、spark是什么 spark是针对于大规模数据处理的统一分析引擎,它是基于内存计算框架,计算速度非常之快,但是它仅仅只是涉及到计算,并没有涉及到数据的存储,后期需要使用spark对接外部的数…

Python:类型转换和深浅拷贝,可变与不可变对象

int():转换为一个整数,只能转换由纯数字组成的字符串 浮点型强转整型会去掉小数点及后面的数,只保留整数部分 #如果字符串中有数字和正负号以外的字符就会报错 float():整形转换为浮点型会自动添加一位小数 .0 如果字符串中有…