spring中EventListener的使用方式

更新時間：2023年12月14日 08:43:30 作者：不喜歡吃貓的魚

這篇文章主要介紹了spring中EventListener的使用方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

spring自帶EventListener使用

首先了解下事件監(jiān)聽的基本原理，這里使用到的是設(shè)計模式中的“’'觀察者模式"”模式。

監(jiān)聽監(jiān)聽監(jiān)聽事件發(fā)布者監(jiān)聽者A 監(jiān)聽者B 監(jiān)聽者C 監(jiān)聽到后處理自己的邏輯監(jiān)聽到后處理自己的邏輯監(jiān)聽到后處理自己的邏輯

整個的監(jiān)聽過程是通過一個事件觸發(fā)機制來實現(xiàn)，首先由事件發(fā)布者發(fā)布事件消息，對應(yīng)的監(jiān)聽者接收到消息后就處理自己的業(yè)務(wù)邏輯。

舉例說明

A是BCD三人的隊長，今天他們4人要去執(zhí)行一項任務(wù)。

在開始之前隊長已經(jīng)分別將各個人任務(wù)分配下去，行動的時候只要隊長A向各個隊員發(fā)送統(tǒng)一的行動指令“行動”，當(dāng)BCD接收到A的指令“行動”之后就馬上去處理各自的任務(wù)。

這里的A就做為事件發(fā)布者，BCD三人監(jiān)聽A發(fā)送的指令做出相應(yīng)的行動，整體的原理相對來說較為簡單。

示例代碼

創(chuàng)建事件發(fā)布實體對象

public class PushEvent extends ApplicationEvent {

    private String msg;

    public PushEvent(Object source, String msg) {
        super(source);
        this.msg = msg;
    }

    public String getMsg() {
        return msg;
    }

    public void setMsg(String msg) {
        this.msg = msg;
    }
}

創(chuàng)建監(jiān)聽者1

@Slf4j
@Service
public class EventListenerDemo {

   @EventListener
   public void eventListener(PushEvent event) {
       log.info(this.getClass().getSimpleName() + "監(jiān)聽到數(shù)據(jù)：" + event.getMsg());
   }
}

創(chuàng)建第二個監(jiān)聽者

@Slf4j
@Service
public class EventListenerDemo1 {

    @EventListener
    public void eventListener(PushEvent event){
        log.info(this.getClass().getSimpleName()+"監(jiān)聽到數(shù)據(jù)："+event.getMsg());
    }
}

測試

@Slf4j
@SpringBootTest
class DemoApplicationTests {

    @Autowired
    private ApplicationContext applicationContext;

    @Test
    public void publish() {
        String msg = "測試數(shù)據(jù)";
        log.info("發(fā)布信息：" + msg);
        ApplicationEvent event = new PushEvent(this, msg);
        applicationContext.publishEvent(event);
    }
}

運行結(jié)果