投稿
  1. 簡單一點首頁
  2. 編程

SpringBoot集成的多個方面

TVYR • • 編程

一、SpringBoot集成AD

SpringBoot可以輕鬆地集成Active Directory，來實現用戶身份驗證和訪問控制。可以使用Spring Security和Spring LDAP庫來實現這一點。要使用這些庫，可以按照以下步驟進行：

1、在pom.xml文件中引入spring-boot-starter-security和spring-ldap-core依賴：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-security</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.ldap</groupId>
    <artifactId>spring-ldap-core</artifactId>
</dependency>

2、在application.properties文件中添加Spring Security配置信息：

spring.security.user.name=user
spring.security.user.password=password
spring.security.user.roles=user
spring.ldap.urls=ldap://ad-server:389
spring.ldap.base=dc=example,dc=com
spring.ldap.username=uid={0},ou=people
spring.ldap.passwordParameter=password
spring.ldap.rolePrefix=ROLE_

3、創建一個LDAP用戶存儲庫和一個安全配置類：

public class LdapUserRepository implements UserDetailsService {
    private LdapTemplate ldapTemplate;
    
    public LdapUserRepository(LdapTemplate ldapTemplate) {
        this.ldapTemplate = ldapTemplate;
    }
    
    public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
        AndFilter filter = new AndFilter();
        filter.and(new EqualsFilter("objectclass", "person")).and(new EqualsFilter("uid", username));
        
        List<LdapUserDetailsImpl> users = ldapTemplate.search("", filter.encode(),
                new LdapUserDetailsImpl());
        if (users.isEmpty()) {
            throw new UsernameNotFoundException("User not found.");
        }
        
        return users.get(0);
    }
}

@Configuration
@EnableWebSecurity
public class SecurityConfig extends WebSecurityConfigurerAdapter {
    @Autowired
    private LdapTemplate ldapTemplate;
    
    @Autowired
    private LdapUserRepository ldapUserRepository;
    
    @Override
    protected void configure(HttpSecurity http) throws Exception {
        http.authorizeRequests().anyRequest().authenticated().and().formLogin()
            .defaultSuccessUrl("/home").permitAll().and().logout().permitAll();
    }

    @Override
    public void configure(AuthenticationManagerBuilder auth) throws Exception {
        auth.userDetailsService(ldapUserRepository).passwordEncoder(new LdapShaPasswordEncoder());
    }
    
    @Bean
    public LdapTemplate ldapTemplate() {
        return new LdapTemplate(new LdapContextSource());
    }
    
    @Bean
    public LdapUserRepository ldapUserRepository() {
        return new LdapUserRepository(ldapTemplate);
    }
}

在這個例子中，LDAP用戶存儲庫實現了UserDetailsService接口，並且重寫了loadUserByUsername方法來使用LdapTemplate從LDAP中檢索用戶詳細信息。安全配置使用WebSecurityConfigurerAdapter來配置Spring Security，並且將LdapUserRepository和LdapShaPasswordEncoder設置為身份驗證管理器。

二、SpringBoot集成AOP

SpringBoot使得使用AOP變得簡單，可以使用Spring AOP或AspectJ框架來實現面向切面的編程。下面是一個基於AspectJ的例子：

@Aspect
@Component
public class MyAspect {
    @Around("@annotation(MyAnnotation)")
    public Object doAround(ProceedingJoinPoint point) throws Throwable {
        // do something before the method is called
        Object result = point.proceed();
        // do something after the method is called
        return result;
    }
}

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface MyAnnotation {

}

@Service
public class MyService {
    @MyAnnotation
    public void myMethod() {
        // do something
    }
}

在這個例子中，定義了一個MyAspect切面，它繞着有@MyAnnotation註解的方法進行處理。在MyService中的myMethod方法使用了@MyAnnotation註解，這個方法將在調用之前和之後都調用MyAspect中的doAround方法。

三、SpringBoot集成MVC

SpringBoot利用自動配置功能，可以很容易地集成Spring MVC，開發RESTful API。使用Spring MVC，可以輕鬆地創建基於HTTP的服務，如以下例子：

@RestController
@RequestMapping("/api")
public class MyController {
    @GetMapping("/my-method")
    public ResponseEntity<String> myMethod() {
        return ResponseEntity.ok("Hello, world!");
    }
}

