SpringSecurity实战教程（十八）安全日志与审计：关键操作追踪与风险预警

1. 前言#

在我们日常开发系统的安全架构中，仅仅通过认证和授权往往不足以满足合规、溯源、风险预警等需求。企业级系统必须记录并分析 “谁在什么时候对什么资源做了什么操作”，并结合规则引擎识别异常行为，及时告警。

安全审计作为企业防护的最后一道防线，能有效追踪异常行为、还原攻击链、满足合规要求。本文笔者将带领大家基于 Spring Security 构建完整的安全审计系统，实现关键操作追踪与实时风险预警。

2. Spring Security 审计架构设计#

2.1 系统架构#

我们常见的安全审计应该具备以下基础：以笔者目前所在公司使用的系统架构如下图：

2.2 审计日志四要素#

要素	说明	示例
主体	操作执行者	用户 ID、IP 地址
客体	被操作对象	数据 ID、接口路径
动作	操作类型	登录、删除、授权变更
环境	操作上下文	时间、设备、地理位置

2.3 技术栈选择#

事件采集：Spring AOP + ApplicationEvent
存储方案：MySQL + MyBatis‑Plus（中小型应用适用）或 Elasticsearch + Logstash（大型应用 + 实时检索）
风险分析：Drools 规则引擎
可视化：Grafana 监控看板

笔者为简化演示，本文以 MySQL + MyBatis‑Plus 为存储方案。

鉴于之前的子模块代码中，我们已经集成好了 MySQL + MyBatis‑Plus，在开始之前复用之前的子模块，需在 pom.xml 中引入：

1
<dependency>
2
    <groupId>org.drools</groupId>
3
    <artifactId>drools-core</artifactId>
4
    <version>9.44.0.Final</version>
5
</dependency>
6
<dependency>
7
    <groupId>org.kie</groupId>
8
    <artifactId>kie-spring</artifactId>
9
    <version>7.74.1.Final</version>
10
</dependency>

3. 数据库与实体设计#

1
CREATE TABLE audit_log (
2
  id BIGINT AUTO_INCREMENT PRIMARY KEY,
3
  username VARCHAR(50),
4
  action VARCHAR(100),
5
  resource VARCHAR(200),
6
  timestamp DATETIME,
7
  duration BIGINT
8
);

1
@Data
2
@TableName("audit_log")
3
public class AuditLog {
4
    @TableId(type = IdType.AUTO)
5
    private Long id;
6
    private String username;
7
    private String action;
8
    private String resource;
9
    private LocalDateTime timestamp;
10
    private Long duration;
11
}
12

13
// Mapper
14
@Mapper
15
public interface AuditLogMapper extends BaseMapper<AuditLog> {}

4. 事件采集：Spring AOP + 自定义注解#

4.1 自定义注解#

1
@Target({ElementType.METHOD})
2
@Retention(RetentionPolicy.RUNTIME)
3
public @interface Audit {
4
    String action();
5
    String resource();
6
}

4.2 AOP 切面实现#

1
@Aspect
2
@Component
3
public class AuditAspect {
4
    @Autowired
5
    private ApplicationEventPublisher publisher;
6

7
    @Pointcut("@annotation(audit)")
8
    public void auditPoint(Audit audit) {}
9

10
    @Around("auditPoint(audit)")
11
    public Object around(ProceedingJoinPoint jp, Audit audit) throws Throwable {
12
        long start = System.currentTimeMillis();
13
        Object result = jp.proceed();
14
        long duration = System.currentTimeMillis() - start;
15

16
        MethodSignature ms = (MethodSignature) jp.getSignature();
17
        String username = ((UserDetails) SecurityContextHolder.getContext()
18
                .getAuthentication().getPrincipal()).getUsername();
19

20
        AuditEvent evt = new AuditEvent(username, audit.action(), audit.resource(), duration, LocalDateTime.now());
21
        publisher.publishEvent(evt);
22
        return result;
23
    }
24
}

说明：上述代码中，可补充捕获异常并发布失败事件。

4.3 事件类#

1
public record AuditEvent(String username, String action,
2
                         String resource, long duration,
3
                         LocalDateTime timestamp) {}

4.4 事件监听并保存日志#

1
@Component
2
@RequiredArgsConstructor
3
public class AuditListener {
4
    private final AuditLogMapper mapper;
5
    private final KieContainer kieContainer;
6
    private final Counter riskCounter; // Prometheus counter
7

8
    @EventListener
9
    public void handle(AuditEvent evt) {
10
        AuditLog log = new AuditLog(null, evt.username(),
11
                evt.action(), evt.resource(),
12
                evt.timestamp(), evt.duration());
13
        mapper.insert(log);
14

15
        var session = kieContainer.newKieSession();
16
        session.insert(log);
17
        var fired = session.fireAllRules();
18
        session.dispose();
19

20
        if (fired > 0) riskCounter.increment();
21
    }
22
}

