SpringBoot中异步注解@Async介绍

这篇具有很好参考价值的文章主要介绍了SpringBoot中异步注解@Async介绍。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

介绍在SpringBoot项目中,使用@Async不生效的原因介绍和分析;

代码参考gitee仓库:spring-boot-2022-05: 主要是介绍Spring框架注解、常用的功能的使用案例,记录平时遇到的技术知识点,进行实践操作; - Gitee.com

 一、常见原因:

1.启动类中没有添加注解@EnableAsync;

2.同一个类中调用含有@Async的方法;因为@Transactional和@Async是采用Spring AOP原理实现的,需要通过代理对象调用其方法。

3.方法必须是public修饰,且返回值是void或Future。

4.使用ThreadPoolTaskExecutor对象创建自定义线程池?

5.关于@Async("param")中参数param含义?

正确使用步骤事项:

第一步:启动类中应该添加注解@EnableAsync;

第二步:执行方法和异步方法不在同一个类中。

第三步:异步方法必须是public 修饰,且返回值是void或Future;

二、具体案例:

1.启动类需要添加注解@EnableAsync

package com.dbzhang;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;

/**
 * @program: spring-boot-2022-05
 * @description:
 * @author: zdb
 * @motto: 认真写好每一行代码
 * @create: 2022-05-05 13:15
 */
@SpringBootApplication
@EnableAsync
public class ApplicationRun {
    public static void main(String[] args) {
        SpringApplication.run(ApplicationRun.class, args);
    }
}

2.PlayerService业务类:通过代理对象调用异步方法发送短信asyncMethodClass.sendMessage(playerId, msg);

package com.dbzhang.asyc;

import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

/**
 * @program: spring-boot-2022-05
 * @description:
 * @author: zdb
 * @motto: 认真写好每一行代码
 * @create: 2022-10-18 13:11
 */
@Component
@Slf4j
public class PlayerService {

    @Resource
    private AsyncMethodClass asyncMethodClass;


    public void register(Long playerId) {
        log.info("begin----注册用户编号,playerId:{}", playerId);
        //异步发送短信
        String msg = "异步发送短信";
        asyncMethodClass.sendMessage(playerId, msg);
        log.info("end----注册用户编号,playerId:{}", playerId);
    }
}

3.AsyncMethodClass中异步方法,使用@Async("param")标记异步方法,其中param参数是引用线程池的bean名称,但是Spring容器中必须存在这个bean。

package com.dbzhang.asyc;

import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

/**
 * @program: spring-boot-2022-05
 * @description:
 * @author: zdb
 * @motto: 认真写好每一行代码
 * @create: 2022-10-18 13:12
 */
@Component
@Slf4j
public class AsyncMethodClass {

    /**
     * 测试调用异常方法:发送短信
     * 
     */
    @Async("threadPoolTaskExecutor")
    public void sendMessage(Long playerId, String msg) {
        log.info("玩家注册编号playerId:{},发送短信信息msg:{}", playerId, msg);
    }
}

4.自定义线程池ThreadPoolTaskExector,并交给Spring容器管理。

package com.dbzhang.asyc;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;


/**
 * @program: spring-boot-2022-05
 * @description: 自定义线程池配置
 * @author: zdb
 * @motto: 认真写好每一行代码
 * @create: 2022-10-19 12:50
 */
@Configuration
public class AsyncThreadParam {

    @Value("${threadPool.corePoolSize}")
    private int corePoolSize;

    @Value("${threadPool.maxPoolSize}")
    private int maxPoolSize;

    @Value("${threadPool.keepAliveSeconds}")
    private int keepAliveSeconds;

    @Value("${threadPool.queueCapacity}")
    private int queueCapacity;

    @Value("${threadPool.namePrefix}")
    private String namePrefix;

    /**
     * 初始化线程池参数
     *
     * @return
     */
    @Bean(value = "threadPoolTaskExecutor")
    public ThreadPoolTaskExecutor initThreadPoolTaskExecutor() {
        ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor();
        threadPoolTaskExecutor.setCorePoolSize(corePoolSize);
        threadPoolTaskExecutor.setMaxPoolSize(maxPoolSize);
        threadPoolTaskExecutor.setQueueCapacity(queueCapacity);
        threadPoolTaskExecutor.setKeepAliveSeconds(keepAliveSeconds);
        threadPoolTaskExecutor.setThreadNamePrefix(namePrefix);
//        threadPoolTaskExecutor.setRejectedExecutionHandler();
        return threadPoolTaskExecutor;
    }
}

5.配置文件中执行线程参数:

#自定义线程池ThreadPoolTaskExecutor参数
threadPool:
  corePoolSize: 2
  maxPoolSize: 5
  keepAliveSeconds: 60
  queueCapacity: 10
  namePrefix: async-zdb-

6.测试类:

package com.dbzhang.async;

import com.dbzhang.asyc.PlayerService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