在這個例子中，MyController類使用@RestController和@RequestMapping註解來定義一個基於HTTP的服務。使用@GetMapping註解來定義一個GET方法可以處理來自/api/my-method的HTTP請求，返回一個字符串形式的HTTP響應。

四、SpringBoot集成ES

SpringBoot可以很容易地集成Elasticsearch搜索引擎，使用Spring Data Elasticsearch庫。Spring Data Elasticsearch旨在為Spring開發人員提供易於使用的Elasticsearch客戶端和存儲庫。使用Spring Data Elasticsearch，可以輕鬆地進行索引和搜索。

以下是一個基本的例子：

@Configuration
@EnableElasticsearchRepositories(basePackages = "com.example.repository")
public class ElasticsearchConfig extends AbstractElasticsearchConfiguration {
    @Value("${elasticsearch.host}")
    private String host;

    @Value("${elasticsearch.port}")
    private int port;

    @Bean
    @Override
    public RestHighLevelClient elasticsearchClient() {
        final ClientConfiguration clientConfiguration = ClientConfiguration.builder()
            .connectedTo(host + ":" + port)
            .build();

        return RestClients.create(clientConfiguration).rest();
    }
}

@Document(indexName = "my_index", type = "my_type")
public class MyEntity {
    @Id
    private String id;

    private String field1;

    private String field2;

    // getters and setters omitted
}

public interface MyRepository extends ElasticsearchRepository<MyEntity, String> {
    List<MyEntity> findByField1(String field1);
}

@RestController
@RequestMapping("/api")
public class MyController {
    @Autowired
    private MyRepository myRepository;

    @GetMapping("/search")
    public ResponseEntity<List<MyEntity>> search(@RequestParam("q") String query) {
        List<MyEntity> result = myRepository.findByField1(query);
        return ResponseEntity.ok(result);
    }
}

在這個例子中，配置了Elasticsearch的客戶端和存儲庫配置類。MyEntity類是一個帶有@Id註解的Spring Data Elasticsearch實體，MyRepository接口繼承了ElasticsearchRepository並定義了一個簡單的方法。MyController類使用MyRepository來搜索通過HTTP請求參數傳遞的字符串，並返回HTTP響應。

五、SpringBoot集成OSS

SpringBoot可以輕鬆地集成各種對象存儲服務，如Amazon S3，Microsoft Azure Blob存儲等。這些存儲服務可用於存儲和檢索文件、圖像、視頻和其他多媒體資料。下面使用阿里雲OSS作為例子：

@Configuration
public class OSSConfig {
    @Value("${aliyun.oss.endpoint}")
    private String endpoint;

    @Value("${aliyun.oss.accessKeyId}")
    private String accessKeyId;

    @Value("${aliyun.oss.accessKeySecret}")
    private String accessKeySecret;

    @Value("${aliyun.oss.bucketName}")
    private String bucketName;

    @Bean
    public OSS ossClient() {
        return new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
    }

    @Bean
    public CommandLineRunner init(OSS ossClient) {
        return args -> ossClient.createBucket(bucketName);
    }

    @PreDestroy
    public void cleanUp() {
        ossClient.deleteBucket(bucketName);
    }
}

@RestController
@RequestMapping("/api")
public class MyController {
    @Autowired
    private OSS ossClient;

    @PostMapping("/upload-file")
    public String uploadFile(@RequestParam("file") MultipartFile file) throws IOException {
        String filename = UUID.randomUUID().toString() + "." + FilenameUtils.getExtension(file.getOriginalFilename());
        ossClient.putObject(bucketName, filename, file.getInputStream());
        return filename;
    }
}

在這個例子中，使用@Configuration註解的配置類來配置OSS客戶端和Bucket存儲庫。使用CommandLineRunner從應用程序啟動時創建Bucket。在應用程序退出時刪除Bucket，使用@PreDestroy註解的cleanUp方法。MyController類使用Spring MVC的@PostMapping註解來定義一個上傳文件的HTTP POST方法。使用OSSClient將文件上傳到阿里雲OSS中，返回生成的文件名。MultipartFile是一個Spring框架提供的用於處理多部分文件上傳的接口。

