import org.springframework.context.MessageSource;

import org.springframework.context.MessageSourceAware;

package cn.hncu.p3.p2_TaskExecutor;

import org.springframework.scheduling.annotation.Async;

import org.springframework.stereotype.Service;

public class AsyncTaskService {

@Async

public void executeAsyncTask(Integer i){

System.out.println("executeAsyncTask:"+i);

}

@Async

public void executeAsyncTaskPlus(Integer i){

System.out.println("executeAsyncTaskPlus:"+i);

}

}

package cn.hncu.p3.p2_TaskExecutor;

import org.springframework.context.annotation.AnnotationConfigApplicationContext;

public class Main {

public static void main(String[] args) {

AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(TaskExecutorConfig.class);

AsyncTaskService asyncTaskService = context.getBean(AsyncTaskService.class);

for(int i=0;i<10;i++){

asyncTaskService.executeAsyncTaskPlus(i);

asyncTaskService.executeAsyncTask(i+1);

}

context.close();

}

}

package cn.hncu.p3.p2_TaskExecutor;

import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;

import org.springframework.context.annotation.ComponentScan;

import org.springframework.context.annotation.Configuration;

import org.springframework.scheduling.annotation.AsyncConfigurer;

import org.springframework.scheduling.annotation.EnableAsync;

import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;

@ComponentScan("cn.hncu.p3.p2_TaskExecutor")

@EnableAsync //利用@EnableAsync注解开启异步任务支持

public class TaskExecutorConfig implements AsyncConfigurer{

//配置类实现AsyncConfigurer接口并重写getAsyncExcutor方法，并返回一个ThreadPoolTaskExevutor

//这样我们就获得了一个基于线程池TaskExecutor

@Override

public Executor getAsyncExecutor() {

ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();

taskExecutor.setCorePoolSize(5);//线程池维护线程的最少数量

taskExecutor.setMaxPoolSize(10);//线程池维护线程的最大数量

taskExecutor.setQueueCapacity(25);//线程池所使用的缓冲队列

taskExecutor.initialize();

return taskExecutor;

}

@Override

public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {

return null;

}

}

#分析

Spring的依赖注入的最大亮点就是你所有的Bean对Spring容器的存在是没有意识的。

也就是说，你可以把你的容器换成别的容器，如Google Guice，这时Bean之间的耦合度很低。

但是在实际项目中，基本上不可避免的要用到Spring容器本身的功能资源，这时你的Bean必须要意识到Spring容器的存在，才能调用Spring所提供的资源，这就是所谓的Spring Aware。

其实Spring Aware本来就是Spring设计用来框架内部使用的，如果使用了Spring Aware，你的Bean就会和Spring框架耦合。也就不能换容器了。

现在把Spring提供的Aware接口列出来:

| Spring提供的Aware接口 ||

| ------------- |:-------------:|

| BeanNameAware | 获得容器中Bean的名称 |

| BeanFactoryAware | 获得当前bean factory，这样可以调用容器的服务 |

| ApplicationContextAware* | 当前的application context，这样可以调用容器的服务 |

| MessageSourceAware | 获得message source，这样可以获得文本信息 |

| ApplicationEventPublisherAware | 应用实践发布器，可以发布事件 |

| ResourceLoaderAware | 获得资源加载器，可以获得外部资源文件 |

Spring Aware的目的是为了让Bean获得Spring容器的服务。

因为ApplicationContext接口集成了MessageSource接口、ApplicationEventPublisher接口和ResourceLoader接口，所以Bean继承ApplicationContextAware可以获得Spring容器的所有服务，但是，原则上我们还是用到什么接口了，就实现什么接口。

在这里的示例，简单的演示BeanNameAware接口和ResourceLoaderAware接口。

一样的，进行本示例的演示，需要先配置好Maven和Spring哦、

见:

<a href="http://blog.csdn.net/qq_26525215/article/details/53010442" target='_blank'>【Spring】基于IntelliJ IDEA搭建Maven</a>

#示例

因为要演示外部资源，所以先准备好一个外部文件资源，

我就建在java文件目录下，test.txt文件，内容:

##Spring Aware 演示Bean

##配置类

##运行类

#运行结果