guava的事件发布订阅功能

事件的重要性，不用说很重要，在不少时候咱们作完一个操做的时候,须要告知另一个对象让他执行相应操做，好比当用户注册成功的时候，须要抛出一个注册成功的事件，那么有监听器捕获到这个事件，完成后续用户信息初始化的功能。

其实事件发布订阅很简单，总得来讲就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 {
    @Autowired
    private EventBus eventBus;//自动注入guava的EventBus

    @RpcConsumer
    private UserService userService;

    public VegaUserRegisterListener(){
        super();
    }

    @PostConstruct
    public void register() {
        eventBus.register(this);
    }//构造方法完成后，将这个监听器注册到EventBus中，至关于订阅

    @Subscribe//这个注解就是捕获到相应事件后处理对应函数
    public void initUserRank(UserRegisteredEvent userRegisteredEvent) {
     userService.initUserRank(userRegisteredEvent.getUserId());//初始化用户信息
    
    }

}

 

ok，完成是否是很简单，事件的抛出只须要在须要抛出的地方调用 eventBus.post(Object object)方法便可。