spring 3中的@async初探

  在spring 3中，@Async注解能让某个方法快速变为异步执行，马上来先DEMO上手下。

假如在网站的用户注册后，需要发送邮件，然后用户得到邮件确认后才能继续其他工作；
假设发送是一个很耗费时间的过程，因此需要异步。

1 namespace要注意，加上task
  

<?xml version=”1.0″ encoding=”UTF-8″?>

<beans xmlns=”http://www.springframework.org/schema/beans” xmlns:xsi=”http://www.w3.org/2001/XMLSchema-instance”
xmlns:p=”http://www.springframework.org/schema/p” xmlns:context=”http://www.springframework.org/schema/context”
xsi:schemaLocation=”
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd
http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.0.xsd”>

<context:component-scan base-package=”cs”/>

</beans>

2 RegularService.java 注册类
  

 import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import cs.async.MailUtility;

@Service
public class RegularService {

@Autowired
private MailUtility mailUtility ;

public void registerUser(String userName){

System.out.println(” User registration for  “+userName +” complete”);

mailUtility.sendMail(userName);

System.out.println(” 注册完成，邮件稍后发送“);
}

}

3 发送邮件的工具类
   
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

@Component
public class MailUtility {

@Async
public void sendMail(String name){

System.out.println(” 在做发送准备工作中  “);

try {
Thread.sleep(5000);

} catch (InterruptedException e) {

e.printStackTrace();
}

System.out.println(” 异步发送完毕“);

}

}




4 最后在applicationContext.xml中加入：

  
<?xml version=”1.0″ encoding=”UTF-8″?>

<beans xmlns=”http://www.springframework.org/schema/beans” xmlns:xsi=”http://www.w3.org/2001/XMLSchema-instance”
xmlns:p=”http://www.springframework.org/schema/p” xmlns:context=”http://www.springframework.org/schema/context”
xmlns:task=”http://www.springframework.org/schema/task”
xsi:schemaLocation=”
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd
http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.0.xsd“>

<context:component-scan base-package=”cs”/>

<task:annotation-driven/>

</beans>


   就是<task:annotation-driven/>这个一定不能少喔。



5 运行：

   User registration for  tom complete

  注册完成，邮件稍后发送

在做发送准备工作中

异步发送完毕



6 有的时候，要从异步中返回值，这个时候，spring会返回一个java.util.concurrent.Future对象，要调用其中的get方法，比如

   
@Async
public Future<Balance> findBalanceAsync(final Account account) {
    Balance balance = accountRepository.findBalance(account);
    return new AsyncResult<Balance>(balance);
}

Balance balance = future.get();



   

评论

9 楼 jackyrong 2013-04-30  

huang_yong 写道

请教一个问题：

若@Async定义在@Service类的方法上，则无法实现异步效果？例如：

@Service
public class MailServiceImpl implements MailService {
    [color=red]@Async[/color]
    @Override
    public void sendMail(...) {
        ...
    }
}

以上无法实现异步调用。若在该类中封装一个private方法，则仍然无法实现。

若单独定义一个@Component类，在该类的方法上使用@Async，则可以实现异步效果。例如：

@Component
public class MailSender {
    [color=red]@Async[/color]
    public void send(...) {
        ...
    }
}

在MailServiceImpl注入MailSender，并调用send方法，这样可以实现异步调用。

应该是的

8 楼 huang_yong 2013-04-29  

请教一个问题：

若@Async定义在@Service类的方法上，则无法实现异步效果？例如：

@Service
public class MailServiceImpl implements MailService {
    [color=red]@Async[/color]
    @Override
    public void sendMail(...) {
        ...
    }
}

以上无法实现异步调用。若在该类中封装一个private方法，则仍然无法实现。

若单独定义一个@Component类，在该类的方法上使用@Async，则可以实现异步效果。例如：

@Component
public class MailSender {
    [color=red]@Async[/color]
    public void send(...) {
        ...
    }
}

在MailServiceImpl注入MailSender，并调用send方法，这样可以实现异步调用。

7 楼 宋建勇 2012-11-21  

jd2bs 写道

Future.get() 貌似阻塞的，最好写成

if（Future..isDone()）{
   Future.get();
}


http://www.cnblogs.com/uptownBoy/articles/1772483.html   

nice

6 楼 freezingsky 2012-11-19  

kjj 写道

宋建勇 写道

不过，从异步中返回值的话就没有达到异步的效果

返回值为啥就没有异步效果！！

我只能说1楼想多了！

5 楼 jackyrong 2012-11-17  

jd2bs 写道

Future.get() 貌似阻塞的，最好写成

if（Future..isDone()）{
   Future.get();
}


http://www.cnblogs.com/uptownBoy/articles/1772483.html   

GOOD

4 楼 jd2bs 2012-11-17  

Future.get() 貌似阻塞的，最好写成

if（Future..isDone()）{
   Future.get();
}


http://www.cnblogs.com/uptownBoy/articles/1772483.html   

3 楼 kjj 2012-11-17  

宋建勇 写道

不过，从异步中返回值的话就没有达到异步的效果

返回值为啥就没有异步效果！！

2 楼 宋建勇 2012-11-17  

不过，从异步中返回值的话就没有达到异步的效果

1 楼 宋建勇 2012-11-17