spring boot @Configuration、@ImportResource使用

我不是女神ヾ 2022-05-31 11:58 188阅读 0赞

在spring mvc中一般采用xml配置一些第三方属性，而spring boot比较多还是采用@Configuration注解方式，那么如何将xml中配置转换成@Configuration配置呢？下面以配置线程池ThreadPoolTaskExecutor为例。

xml配置如下：

<bean id="threadPoolTaskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
         <property name="corePoolSize" value="50"/>
         <property name="maxPoolSize" value="100"/>
         <property name="queueCapacity" value="200"/>
         <property name="keepAliveSeconds" value="300"/>
         <property name="rejectedExecutionHandler">
                <bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy"/>
        </property>
    </bean>

新建MyThreadPoolConfig类，作为配置类，具体代码如何下

package com.test.mqtest.config;

import java.util.concurrent.ThreadPoolExecutor;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

@Configuration

public class MyThreadPoolConfig \{

privateintcorePoolSize = 50;//线程池维护线程的最少数量

privateintmaxPoolSize = 100;//线程池维护线程的最大数量

private int queueCapacity = 200; //缓存队列

private int keepAlive = 300;//允许的空闲时间

@Bean

public ThreadPoolTaskExecutor threadPoolExecutor()\{

ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();

executor.setCorePoolSize(corePoolSize);

executor.setMaxPoolSize(maxPoolSize);

executor.setQueueCapacity(queueCapacity);

executor.setThreadNamePrefix("mqExecutor-");

// rejection-policy：当pool已经达到max size的时候，如何处理新任务

// CALLER\_RUNS：不在新线程中执行任务，而是由调用者所在的线程来执行

executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); //对拒绝task的处理策略

executor.setKeepAliveSeconds(keepAlive);

executor.initialize();

return executor;

如何使用呢？采用注解方式，如下：

@Autowired

ThreadPoolTaskExecutor threadPoolTaskExecutor;

另外一种方法，使用@ImportResource("classpath:MyThreadPoolConfig.xml")引用xml文件。

package com.test.mqtest.config;  
  
  
import java.util.concurrent.ThreadPoolExecutor;  
  
  
import org.springframework.context.annotation.Bean;  
import org.springframework.context.annotation.Conditional;  
import org.springframework.context.annotation.Configuration;  
import org.springframework.context.annotation.ImportResource;  
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;  
  
public class MyThreadPool \{  
  
@Configuration  
@ImportResource("classpath:MyThreadPoolConfig.xml")  
static class MyThreadPoolConfig \{  
\}      
\}