• spring监控配置

@Configuration@EnableAspectJAutoProxy(proxyTargetClass = true)**public class DruidAspectConfig {

  1. @Bean
  2. public DruidStatInterceptor druidStatInterceptor() {
  3.     DruidStatInterceptor dsInterceptor = new DruidStatInterceptor();
  4.     return dsInterceptor;
  5. }
  6. @Bean
  7. @Scope("prototype")
  8. public JdkRegexpMethodPointcut druidStatPointcut() {
  9.     JdkRegexpMethodPointcut pointcut = new JdkRegexpMethodPointcut();
  10.     pointcut.setPatterns("com.xxx.dao.*","com.xxx.service.*");
  11.     return pointcut;
  12. }
  13. @Bean
  14. public DefaultPointcutAdvisor druidStatAdvisor(DruidStatInterceptor druidStatInterceptor, JdkRegexpMethodPointcut druidStatPointcut) {
  15.     DefaultPointcutAdvisor defaultPointAdvisor = new DefaultPointcutAdvisor();
  16.     defaultPointAdvisor.setPointcut(druidStatPointcut);
  17.     defaultPointAdvisor.setAdvice(druidStatInterceptor);
  18.     return defaultPointAdvisor;
  19. }

}

  • sql监控配置

@Configurationpublic class DruidConfig {

  1. @Bean
  2. public Slf4jLogFilter logFilter () {
  4.     Slf4jLogFilter logFilter = new Slf4jLogFilter();
  5.     logFilter.setStatementExecutableSqlLogEnable(true);
  6.     logFilter.setStatementLogEnabled(false);
  7.     return logFilter;
  8. }
  10. @Bean
  11. public StatFilter statFilter () {
  13.     StatFilter statFilter = new StatFilter();
  14.     statFilter.setSlowSqlMillis(3000);
  15.     statFilter.setLogSlowSql(true);
  16.     statFilter.setMergeSql(true);
  17.     return statFilter;
  18. }
  20. /**
  21.  * sql防火墙过滤器配置
  22.  * @param wallConfig
  23.  * @return
  24.  */
  25. @Bean
  26. public WallFilter wallFilter (WallConfig wallConfig) {
  28.     WallFilter wallFilter = new WallFilter();
  29.     wallFilter.setConfig(wallConfig);
  30.     wallFilter.setLogViolation(true);//对被认为是攻击的SQL进行LOG.error输出
  31.     wallFilter.setThrowException(false);//对被认为是攻击的SQL抛出SQLException
  32.     return wallFilter;
  33. }
  35. /**
  36.  * sql防火墙配置
  37.  * @return
  38.  */
  39. @Bean
  40. public WallConfig wallConfig () {
  42.     WallConfig wallConfig = new WallConfig();
  43.     wallConfig.setAlterTableAllow(false);
  44.     wallConfig.setCreateTableAllow(false);
  45.     wallConfig.setDeleteAllow(false);
  46.     wallConfig.setMergeAllow(false);
  47.     wallConfig.setDescribeAllow(false);
  48.     wallConfig.setShowAllow(false);
  49.     return wallConfig;
  50. }

}

  • 注意引入aspectj支持，否则会报错

    org.aspectj aspectjrt xxx org.aspectj aspectjweaver xxxx