spring事件广播机制

曾经终败给现在 2022-05-27 06:51 264阅读 0赞

打个比方，当我们和其他公司进行业务接口对接时，我们这边需要保存或者修改某些数据，但是保存和修改这些数据对整个流程没有太大的影响,这个时候我们应该怎么做呢？是的，我们要考虑异步去保存或者修改数据，但怎么去异步保存数据呢？这个时候我们就可以使用事件广播来做这个操作

看过spring源码的大神都知道，当我们初始化容器的过程中，我们会有initApplicationEventMulticaster()--->此方法在org.springframework.context.support.AbstractApplicationContext.refresh()中，默认情况使用的事件广播是SimpleApplicationEventMulticaster这个类，这个类中有Executor接口，感觉是不是很熟悉？提示一下，线程池。如果还不熟悉的请自行百度，我们需要手动去设置这个线程池，该怎么配置呢？请看

<bean id="applicationEventMulticaster" class="org.springframework.context.event.SimpleApplicationEventMulticaster">
        <property name="taskExecutor" ref="coreTaskExecutor"/>
    </bean>
    
    <bean id="coreTaskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
        <property name="corePoolSize" value="10"/>
        <property name="maxPoolSize" value="20"/>
        <property name="queueCapacity" value="25"/>
        <property name="threadNamePrefix" value="coreTaskExecutor"/>
    </bean>

在applicationContext.xml中配置，如果使用的springboot,可以使用

@ImportResource**(****"classpath:applicationContext.xml"****)**

来导入xml文件

配置好了之后，我们可以定义我们自己的事件和监听器了

创建事件类，需要继承ApplicationEvent

public class TestEvent extends ApplicationEvent {
    
       public TestEvent(Object source) {
          super(source);
       }
    }

Object对象就是我们需要传递的参数

接着，定义我们的监听，需要实现ApplicationListener这个接口

public class TestListener implements ApplicationListener {
       @Override
       public void onApplicationEvent(ApplicationEvent event) {
          if(!(event instanceof TestEvent)){
             return;
          }
          event.getSource();//获取传递的参数,即：和TestEvent中的source一样的 //再次处理业务逻辑    TODO     }
    }

我们主要是在监听器中处理业务逻辑

是不是想到了个问题，参数怎么传递过来的呢？别着急，我们慢慢来

参数当然是从我们正常处理业务逻辑代码中传递过来的了，监听器中的代码只是处理分支的情况，正常情况，我们一般都是在service的实现类中进行事件广播并传递参数，此类必须实现ApplicationContextAware这个接口

public class TestServiceImpl implements ApplicationContextAware{
       ApplicationContext applicationContext;
    
       @Override
       public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
          this.applicationContext = applicationContext;
       }
    
       public void test(){
          String datas = "";//传递参数也可以是map、list、实体对象等 applicationContext.publishEvent(new TestEvent(datas));
       }
    }

那么在监听器中就可以接收到datas数据了，然后就可以愉快的进行代码编写了

努力成就非凡，请不要在最该奋斗的年纪选择安逸