Spring Cloud Security监控示例-监控

@Component
public class SecurityMonitor implements HealthIndicator {

  @Autowired
  private SecurityMetrics securityMetrics;

  @Override
  public Health health() {
    Map<String, Object> details = new HashMap<>();
    details.put("login.count", securityMetrics.loginCounter.count());
    details.put("session.time.max", securityMetrics.sessionTimer.max(TimeUnit.MILLISECONDS));
    details.put("session.time.mean", securityMetrics.sessionTimer.mean(TimeUnit.MILLISECONDS));

    return Health.status("UP")
      .withDetails(details)
      .build();
  }

}

@SpringBootApplication
@EnableWebSecurity
@EnablePrometheusMetrics
public class Application extends WebSecurityConfigurerAdapter {

  public static void main(String[] args) {
    SpringApplication.run(Application.class, args);
  }

  @Autowired
  private SecurityMonitor securityMonitor;

  @Override
  protected void configure(HttpSecurity http) throws Exception {
    http
      .authorizeRequests()
        .antMatchers("/public/**").permitAll()
        .anyRequest().authenticated()
        .and()
      .formLogin()
        .loginPage("/login")
        .permitAll()
        .and()
      .logout()
        .logoutSuccessUrl("/login?logout")
        .permitAll()
      .and()
      .csrf().disable();
  }

  @Autowired
  public void configureGlobal(AuthenticationManagerBuilder auth) throws Exception {
    auth
      .inMemoryAuthentication()
        .withUser("user").password("{noop}password").roles("USER")
        .and()
        .withUser("admin").password("{noop}password").roles("USER", "ADMIN");
  }

  @Bean
  public SecurityMetrics securityMetrics() {
    return new SecurityMetrics();
  }

  @Bean
  public MetricsConfigurerAdapter metricsConfigurerAdapter() {
    return new MetricsConfigurerAdapter() {
      @Override
      public void configureReporters(MetricRegistry metricRegistry) {
        ConsoleReporter.forRegistry(metricRegistry)
          .convertRatesTo(TimeUnit.SECONDS)
          .convertDurationsTo(TimeUnit.MILLISECONDS)
          .build()
          .start(10, TimeUnit.SECONDS);
      }
    };
  }

  @Bean
  public ServletContextInitializer initializer() {
    return servletContext -> {
      // Register the Metrics Servlet
      MetricsServlet metricsServlet = new MetricsServlet();
      ServletRegistration.Dynamic servletRegistration = servletContext.addServlet("metrics", metricsServlet);
      servletRegistration.addMapping("/metrics/*");

      // Register the Metrics Filter
      FilterRegistration.Dynamic filterRegistration = servletContext.addFilter("metricsFilter", new InstrumentedFilter());
      filterRegistration.addMappingForUrlPatterns(EnumSet.of(DispatcherType.REQUEST), false, "/*");

      // Register the Prometheus Exporter
      ExporterRegistrationListener exporterRegistrationListener = new ExporterRegistrationListener(securityMetrics());
      servletContext.addListener(exporterRegistrationListener);
    };
  }

  @Bean
  public PrometheusEndpoint prometheusEndpoint() {
    return new PrometheusEndpoint();
  }

  @Bean
  public HealthIndicator securityMonitor() {
    return securityMonitor;
  }

}