详解springboot中使用异步的常用两种方式及其比较

2024-02-22 05:29:13

一般对于业务复杂的流程，会有一些处理逻辑不需要及时返回，甚至不需要返回值，但是如果充斥在主流程中，占用大量时间来处理，就可以通过异步的方式来优化。

实现异步的常用方法远不止两种，但是个人经验常用的，好用的，这里我就说两种，最好用的是第二种。

spring的注解方式@Async org.springframework.scheduling.annotation.Async
jdk1.8后的CompletableFuture java.util.concurrent.CompletableFuture

其中第一种的使用注意事项比较多

1.不要在本类中异步调用。即一个方法是异步方法，然后用另一个方法调用这个异步方法。

2.不要有返回值，使用void

3.不能使用本类的私有方法或者非接口化加注@Async,因为代理不到失效

4.异步方法不能使用static修饰

5.异步类需使用@Component注解，不然将导致spring无法扫描到异步类

6.SpringBoot框架必须在启动类中增加@EnableAsync注解

7.异步方法不要和事物注解同时存在。可以在事物的方法中调用另外一个类中的异步方法。在调用Async方法的方法上标注@Transactional是管理调用方法的事务的,在Async方法上标注@Transactional是管理异步方法的事务,事务因线程隔离

@Async的使用方式

1.pom引入依赖。只要依赖中存在spring-context包即可。

2.需要在springboot启动类上加上开启异步的注解@EnableAsync

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.scheduling.annotation.EnableAsync;

@EnableAsync
@EnableHystrix
@EnableFeignClients
@SpringBootApplication
public class OrderServerApplication extends SpringBootServletInitializer {

 @Override
 protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
  return application.sources(OrderServerApplication.class);
 }

 public static void main(String[] args) {
  SpringApplication.run(OrderServerApplication.class, args);
 }
}

3.可以专门封装一个异步类。然后那个方法需要用到异步的操作。在这个类中封装，然后在类中引入异步类即可。

在使用异步的地方引入调用即可。

CompletableFuture中的异步方法是在一个正常的方法体内使用即可。

 private ExecutorService pool = Executors.newFixedThreadPool(2);

 @Override
 public void synOrder(String orderId, OrderSourceEnum type, Integer status) {
  try {
   CompletableFuture.runAsync(() -> {
   		 //下面是一些业务操作。
    PageVO pageVO = new PageVO();
    Set<String> orderIds = new HashSet<>();
    orderIds.add(orderId);
    pageVO.setIds(orderIds);
    pageVO.setOrderType(type);
    List<MaisOrderDTO> maisOrderDTOS = orderSourceService.batchGetDetails(pageVO);
    if (CollectionUtils.isEmpty(maisOrderDTOS)) {
     throw new RuntimeException("未找到id=" + orderId + "类型为:" + type.getDesc() + "的订单");
    }
   }, pool);
  } catch (Exception e) {
   log.info("同步单个订单给群脉出现异常：{}", e);
  }
 }

参考博客：[Java并发-15] CompletableFuture: 异步编程

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。

简述Springboot @Async 异步方法

1.异步调用异步调用就是在不阻塞主线程的情况下执行高耗时方法 2.常规异步通过开启新线程实现 3.在Springboot中启用异步方法需要4个注解 1.@EnableAsync 开启异步 2.@Component 注册异步组件 3.@Async 标注异步方法 4.@Autowired 注入异步组件 4.进行一次异步调用 1.首先在一个Config类上标注开启异步 2.然后创建一个异步的组件类,就跟Service,Controller 一样一样的,用Component标注,Service也行
SpringBoot异步调用方法并接收返回值

项目中肯定会遇到异步调用其他方法的场景,比如有个计算过程,需要计算很多个指标的值,但是每个指标计算的效率快慢不同,如果采用同步执行的方式,运行这一个过程的时间是计算所有指标的时间之和.比如: 方法A:计算指标x,指标y,指标z的值,其中计算指标x需要1s,计算指标y需要2s,指标z需要3s.最终执行完方法A就是5s. 现在用异步的方式优化一下方法A异步调用方法B,方法C,方法D,方法B,方法C,方法D分别计算指标x,指标y,指标z的值,那么最终执行完方法A的时间则是3s. 步骤1:配置线程池,
Springboot实现高吞吐量异步处理详解(适用于高并发场景)

