IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> Java知识库 -> SpringBoot中异步注解@Async介绍 -> 正文阅读

[Java知识库]SpringBoot中异步注解@Async介绍

作者:language-java

介绍在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.执行结果:

?

  Java知识库 最新文章
计算距离春节还有多长时间
系统开发系列 之WebService(spring框架+ma
springBoot+Cache(自定义有效时间配置)
SpringBoot整合mybatis实现增删改查、分页查
spring教程
SpringBoot+Vue实现美食交流网站的设计与实
虚拟机内存结构以及虚拟机中销毁和新建对象
SpringMVC---原理
小李同学: Java如何按多个字段分组
打印票据--java
上一篇文章      下一篇文章      查看所有文章
加:2022-10-22 21:01:38  更:2022-10-22 21:02:36 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2025年3日历 -2025/3/10 18:28:26-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码