5. Drools 动态规则引擎#

5.1 Drools 配置#

1
@Configuration
2
public class DroolsConfig {
3
    @Bean
4
    public KieContainer kieContainer() {
5
        KieServices ks = KieServices.Factory.get();
6
        KieFileSystem kfs = ks.newKieFileSystem();
7
        kfs.write(ResourceFactory.newClassPathResource("rules/audit-risk.drl"));
8
        ks.newKieBuilder(kfs).buildAll();
9
        return ks.newKieContainer(
10
                ks.getRepository().getDefaultReleaseId());
11
    }
12
}

5.2 规则文件 `audit-risk.drl`#

1
rule "Slow Audit"
2
when
3
    $log: AuditLog(duration > 1000)
4
then
5
    System.out.println("风险预警：操作耗时过长 by " + $log.getUsername());
6
end

6. 监控指标采集与可视化#

6.1 添加监控依赖并启用 Actuator#

1
<dependency>
2
    <groupId>io.micrometer</groupId>
3
    <artifactId>micrometer-registry-prometheus</artifactId>
4
</dependency>
5
<dependency>
6
    <groupId>org.springframework.boot</groupId>
7
    <artifactId>spring-boot-starter-actuator</artifactId>
8
</dependency>

6.2 配置 `application.yml`#

1
management:
2
  endpoints:
3
    web:
4
      exposure:
5
        include: prometheus,health

6.3 指标配置#

1
@Configuration
2
public class MetricsConfig {
3
    @Bean
4
    public Counter riskCounter(MeterRegistry reg) {
5
        return Counter.builder("audit.risk.count")
6
                .description("Number of risky audit events")
7
                .register(reg);
8
    }
9
}

Prometheus 采集 /actuator/prometheus，Grafana 仪表板配置查询：audit_risk_count。

7. 控制器示例#

完成上述所有操作后，可编写一个 Controller 进行相关测试：

1
@RestController
2
@RequestMapping("/api")
3
@RequiredArgsConstructor
4
public class DemoController {
5
    @Audit(action = "ACCESS", resource = "demoEndpoint")
6
    @GetMapping("/demo")
7
    public String demo() {
8
        return "OK";
9
    }
10
}

8. 结语#

本章节我们以最简单的一个入门示例，主要讲解了：

利用 MyBatis‑Plus 实现高效、自动化地操作 MySQL 审计日志表；
通过 Spring AOP + ApplicationEvent 实现操作日志透明采集；
使用 Drools 规则引擎实现可配置、实时化的风险判断；
集成 Prometheus + Grafana 实现可视化监控，从流量、耗时、风险事件维度全方位审计系统行为。

这套方案可按需扩展为审计超级系统，支持敏感操作追踪、异常报警、人机判定等功能，适合企业级复杂场景。后续可添加 CI/CD 自动部署 Drools 规则、Grafana 警报等高级功能。

音乐

音乐

1. 前言#

2. Spring Security 审计架构设计#

2.1 系统架构#

2.2 审计日志四要素#

2.3 技术栈选择#

3. 数据库与实体设计#

4. 事件采集：Spring AOP + 自定义注解#

4.1 自定义注解#

4.2 AOP 切面实现#

4.3 事件类#

4.4 事件监听并保存日志#

5. Drools 动态规则引擎#

5.1 Drools 配置#

5.2 规则文件 `audit-risk.drl`#

6. 监控指标采集与可视化#

6.1 添加监控依赖并启用 Actuator#

6.2 配置 `application.yml`#

6.3 指标配置#

7. 控制器示例#

8. 结语#

支持与分享

评论区

音乐

文章目录

音乐

音乐

SpringSecurity实战教程（十八）安全日志与审计：关键操作追踪与风险预警

1. 前言#

2. Spring Security 审计架构设计#

2.1 系统架构#

2.2 审计日志四要素#

2.3 技术栈选择#

3. 数据库与实体设计#

4. 事件采集：Spring AOP + 自定义注解#

4.1 自定义注解#

4.2 AOP 切面实现#

4.3 事件类#

4.4 事件监听并保存日志#

5. Drools 动态规则引擎#

5.1 Drools 配置#

5.2 规则文件 audit-risk.drl#

6. 监控指标采集与可视化#

6.1 添加监控依赖并启用 Actuator#

6.2 配置 application.yml#

6.3 指标配置#

7. 控制器示例#

8. 结语#

支持与分享

评论区

音乐

文章目录

5.2 规则文件 `audit-risk.drl`#

6.2 配置 `application.yml`#