快捷導(dǎo)航

spring中EventListener的使用方式

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

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

spring自帶EventListener使用

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

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

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

舉例說(shuō)明

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

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

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

示例代碼

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

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)聽(tīng)者1

@Slf4j
@Service
public class EventListenerDemo {

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

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

@Slf4j
@Service
public class EventListenerDemo1 {

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

測(cè)試

@Slf4j
@SpringBootTest
class DemoApplicationTests {

    @Autowired
    private ApplicationContext applicationContext;

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

運(yùn)行結(jié)果