阅读数:104 评论数:0

一、简介

当把一个事件发布到Spring提供的ApplicationContext中，被监听器侦测到，就会执行对理原处理方法。

ApplicationContext继承了ApplicationEventPublisher接口，从而拥有事件发布的能力。但是实际ApplicationContext事件发布委托给ApplicationEventMulticaster执行。

二、使用方法

1、自定义发布的事件类，需要继承ApplicationiEvent或其扩展类。

import com.alibaba.fastjson.JSONObject;
import org.springframework.context.ApplicationEvent;

public class EsSaveEvent extends ApplicationEvent {

    private JSONObject data;

    public EsSaveEvent(JSONObject source) {
        super(source);
        this.data = source;
    }

    public JSONObject getData() {
        return data;
    }
}

2、监听事件

（1）使用注解@EventListener监听事件。

import com.alibaba.fastjson.JSONObject;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import java.util.Arrays;
import java.util.List;

@Component
public class EventListener {

    //监听事件
    @org.springframework.context.event.EventListener
    public void listenEvent(EsSaveEvent  event) {
        //可以添加事务处理
        //divide(event);
        JSONObject object = event.getData();
        //对数据进行处理
         System.out.println("data:"+object.toJSONString());
        }

    }

    //在监听器中重新开一个事务（可选）
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void divide(EsSaveEvent event) {
        System.out.println("事务处理");
    }


}

（2）基于ApplicationListener实现事件监听

@Component
public class DemoListener implements ApplicationListener<EsSaveEvent>{
  @Override
  public void onApplicationEvent(EsSaveEvent event){
    ....
  }
}

（3）如果需要异步监听 @Async

参见：Spring注解@EnableAsync @Async

3、使用ApplicationEventPublisher发布事件。

@Autowired
private ApplicationEventPublisher publisher;

public test(){
	JSONObject data=new JSONObject();
    publisher.publishEvent(new EsSaveEvent(data));
}