spring 异步事件,springboot 异步执行

2022-07-31 15:00:00 分类：java 阅读()

　　spring 异步事件,springboot 异步执行

　　

目录

简介事件监听简述实例同步监听（无序)同步监听（有序)异步监听（无序)

 

　　

简介

说明

 

　　本文用示例介绍跳羚中的事件的用法及原理。

　　

事件监听简述

事件的发布与监听从属于观察者模式；和（法属)马提尼克岛(马提尼克岛的简写)相比，事件的发布与监听偏向于处理服务内的某些逻辑。

 

　　多个监听器可以监听同一个事件。例如：发布了事件一，监听器英语字母表中第一个字母和监听器仓库都监听了事件一，则监听器英语字母表中第一个字母和仓库都会进行处理。

　　同步与异步监听

　　监听方式特点使用时机同步监听发布器线程与监听器线程处于同一线程1.监听逻辑处理较快2.需要紧接着根据监听器追踪业务线程异步监听发布器线程与监听器线程处于不同线程1.监听逻辑处理比较耗时2.追求响应性能事件的顺序

　　可使用实现整齐的接口的方式，调整监听器顺序。

　　注意：必须是同时实现ApplicationListenerMyEvent，已订购这样的方法才能控制顺序。

　　下边几种都是无法控制顺序的：

　　@ Component @ EventListerner实现整齐的实现ApplicationListenerMyEvent @订单

　　

实例

 

　　

同步监听(无序)

事件

 

　　包com。举例。事件；导入org。spring框架。语境。应用程序事件；公共类MyEvent扩展应用事件{公共我的事件(对象源){超级(源)；} }监听器

　　监听器数字一(一)

　　包com。举例。事件；导入org。spring框架。语境。事件。事件侦听器；导入org。spring框架。刻板印象。组件；@ component public class my listener { @ event listener public void ABC(my event event){ system。出去。println(监听器：“我的听众))；System.out.println(监听器所在线程： Thread.currentThread().getName())；System.out.println(事件： 事件);System.out.println(事件的数据：事件。getsource())；}}监听器注射毒品

　　包com。举例。事件；导入org。spring框架。语境。事件。事件侦听器；导入org。spring框架。刻板印象。组件；@ component公共类my listener 2 { @ event listener public void on application event(my event事件){ System.out.println(监听器：‘‘我的听众2’)；System.out.println(所在线程： Thread.currentThread().getName())；System.out.println(事件： 事件);System.out.println(事件的数据：事件。getsource())；} }发布器

　　包com。举例。事件；导入org。spring框架。豆子。工厂。注释。自动连线；导入org。spring框架。语境。应用

　　ationContext;import org.springframework.stereotype.Component; @Componentpublic class MyPublisher { @Autowired ApplicationContext applicationContext; public void myPublish(String message) { System.out.println("发布器所在线程：" + Thread.currentThread().getName()); applicationContext.publishEvent(new MyEvent(message)); }}测试

　　写一个Controller

　　

package com.example.controller; import com.example.event.MyPublisher;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController; @RestControllerpublic class HelloController { @Autowired MyPublisher myPublisher; @GetMapping("/test1") public String test1() { myPublisher.myPublish("Hello"); return "test1 success"; }}

启动后，访问：http://localhost:8080/test1

 

　　后端输出：

　　

发布器所在线程：http-nio-8080-exec-1监听器： MyListener 所在线程： http-nio-8080-exec-1 事件： com.example.event.MyEvent[source=Hello] 事件的数据：Hello监听器： MyListener2 所在线程： http-nio-8080-exec-1 事件： com.example.event.MyEvent[source=Hello] 事件的数据：Hello

 

　　

可以发现，所有监听器和发布器都在同一个线程。

 

　　

 

　　

同步监听(有序)

事件

 

　　

package com.example.event; import org.springframework.context.ApplicationEvent; public class MyEvent extends ApplicationEvent { public MyEvent(Object source) { super(source); } }

监听器

 

　　监听器1

　　

package com.example.event; import org.springframework.context.ApplicationListener;import org.springframework.core.Ordered;import org.springframework.stereotype.Component; @Componentpublic class MyListener implements ApplicationListener<MyEvent>, Ordered { @Override public void onApplicationEvent(MyEvent event) { System.out.println("监听器： " + "MyListener"); System.out.println(" 所在线程： " + Thread.currentThread().getName()); System.out.println(" 事件： " + event); System.out.println(" 事件的数据：" + event.getSource()); } @Override public int getOrder() { return 2; }}

监听器2

 

　　

package com.example.event; import org.springframework.context.ApplicationListener;import org.springframework.core.Ordered;import org.springframework.stereotype.Component; @Componentpublic class MyListener2 implements ApplicationListener<MyEvent>, Ordered { public void onApplicationEvent(MyEvent event) { System.out.println("监听器： " + "MyListener2"); System.out.println(" 所在线程： " + Thread.currentThread().getName()); System.out.println(" 事件： " + event); System.out.println(" 事件的数据：" + event.getSource()); } @Override public int getOrder() { return 1; }}

发布器

 

　　

package com.example.event; import org.springframework.beans.factory.annotation.Autowired;import org.springframework.context.ApplicationContext;import org.springframework.stereotype.Component; @Componentpublic class MyPublisher { @Autowired ApplicationContext applicationContext; public void myPublish(String message) { System.out.println("发布器所在线程：" + Thread.currentThread().getName()); applicationContext.publishEvent(new MyEvent(message)); }}

