Spring应用程序事件

一、定义应用程序事件

MessageEvent.java

package com.airkisser;

import org.springframework.context.ApplicationEvent;

public class MessageEvent extends ApplicationEvent {

    public MessageEvent(Object source) {
        super(source);
    }

}

二、发布应用程序事件

package com.airkisser;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import java.util.Date;

@Service
public class EventPublisher {

    @Autowired
    private ApplicationEventPublisher eventPublisher;

    @Scheduled(fixedDelay = 1000L)//每秒执行一次
    public void publish() {
        // 发布事件
        eventPublisher.publishEvent(new MessageEvent(new Date()));
    }

}

三、订阅应用程序事件

package com.airkisser;

import org.springframework.context.ApplicationEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Service;

@Service
public class EventListener implements ApplicationListener<ApplicationEvent> {

    @Override
    public void onApplicationEvent(ApplicationEvent event) {
        if (event instanceof MessageEvent) {
            System.out.println(event.getSource());
        }
    }

}

四、结果

Mon Mar 13 11:04:52 CST 2017
Mon Mar 13 11:04:53 CST 2017
Mon Mar 13 11:04:54 CST 2017
Mon Mar 13 11:04:55 CST 2017
Mon Mar 13 11:04:56 CST 2017
Mon Mar 13 11:04:57 CST 2017
Mon Mar 13 11:04:58 CST 2017