/**
 * @program: spring-boot-2022-05
 * @description:
 * @author: zdb
 * @motto: 认真写好每一行代码
 * @create: 2022-10-18 13:18
 */
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest
public class AsyncTest {

    @Autowired
    private PlayerService playerService;

    @Test
    public void testAsync() {
        playerService.register(123456789L);
    }
}

 7.执行结果:

SpringBoot中异步注解@Async介绍

 文章来源地址https://www.toymoban.com/news/detail-416275.html

到了这里,关于SpringBoot中异步注解@Async介绍的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 原来你是这样的SpringBoot--Async异步任务

    本节我们一起学习一下SpringBoot中的异步调用,主要用于优化耗时较长的操作,提高系统性能和吞吐量。 首先给启动类增加注解@EnableAsync,支持异步调用 然后定义要执行的Task,分类增加一个同步方法和异步方法,其中异步方法需要增加注解@Async 其实接下来就可以在controller中

    2024年02月11日
    浏览(37)
  • SpringBoot中@EnableAsync和@Async注解的使用

    异步的优点: 提高应用程序的响应能力 提高系统的吞吐量 节约资源 :异步操作可以避免在请求处理期间占用过多的线程资源,减少服务器的负载。 优化用户体验 需要注意的问题: 事务问题 :异步处理时,需要注意在事务没有结束时做异步操作,可能会导致读取不到甚至

    2023年04月25日
    浏览(35)
  • 自定义注解实现springboot 多线程事务(基于@Async注解的多线程)

    目录 前言 一、springboot多线程(声明式)的使用方法? 二、自定义注解实现多线程事务控制 1.自定义注解 2.AOP内容 3.注解使用Demo 本文是基于springboot的@Async注解开启多线程, 并通过自定义注解和AOP实现的多线程事务, 避免繁琐的手动提交/回滚事务  (CV即用, 参数齐全, 无需配置

    2023年04月09日
    浏览(39)
  • Springboot项目:解决@Async注解获取不到上下文信息问题

    springboot项目中,需要使用到异步调用某个方法,此时 第一个想到的就是 @Async 注解,但是 发现 方法执行报错了,具体报错如下: 上面日志有点多,其实核心就是这一部分日志: 这块逻辑就是,使用spring底层提供的获取上下文信息的方法。 所以说明 获取不到上下文信息,结

    2024年01月17日
    浏览(45)
  • springboot 异步执行方法详细介绍

            在Spring Boot中,异步执行方法是一种提高应用程序性能和响应性的技术。通过异步执行,你可以在处理耗时的业务逻辑时,不需要阻塞当前线程,从而提高应用程序的吞吐量和并发处理能力。         基本概念         在Spring中,异步执行通常是通过`@Asy

    2024年02月21日
    浏览(38)
  • @Async异步线程:Spring 自带的异步解决方案

            在项目应用中,使用MQ异步调用来实现系统性能优化,完成服务间数据同步是常用的技术手段。如果是在同一台服务器内部,不涉及到分布式系统,单纯的想实现部分业务的异步执行,这里介绍一个更简单的异步方法调用。         对于异步方法调用,从Spring3 开

    2023年04月24日
    浏览(66)
  • HarmonyOS通过async与await同异步转换 解决异步回调地狱

    我在 HarmonyOS 发送http网络请求 中讲述了 HTTP请求的基本方式 然后 就带出了 回调地狱的问题 然后 上文 HarmonyOS 通过Promise 解决异步回调地狱问题 我们用Promise的解决方案 搞定了 这个问题 但是 Promise 这种写法 可读性其实没有那么优秀 没有搞定 Promise return规则的人甚至都看不懂

    2024年01月24日
    浏览(48)
  • Spring之异步任务@Async详解分析

    在 java 中异步线程很重要,比如在业务流处理时,需要通知硬件设备,发短信通知用户,或者需要上传一些图片资源到其他服务器这种耗时的操作,在主线程里处理会阻塞整理流程,而且我们也不需要等待处理结果之后再进行下一步操作,这时候就可以使用异步线程进行处理

    2024年02月01日
    浏览(61)
  • promise及异步编程async await

    ECMAScript 6 新增了正式的 Promise(期约)引用类型,支持优雅地定义和组织异步逻辑。接下来几个版本增加了使用 async 和 await 定义异步函数的机制 JavaScript 是单线程事件循环模型。异步行为是为了优化因计算量大而时间长的操作,只要你不想为等待某个异步操作而阻塞

    2024年02月04日
    浏览(43)
  • es--基础--9.2--SpringBoot注解--Field--介绍

    字段名称,是name的别名 字段名称 字段类型 默认:自动检测字段的类型 是否建立索引 false: 不能查询 不能得到返回 时间类型的格式化 是否存储原文 false:字段内容 存储到_source中 ture:字段内容 存储到其他地方,不存储到_source中 当你将一个field的store属性设置为true,这个

    2024年02月02日
    浏览(36)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包