ApplicationEventPublisher异步解耦

• 2020博客地址汇总
• 2019年博客汇总

需求

当用户注册后&＃xff0c;给他发送一封邮件通知他注册成功了&＃xff0c;然后给他初始化积分&＃xff0c;再发放一张新用户注册优惠券等。

用户注册事件

public class UserRegisterEvent extends ApplicationEvent{public UserRegisterEvent(String name) { //name即source 复杂的对象&＃xff0c;但注意要了解清楚序列化机制super(name);}
}


用户注册服务发布者

&＃64;Service
public class UserService {&＃64;Autowiredprivate ApplicationEventPublisher applicationEventPublisher;public void register(String name) {System.out.println("用户&＃xff1a;" &＃43; name &＃43; " 已注册&＃xff01;");applicationEventPublisher.publishEvent(new UserRegisterEvent(name));}
}


注意&＃xff1a;再Spring中&＃xff0c;服务必须交给 Spring 容器托管。ApplicationEventPublisherAware 是由 Spring 提供的用于为 Service 注入 ApplicationEventPublisher 事件发布器的接口&＃xff0c;使用这个接口&＃xff0c;我们自己的 Service 就拥有了发布事件的能力。用户注册后&＃xff0c;不再是显示调用其他的业务 Service&＃xff0c;而是发布一个用户注册事件。

创建事件订阅者&＃xff08;邮件服务、积分服务等&＃xff09;

&＃64;Service
public class EmailService implements ApplicationListener {&＃64;Overridepublic void onApplicationEvent(UserRegisterEvent userRegisterEvent) {System.out.println("邮件服务接到通知&＃xff0c;给 " &＃43; userRegisterEvent.getSource() &＃43; " 发送邮件...");}
}


注意&＃xff1a;事件订阅者的服务同样需要托管于 Spring 容器&＃xff0c;ApplicationListener接口是由 Spring 提供的事件订阅者必须实现的接口&＃xff0c;我们一般把该 Service 关心的事件类型作为泛型传入。处理事件&＃xff0c;通过 event.getSource() 即可拿到事件的具体内容&＃xff0c;在本例中便是用户的姓名。

SpringBoot 测试启动类

&＃64;SpringBootApplication
&＃64;RestController
public class EventDemoApp {public static void main(String[] args) {SpringApplication.run(EventDemoApp.class, args);}&＃64;AutowiredUserService userService;&＃64;RequestMapping("/register")public String register(){userService.register("zhangsan");return "success";}
}