广告
返回顶部
首页 > 资讯 > 后端开发 > Python >Spring的事件和监听器-同步与异步详解
  • 806
分享到

Spring的事件和监听器-同步与异步详解

Spring事件Spring监听器Spring同步Spring异步 2022-11-12 22:11:37 806人浏览 独家记忆

Python 官方文档:入门教程 => 点击学习

摘要

目录spring的事件和监听器-同步与异步1、首先新建StartWorkflowEvent.java,2、新建一个监听器StartWorkflowListener.java3、创建一

Spring的事件和监听器-同步与异步

Application下抽象子类ApplicationContextEvent的下面有4个已经实现好的事件

  • ContextClosedEvent容器关闭时)
  • ContextRefreshedEvent(容器刷新是)
  • ContextStartedEvent(容器启动时候)
  • ContextStoppedEvent(容器停止的时候)

同样,这四个事件都继承了ApplicationEvent,如果我们想自定义事件,也可以通过继承ApplicationEvent来实现

1、首先新建StartWorkflowEvent.java,

继承ApplicationEvent抽象类


public class StartWorkflowEvent extends ApplicationEvent {
    //存放构造器送入的值
    private String msg;
    //构造器参数可以随意设置,这里为了方便调试,设置为字符串
    public StartWorkflowEvent (String msg) {
        super(msg);
        this.msg=msg;
    }
    //自定义一个方法,这个方法也可以随意写,这里也是测试用
    public void myevent(){
        System.out.println("********My event**************");
        System.out.println(msg);
        System.out.println("*******************************");
    }
}

2、新建一个监听器StartWorkflowListener.java

实现ApplicationListener<StartWorkflowEvent>



@Component("startWorkflowListener")
public class StartWorkflowListener implements ApplicationListener<StartWorkflowEvent> {
 
    @Autowired
    private OaWorkflowHepler oaWorkflowHepler;
 
//@Async注解异步调用时使用, 异步调用时, 需要在xml配置文件中添加 <task:annotation-driven />
//  @Async
    @Override
    public void onApplicationEvent(StartWorkflowEvent event) {
        oaWorkflowHepler.start(event.getMsg());
    }
}

3、创建一个事件发布类EventPublisher.java



@Component("eventPublisher")
public class EventPublisher {
 
    @Autowired
    private ApplicationContext applicationContext;
 
    
    public void publishEvent(ApplicationEvent event) {
        applicationContext.publishEvent(event);
    }
}

4、相关的配置

<task:annotation-driven />配置:

  • executor:指定一个缺省的executor给@Async使用。

例子:


<task:annotation-driven executor="asyncExecutor" />

<task:executor />配置参数:

  • id:当配置多个executor时,被@Async("id")指定使用;也被作为线程名的前缀。
  • core size:最小的线程数,缺省:1
  • max size:最大的线程数,缺省:Integer.MAX_VALUE
  • queue-capacity:当最小的线程数已经被占用满后,新的任务会被放进queue里面,当这个 queue的capacity也被占满之后,pool里面会创建新线程处理这个任务,直到总线程数达到了max size,这时系统会拒绝这个任务并抛出TaskRejectedException异常(缺省配置的情况下,可以通过rejection-policy 来决定如何处理这种情况)。缺省值为:Integer.MAX_VALUE
  • keep-alive:超过core size的那些线程,任务完成后,再经过这个时长(秒)会被结束掉
  • rejection-policy:当pool已经达到max size的时候,如何处理新任务
  • ABORT(缺省):抛出TaskRejectedException异常,然后不执行
  • DISCARD:不执行,也不抛出异常
  • DISCARD_OLDEST:丢弃queue中最旧的那个任务
  • CALLER_RUNS:不在新线程中执行任务,而是有调用者所在的线程来执行

Spring事件、异步监听

使用事件的模式可以对系统进行解耦,事件源发布一个事件,

事件监听器可以消费这个事件,而事件源不用关注发布的事件有哪些监听器,

这可以对系统进行解耦

在这里插入图片描述


public class Mains extends ApplicationEvent {
    public Mains(Object name) {
        super(name);
        System.out.println(String.fORMat("Hi,我是被监听的%s!",name));
    }
}

@Component
public class ListenerMains {
    //@Async  // 开启异步就无法使用@Order(0)进行排序了
    @Order(0)
    @EventListener(Mains.class)
    public void listener(Mains mains){
        System.out.println("这是第一个监听类 "+mains.getSource());
    }
    //@Async
    @Order(1)
    @EventListener(Mains.class)
    public void listener2(Mains mains){
        System.out.println("这是第二个监听类 "+mains.getSource());
    }
    //@Async
    @Order(2)
    @EventListener(Mains.class)
    public void listener3(Mains mains){
        System.out.println("这是第三个监听类 "+mains.getSource());
    }
}

public class TestController {
    @Autowired
    GetAccessToken getAccessToken;
    @Autowired
    ApplicationEventPublisher publisher;
    @RequestMapping("test")
    public Object get() {
        publisher.publishEvent(new Mains("哈哈哈哈"));
    }
}

以上为个人经验,希望能给大家一个参考,也希望大家多多支持编程网。

--结束END--

本文标题: Spring的事件和监听器-同步与异步详解

本文链接: https://www.lsjlt.com/news/161038.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑,方便收藏和打印~

下载Word文档
猜你喜欢
软考高级职称资格查询
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作