码迷,mamicode.com
首页 > 移动开发 > 详细

Spring----事件(Application Event)

时间:2019-11-19 17:30:01      阅读:86      评论:0      收藏:0      [点我收藏+]

标签:ide   span   lis   system   under   容器   config   over   void   

1、概述

    1.1、Spring的事件  为Bean与Bean之间的消息通信提供了支持

        当一个Bean处理完一个任务后,希望另一个Bean知道并能做出相应的处理,这时我们需要   让另一个Bean  监听  当前Bean所发送的事件

    1.2、Spring的事件需要遵循如下流程:

        a,自定义事件,继承ApplicationEvent

        b,定义事件监听器,实现ApplicationListener

        c,使用容器发布事件   

    1.3、eg:

package com.an.config;

import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;

/**
 * @description: 事件配置类
 * @author: anpeiyong
 * @date: Created in 2019/11/19 16:41
 * @since:
 */
@Configuration
@ComponentScan(value = "com.an")
public class EventConfig {
}

  

package com.an.event;

import org.springframework.context.ApplicationEvent;

/**
 * @description: 自定义事件
 * @author: anpeiyong
 * @date: Created in 2019/11/19 16:32
 * @since:
 */
public class MyEvent extends ApplicationEvent {

    private String msg;

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

    public String getMsg() {
        return msg;
    }

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

  

package com.an.event;

import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;

/**
 * @description: 自定义事件监听器
 *              实现ApplicationListener接口,并指定监听的事件类型ApplicationListener<MyEvent>
 *              使用onApplicationEvent()方法对消息进行接收处理
 * @author: anpeiyong
 * @date: Created in 2019/11/19 16:34
 * @since:
 */
@Component
public class MyListener implements ApplicationListener<MyEvent> {

    @Override
    public void onApplicationEvent(MyEvent event) {
        String msg=event.getMsg();
        System.out.println("我接收到的消息:"+msg);
    }
}

  

package com.an.event;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;

/**
 * @description:
 * @author: anpeiyong
 * @date: Created in 2019/11/19 16:38
 * @since:
 */
@Component
public class MyPublisher {

    //注入ApplicationContext,用来发布事件
    @Autowired
    ApplicationContext applicationContext;

    public void publish(String msg){
        //使用ApplicationContext.publishEvent()发布
        applicationContext.publishEvent(new MyEvent(this,msg));
    }
}

  

package com.an.main;

import com.an.config.EventConfig;
import com.an.event.MyPublisher;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;

/**
 * @description:
 * @author: anpeiyong
 * @date: Created in 2019/11/19 16:41
 * @since:
 */
public class EventMainTest {

    public static void main(String[] args) {
        AnnotationConfigApplicationContext annotationConfigApplicationContext=new AnnotationConfigApplicationContext(EventConfig.class);
        MyPublisher myPublisher=annotationConfigApplicationContext.getBean(MyPublisher.class);
        myPublisher.publish("hello");
        annotationConfigApplicationContext.close();
    }

}

  

结果:

我接收到的消息:hello

  

 

Spring----事件(Application Event)

标签:ide   span   lis   system   under   容器   config   over   void   

原文地址:https://www.cnblogs.com/anpeiyong/p/11890540.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!