package com.ecworking.event;import org.springframework.context.ApplicationEvent;public class DemoEvent extends ApplicationEvent{private static final long serialVersionUID = 1L;private String msg;public DemoEvent(Object source, String msg) {super(source);this.msg = msg;}public String getMsg() {return msg;}public void setMsg(String msg) {this.msg = msg;}
}

package com.ecworking.event;import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;@Component
public class DemoListener implements ApplicationListener<DemoEvent> { //实现ApplicationListener接口，并指定监听的事件类型。public void onApplicationEvent(DemoEvent event){ //使用onApplicationEvent方法对消息进行接受处理。String msg = event.getMsg();System.out.println("bean-demoListener 接收到了 bean-demoPublisher 发布的消息：" + msg);}
}

package com.ecworking.event;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;@Component
public class DemoPublisher {@AutowiredApplicationContext applicationContext; //注入ApplicationContext用来发布事件。public void publish(String msg){applicationContext.publishEvent(new DemoEvent(this, msg)); //使用 ApplcationContext 的 publishEvent 方法来发布。
    }
}

package com.ecworking.event;import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;@Configuration
@ComponentScan("com.ecworking.event")
public class EventConfig {
}

package com.ecworking.event;import org.springframework.context.annotation.AnnotationConfigApplicationContext;public class Main {public static void main(String[] args) {AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(EventConfig.class);DemoPublisher demoPublisher = context.getBean(DemoPublisher.class);demoPublisher.publish("hello application event");context.close();}
}