技术要点 org.springframework.web.context.request.async.DeferredResult<T> 示例如下: 1. 新建Maven项目 async 2. pom.xml <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaL
详解SpringBoot中异步请求和异步调用(看完这一篇就够了)

一.SpringBoot中异步请求的使用 1.异步请求与同步请求特点: 可以先释放容器分配给请求的线程与相关资源,减轻系统负担,释放了容器所分配线程的请求,其响应将被延后,可以在耗时处理完成(例如长时间的运算)时再对客户端进行响应.一句话:增加了服务器对客户端请求的吞吐量(实际生产上我们用的比较少,如果并发请求量很大的情况下,我们会通过nginx把请求负载到集群服务的各个节点上来分摊请求压力,当然还可以通过消息队列来做请求的缓冲). 2.异步请求的实现方式一:Servlet方式实现异步请求
springboot 异步调用的实现方法

说异步调用前,我们说说它对应的同步调用.通常开发过程中,一般上我们都是同步调用,即:程序按定义的顺序依次执行的过程,每一行代码执行过程必须等待上一行代码执行完毕后才执行.而异步调用指:程序在执行时,无需等待执行的返回值可继续执行后面的代码.显而易见,同步有依赖相关性,而异步没有,所以异步可并发执行,可提高执行效率,在相同的时间做更多的事情. 同步程序按照定义顺序依次执行,每一行程序都必须等待上一行程序执行完成之后才能执行,就是在发出一个功能调用时,在没有得到结果之前,该调用就不返回. 异步程
SpringBoot实现定时任务和异步调用

本文实例为大家分享了SpringBoot实现定时任务和异步调用的具体代码,供大家参考,具体内容如下环境: jdk1.8:spring boot2.0.2:Maven3.3 摘要说明: 定时任务:定时任务是业务场景中经常出现的一种情况如:定时发送邮件,短信.定时统计监控数据.定时对账等异步调用:一个都买流程可能包括下单.发货通知.短信推送.消息推送等,其实除了下单这个主要程序是主程序,其他子程序可以同时进行且不影响主程序的运行,这个时候就可以使用异步调用来调用这些子程序: 步骤: 1.定时任务
新手也能看懂的SpringBoot异步编程指南(简单易懂)

通过本文你可以了解到下面这些知识点: Future 模式介绍以及核心思想核心线程数.最大线程数的区别,队列容量代表什么: ThreadPoolTaskExecutor 饱和策略: SpringBoot 异步编程实战,搞懂代码的执行逻辑. Future 模式异步编程在处理耗时操作以及多任务处理的场景下非常有用,我们可以更好的让我们的系统利用好机器的 CPU 和内存,提高它们的利用率.多线程设计模式有很多种,Future模式是多线程开发中非常常见的一种设计模式,本文也是基于这种模式来说明 Sp
SpringBoot异步方法捕捉异常详解

本文实例为大家分享了SpringBoot异步方法捕捉异常的具体代码,供大家参考,具体内容如下由于项目中定时器都采用异步执行方式需要定时监控异步方法执行进度,异常情况 1 执行进度可以设置是否在执行,内存中添加执行标识即可. 防止多次执行可以通过拦截器对此,标识来判断,防止多次执行定时器 2 异常捕捉监控异步方法执行是否异常. 1 无返回值配置AsyncExceptionConfig类,统一处理. 定义异常捕获配置类AsyncExceptionConfig,配置类里面定义SpringAs
SpringBoot开启异步调用方法