六、SpringBoot集成了什麼

SpringBoot集成了很多有用的庫和框架，使得開發和集成變得更加輕鬆。例如：

  • Spring Data MongoDB：用於集成MongoDB數據庫的Spring Data子項目。
  • Spring Batch：Spring框架提供的批處理框架，用於大數據量處理。
  • Spring Cloud Stream：用於構建消息驅動的微服務。
  • Thymeleaf：一個流行的Web模板引擎，用於生成動態HTML。
  • Apache CXF：用於構建Web服務的開源框架。

這些庫和框架都可以通過在pom.xml文件中添加相應的依賴來輕鬆地集成到SpringBoot應用程序中。

七、SpringBoot集成ELK

SpringBoot與Elasticsearch，Logstash和Kibana（ELK）堆棧的集成，可以將日誌轉換為可搜索、可過濾和可視化的格式。下面的例子展示了如何集成一個基本的ELK堆棧：

@Configuration
public class LogstashConfig {
    @Value("${spring.application.name}")
    private String appName;

    @Value("${logging.file}")
    private String logPath;

    @Bean
    public LogstashTcpSocketAppender logstashAppender() {
        LogstashTcpSocketAppender appender = new LogstashTcpSocketAppender();  
        appender.setName("LOGSTASH");  
        appender.setEncoding(Charset.forName("UTF-8")); 
        appender.setContext(LoggerContext.getContext());  
        appender.addDestination("localhost:4560");  

        PatternLayout patternLayout = new PatternLayout();  
        patternLayout.setPattern("%d{yyyy-MM-dd HH:mm:ss.SSS} %5p ${spring.application.name} --- [%15.15t] %-40.40logger{39} : %msg%n%throwable{short.message}%n");  
        patternLayout.setContext(LoggerContext.getContext());  
        patternLayout.start();  
        appender.setLayout(patternLayout);  

        appender.start();  
          
        return appender;  
    }

    @Bean
    public TcpSyslogAppender tcpSyslogAppender() {
        TcpSyslogAppender appender = new TcpSyslogAppender();
        appender.setName("TCP_SYSLOG");

        appender.addFilter(new ThresholdFilter(Level.INFO));

        appender.setSyslogHost("localhost");
        appender.setPort(514);

        PatternLayoutEncoder encoder = new PatternLayoutEncoder();
        encoder.setPattern("%d{yyyy-MM-dd HH:mm:ss.SSS} %5p ${spring.application.name} --- [%15.15t] %-40.40logger{39} : %msg%n%throwable{short.message}%n");
        appender.setEncoder(encoder);

        appender.start();

        return appender;
    }

    @Bean
    public Logger logger() {
        Logger logger = (Logger) LoggerFactory.getLogger("com.example");
        logger.addAppender(logstashAppender());
        logger.addAppender(tcpSyslogAppender());
        logger.setLevel(Level.INFO);
        logger.setAdditive(false);

        return logger;
    }
}

@ControllerAdvice
public class ExceptionControllerAdvice {
    @ExceptionHandler(Exception.class)
    public ResponseEntity<Map<String, Object>> handleException(Exception e) {
        Map<String, Object> result = new HashMap<>();
        result.put("message", e.getMessage());
        result.put("error", true);
        return new ResponseEntity<>(result, HttpStatus.INTERNAL_SERVER_ERROR);
    }
}

@SpringBootApplication
@EnableAsync
public class MyApplication {
    public static void main(String[] args) {
        SpringApplication.run(MyApplication.class, args);
    }
}

@RestController
@RequestMapping("/api")
public class MyController {
    @GetMapping("/my-method")
    public String myMethod() {
        throw new RuntimeException("Something went wrong.");
    }
}

在這個例子中，LogstashConfig配置了兩個appender，一個是LogstashTcpSocketAppender用於將

原創文章，作者：TVYR，如若轉載，請註明出處：https://www.506064.com/zh-hk/n/142687.html

贊 (0)
打賞 微信掃一掃 微信掃一掃 支付寶掃一掃 支付寶掃一掃
TVYR的頭像TVYR
0 0
上一篇 2024-10-12 09:45
下一篇 2024-10-12 09:45

相關推薦

發表回復

登錄後才能評論