测试

 

　　写一个Controller

　　

package com.example.controller; import com.example.event.MyPublisher;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController; @RestControllerpublic class HelloController { @Autowired MyPublisher myPublisher; @GetMapping("/test1") public String test1() { myPublisher.myPublish("Hello"); return "test1 success"; }}

启动后，访问：http://localhost:8080/test1

 

　　后端输出：

　　

发布器所在线程：http-nio-8080-exec-1监听器： MyListener2 所在线程： http-nio-8080-exec-1 事件： com.example.event.MyEvent[source=Hello] 事件的数据：Hello监听器： MyListener 所在线程： http-nio-8080-exec-1 事件： com.example.event.MyEvent[source=Hello] 事件的数据：Hello

 

　　

如果将监听器的实现的Ordered顺序颠倒，则输出结果如下：

 

　　

发布器所在线程：http-nio-8080-exec-1监听器： MyListener 所在线程： http-nio-8080-exec-1 事件： com.example.event.MyEvent[source=Hello] 事件的数据：Hello监听器： MyListener2 所在线程： http-nio-8080-exec-1 事件： com.example.event.MyEvent[source=Hello] 事件的数据：Hello

 

　　

 

　　

异步监听(无序)

方法：

 

　　开启异步监听在监听器上加@Async（此监听器必须是@Component方法注册的）事件

　　

package com.example.event; import org.springframework.context.ApplicationEvent; public class MyEvent extends ApplicationEvent { public MyEvent(Object source) { super(source); } }

同步监听器

 

　　

package com.example.event; import org.springframework.context.event.EventListener;import org.springframework.stereotype.Component; @Componentpublic class MyListener { @EventListener public void abc(MyEvent event) { System.out.println("监听器： " + "MyListener"); System.out.println(" 所在线程： " + Thread.currentThread().getName()); System.out.println(" 事件： " + event); System.out.println(" 事件的数据：" + event.getSource()); }}

异步监听器

 

　　

package com.example.event; import org.springframework.context.event.EventListener;import org.springframework.scheduling.annotation.Async;import org.springframework.stereotype.Component; @Component@Asyncpublic class MyListener2 { @EventListener public void onApplicationEvent(MyEvent event) { System.out.println("监听器： " + "MyListener2"); System.out.println(" 所在线程： " + Thread.currentThread().getName()); System.out.println(" 事件： " + event); System.out.println(" 事件的数据：" + event.getSource()); }}

发布器

 

　　

package com.example.event; import org.springframework.beans.factory.annotation.Autowired;import org.springframework.context.ApplicationContext;import org.springframework.stereotype.Component; @Componentpublic class MyPublisher { @Autowired ApplicationContext applicationContext; public void myPublish(String message) { System.out.println("发布器所在线程：" + Thread.currentThread().getName()); applicationContext.publishEvent(new MyEvent(message)); }}

启动类

 

　　

package com.example; import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.scheduling.annotation.EnableAsync; @SpringBootApplication@EnableAsyncpublic class DemoApplication { public static void main(String[] args) { SpringApplication.run(DemoApplication.class, args); }}

测试

 

　　写一个Controller

　　

package com.example.controller; import com.example.event.MyPublisher;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController; @RestControllerpublic class HelloController { @Autowired MyPublisher myPublisher; @GetMapping("/test1") public String test1() { myPublisher.myPublish("Hello"); return "test1 success"; }}

启动后，访问：http://localhost:8080/test1

 

　　后端输出：

　　

发布器所在线程：http-nio-8080-exec-1监听器： MyListener 所在线程： http-nio-8080-exec-1 事件： com.example.event.MyEvent[source=Hello] 事件的数据：Hello监听器： MyListener2 所在线程： task-1 事件： com.example.event.MyEvent[source=Hello] 事件的数据：Hello

 

　　

到此这篇关于详解SpringBoot实现同步与异步事件监听的文章就介绍到这了,更多相关SpringBoot事件监听内容请搜索盛行IT以前的文章或继续浏览下面的相关文章希望大家以后多多支持盛行IT！

 

郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。

标签：

相关文章阅读

  • ,,详解SpringBoot整合MyBatis详细教程
  • ,,详解SpringBoot中Session超时原理说明
  • ,,浅谈springboot中tk.mapper代码生成器的用法说明
  • ,,SpringBoot项目微信云托管入门部署实践
  • ,,SpringBoot集成JPA持久层框架,简化数据库操作
  • ,,SpringBoot整合Ureport2报表及常见使用方法
  • ,,SpringBoot整合Swagger3生成接口文档过程解析
  • ,,SpringBoot实现动态定时任务
  • ,,Springboot基础之RedisUtils工具类
  • ,,Springboot单元测试无法读取配置文件的解决方案
  • ,,SpringBoot事件发布和监听详解
  • ,,SpringBoot之HandlerInterceptor拦截器的使用详解
  • ,,SpringBoot+阿里云OSS实现在线视频播放的示例
  • ,,SpringBoot+WebSocket实现即时通讯的方法详解
  • ,,SpringBoot+Tess4j实现牛逼的OCR识别工具的示例代码
    • 留言与评论（共有 条评论）
       
    验证码：