异步调用无需等待,方法相当于子线程,后台执行,主线程执行完成,子线程开始执行. SpringBoot 开启异步执行仅需两步: 方法上加 @Async @Override @Async @Transactional(rollbackFor = Exception.class) public Integer init(DatePojo datePojo){ //xxxxxxxxxxx 业务略 xxxxxxx log.info(" 起止日期为 : {} , {} ", start, end)
详解springboot中使用异步的常用两种方式及其比较

一般对于业务复杂的流程,会有一些处理逻辑不需要及时返回,甚至不需要返回值,但是如果充斥在主流程中,占用大量时间来处理,就可以通过异步的方式来优化. 实现异步的常用方法远不止两种,但是个人经验常用的,好用的,这里我就说两种,最好用的是第二种. spring的注解方式@Async org.springframework.scheduling.annotation.Async jdk1.8后的CompletableFuture java.util.concurrent.CompletableFutur
详解shell中脚本参数传递的两种方式

方式一:$0,$1,$2.. 采用$0,$1,$2..等方式获取脚本命令行传入的参数,值得注意的是,$0获取到的是脚本路径以及脚本名,后面按顺序获取参数,当参数超过10个时(包括10个),需要使用${10},${11}....才能获取到参数,但是一般很少会超过10个参数的情况. 1.1 示例:新建一个test.sh的文件 #!/bin/bash echo "脚本$0" echo "第一个参数$1" echo "第二个参数$2" 在shell中执行
详解Vue中使用Echarts的两种方式

1. 直接引入echarts 先npm安装echarts npm install echarts --save 开发: main.js import myCharts from './comm/js/myCharts.js' Vue.use(myCharts) myCharts.js /** * 各种画echarts图表的方法都封装在这里 */ import echarts from 'echarts' (function() { var chart = {}; chart.install =
详解matplotlib中pyplot和面向对象两种绘图模式之间的关系

matplotlib有两种绘图方式,一种是依托matplotlib.pyplot模块实现类似matlab绘图指令的绘图方式,一种是面向对象式绘图,依靠FigureCanvas(画布). Figure (图像). Axes (轴域) 等对象绘图. 这两种方式之间并不是完全独立的,而是通过某种机制进行了联结,pylot绘图模式其实隐式创建了面向对象模式的相关对象,其中的关键是matplotlib._pylab_helpers模块中的单例类Gcf,它的作用是追踪当前活动的画布及图像. 因此,可以说ma
详解pygame捕获键盘事件的两种方式

方式1:在pygame中使用pygame.event.get()方法捕获键盘事件,使用这个方式捕获的键盘事件必须要是按下再弹起才算一次. 示例示例: for event in pygame.event.get(): # 捕获键盘事件 if event.type == pygame.QUIT: # 判断按键类型 print("按下了退出按键") 方式2:在pygame中可以使用pygame.key.get_pressed()来返回所有按键元组,通过判断键盘常量,可以在元组中判断出那个键被
详解SpringBoot静态方法获取bean的三种方式

目录方式一注解@PostConstruct 方式二启动类ApplicationContext 方式三手动注入ApplicationContext 方式一注解@PostConstruct import com.example.javautilsproject.service.AutoMethodDemoService; import org.springframework.beans.factory.annotation.Autowired; import org.springfr
详解查看Python解释器路径的两种方式

进入python的安装目录, 查看python解释器进入bin目录 # ls python(看一下是否有python解释器版本) # pwd (查看当前目录) 复制当前目录即可 1. 通过脚本查看运行以下脚本,或者进入交互模式手动输入即可. import sys import os print('当前 Python 解释器路径:') print(sys.executable) r""" 当前 Python 解释器路径: C:\Users\jpch89\AppData\Lo
详解vue-cli中模拟数据的两种方法

在main.js中引入vue-resource模块,Vue.use(vueResource). 1.使用json-server(不能用post请求) 接下来找到build目录下的webpack.dev.conf.js文件,在const portfinder = require('portfinder')后面引入json-server. /*引入json-server*/ const jsonServer = require('json-server') /*搭建一个server*/ const
详解vscode中console.log的两种快速写法

(一)方法一:直接在script标签中提前定义,仅适用于该html文件! let add = function(a,b){ return a + b; }; console.log(add(20,300)); const { ['log']:C } = console; C(add(20,300)); (二)方法二:按tab键快速生成console.log,且光标在()内部,再次按tab键光标自动跳转到下一行! 1.打开vscode编辑器,选择文件->首选项->用户片段,输入javascrip
详解MyBatis开发Dao层的两种方式（Mapper动态代理方式）

MyBatis开发原始Dao层请阅读我的上一篇博客:MyBatis开发Dao层的两种方式(原始Dao层开发) 接上一篇博客继续介绍MyBatis开发Dao层的第二种方式:Mapper动态代理方式 Mapper接口开发方法只需要程序员编写Mapper接口(相当于Dao接口),由Mybatis框架根据接口定义创建接口的动态代理对象,代理对象的方法体同上一篇博客中Dao接口实现类方法. Mapper接口开发需要遵循以下规范: (1)Mapper.xml文件中的namespace与mapper接口的类路

详解springboot中使用异步的常用两种方式及其比较

相关推荐

随机推荐