事件的重要性,不用说很重要,在很多时候我们做完一个操作的时候,需要告知另外一个对象让他执行相应操作,比如当用户注册成功的时候,需要抛出一个注册成功的事件,那么有监听器捕获到这个事件,完成后续用户信息初始化的功能。
其实事件发布订阅很简单,总得来说就2个重要对象:①事件的定义②监听器的定义
一,事件的定义
guava的事件定义不需要继承某个类或者实现某个接口,只需要正常的java bean对象即可
public class UserRegisteredEvent implements Serializable {private static final long serialVersionUID = 0L;private Long userId;public UserRegisteredEvent(Long userId) {this.userId = userId;}public Long getUserId() {return this.userId;} }//用户注册事件,这个事件抛出的时候可以携带传递一个用户的ID
二,监听器的编写
@Component public class UserRegisterListener {@Autowiredprivate EventBus eventBus;//自动注入guava的EventBus @RpcConsumerprivate UserService userService;public VegaUserRegisterListener(){super();}@PostConstructpublic void register() {eventBus.register(this);}//构造方法完成后,将这个监听器注册到EventBus中,相当于订阅 @Subscribe//这个注解就是捕获到相应事件后处理对应函数public void initUserRank(UserRegisteredEvent userRegisteredEvent) {userService.initUserRank(userRegisteredEvent.getUserId());//初始化用户信息 }}
ok,完成是不是很简单,事件的抛出只需要在需要抛出的地方调用 eventBus.post(Object object)方法即可。