带着新人学springboot的应用09(springboot+异步任务)

  本来想说说检索的,不过不知道什么鬼,下载ElasticSearch太慢了,还是放一下,后面有机会再补上!今天就说个简单的东西,来说说任务。

  什么叫做任务呢?其实就是类中实现了一个什么功能的方法。常见的任务就是异步任务,定时任务,发邮件。

  异步任务:其实就是一个很特别的方法,这个方法没有返回值(也可以有返回值,后面会说的),但是方法内部的逻辑会耗费很多时间!例如,用户请求每次到controller,要执行到这个异步方法的时候,我们只需要命令一个空闲状态的线程去执行它即可,由于没有返回值不影响后续代码的运行,controller直接去执行后续的代码。这样可以极为迅速的响应用户,用户体验非常好。

  定时任务:这个其实看名字就知道了,你可以选定一个月的哪一天哪个小时的具体时分秒,去执行一个方法。这个方法是自动执行的,极大的减轻了我们的工作量。

  发邮件:这个还是比较常见的吧!注册什么的大多都要邮件激活,我们也可以用java程序的方式,来给你邮箱发邮件。

  提前准备:大概了解一下javase中多线程和线程池概念,重点是ThreadPoolTaskExecutor这个类。

1.简单说说异步任务和RabbitMQ

  不知道看了我上面说了异步任务,大家有没有想到前面说过的一个东西,就是RabbitMQ啊!这个消息队列,不就是也是这样的吗?生产者发消息给交换器之后,就不管了,也许生产者就可以直接响应用户响应成功了。而内部也许还有交换器发消息给队列,然后消费者消费消息,但这个过程就跟用户就没什么关系了,干嘛要用户浪费时间在那瞎等呢?

  就我而言,异步任务和RabbitMQ最大的区别应该是访问量的差异;可以将异步任务看作是简化版RabbitMQ 。

  你想啊,假如你做了一个系统,最大访问量总共那么点人,你还要去用个RabbitMQ去搞这搞那的,麻不麻烦啊。。。

  但是假如你在一家大公司,做的系统是给几十万甚至几百万用户用的,那么肯定要用RabbitMQ啊。这个时候如果用异步任务,哪有这么多空闲线程去给你执行这个任务啊,而且线程到了一个数目之后,效率反而是降低的。

  补充小知识:大家知不知道服务器怎么处理多个请求的啊?

  假如都是同步任务:请用请求一到,服务器就出用一个线程去执行,并且到了service层之后,假设会有个任务需要几十秒才能执行完毕;那么执行到这里就会卡住了,请求到这里都要卡住几十秒,人多的时候可能还要排队,等时间过了你才会得到响应。

  那就等着呗,然而不巧的是,这个时候又有几千人来来给服务器发请求,于是这几千人每人等几十秒,而且由于服务器又比较水,一下子开了几千个线程还有点卡于是要等更长时间。(咳,所以越贵的服务器配置高,线程能够开得多,运行速度快,处理多人请求的能力就很牛),于是这几千人用了这个系统之后,心中大骂日了狗了哦,下次再也不用这个鬼系统了。

  那假如是异步任务:还是用订单/库存系统举例,几千人都在买买买,一时间几千个订单请求到controller,然后调用service(注:service还是跟上面一样要几十秒),一到service,判断是个异步方法,于是赶紧让处理异步任务的线程过来慢慢处理就好,controller可以直接响应用户“订单成功”。用户极短时间就收到响应,于是可以继续买买买。

  这里就要说个东西,那个处理异步方法的线程哪里来的啊?其实是从异步方法线程池里拿的。大家应该知道连接池啊,是处理与数据库连接问题的,还能设置个数,最大超时时间等等,还能防止频繁的销毁创建线程的资源消耗。这里的线程池也差不多,可以设置个数啊什么的。。。。后面我们就会试试简单的配置一个连接池专门处理异步任务。

2.简单使用异步任务

  创建一个简单的springboot项目,web模块+1.5.xx版本。

  简单写个controller和一个处理逻辑的类,先看看同步处理:

  ok,你可以测试一下,等5秒钟浏览器才会响应,emmm...玛德,等得真烦。。。

  测试异步处理,加两个注解就ok了。

  然后这次就能不超过一秒钟,就返回响应成功了,你们也可以自己用System.currentTimeMillis()这个方法去测测时间,这里就不多说了。

  这里就需要考虑了,假如访问量很多,每个请求都过来调用HelloTask方法,那就要拿到相应数量的处理异步的线程,来处理这个HelloTask方法!

  处理异步任务的线程也是属于服务器的线程啊,线程数太多服务器会很卡的,默认是有线程池的!但是我们根据自己项目的需求,于是要自定义线程池的一些配置。

  假如线程池里就设置最多30个线程(这里也会有个类似RabbitMq的简单消息队列),那么即使几千人来调用HelloTask方法,那么最多也就拿到30个处理异步的线程,来处理这个方法;至于其他的那么多请求就丢到请求队列里,等这30个线程中某些率先处理完任务的线程就会从这消息队列中拿任务继续处理。

3.自定义异步任务的线程池

   刚刚查一下资料,其实也是可以用多线程来做的,只是每次都用多线程比较麻烦,不过小伙伴们可以试试。

  线程池就相当于包装了一下多线程的操作,做了很多配置!就类似ArrayList和Object数组的关系。

  

  在下面方法打印当前线程(注意,这里注解@Async(“自己配置的线程池的名字”),这里可以指定配置的哪个线程池,可以自己试试,我们这里要写应该是taskExecutor)

 然后运行,打开浏览器,疯狂刷新,控制台打印如下;(注意:可以把线程池中线程数目弄少一点,把sleep时间调整短一点,就能明显看到线程不会按顺序使用了,而是随机的!这个自己可以测试一下)

4.给异步方法设置返回值

   前面说的都是异步方法返回值为void的情况,但是有的时候我们要拿到异步方法的返回值。

  这个逻辑是怎么回事呢?有了返回值还能异步吗?答案是可以的。

  举个例子,当请求到controller,线程就会去执行controller方法,碰到了要执行一个异步方法,于是异步方法立马返回一个Future对象敷衍controller一下(玛德,controller真是老实人...),然后继续执行controller后面的方法,不会停顿;

  这个Future就是异步方法的返回值,只是刚开始还没有数据,等异步方法执行完毕,自动的就会将数据放入Future,比较常见的是利用Future来捕获异常。

  其中,Future是个接口,实现类是AsyncResult,下面就看看修改后的controller:

 

  再看看异步方法内部代码:

  ok,可以了,运行应用,测试结果如下:

  简单的看了看异步任务的用法,应该还是比较容易的,用起来也没什么难度,就是真实项目碰到的情况可能就会很复杂,要考虑的情况比较多了。

原文地址:https://www.cnblogs.com/wyq1995/p/10076949.html

时间: 2024-10-07 18:49:01

带着新人学springboot的应用09(springboot+异步任务)的相关文章

带着新人学springboot的应用07(springboot+RabbitMQ 下)

说一两句废话,强烈推荐各位小伙伴空闲时候也可以写写自己的博客!不管水平高低,不管写的怎么样,不要觉得写不好或者水平不够就不写了(咳,我以前就是这样的想法...自我反省!). 但是开始写博客之后,你会发现很多你以为自己会的东西其实你并不会,然后你会经常在头脑中不断的搜索有关的片段,或者去别的大神博客里到处找有关的资料,最后领悟了属于自己的东西!然后再写出来和别人分享,别人也会给你点意见,你也会慢慢的改进.这不就是学习+复习+巩固+创新+分享+改进的这么的一个过程吗? 以前看过曹雪芹的红楼梦,让我印

带着新人学springboot的应用01(springboot+mybatis+缓存 中)

继续接着上一节,大家应该知道驼峰命名法吧!就是我们javabean中属性一般命名是lastName,userName这种类型的,而数据库中列名一般都是last_name,user_name这种的,要让对应起来,在springboot中可以设置 另外大家可以看看我们用了mybatis依赖之后,导入了一些什么jar包,比较关键的是那个autoconfigure,其实内部就跟之前我们手写的那个starter原理差不多 我们也可以用xxxCustomizer来定制功能,以上面的驼峰命名为例,就可以使用这

带着新人学springboot的应用01(springboot+mybatis+缓存 下)

springboot+mybatis+缓存,基本的用法想必是会了,现在说一说内部大概的原理. 稍微提一下mybatis,只要导入了mybatis的依赖,那么有个自动配置类就会生效,你可以去mybatis的jar包里面的META-INF/spring.factories中看到这个xxxAutoConfiguration,就如下图所示,这个应该很熟悉了,所以我们要看看mybatis的配置,肯定要看这个类. 开这个类,看到这里 看了看,其他的没什么说的,要看看在yml给mybatis可以配置哪些参数,

带着新人学springboot的应用05(springboot+RabbitMQ 上)

这次就来说说RabbitMQ,这个应该不陌生了,随便一查就知道这个是用来做消息队列的.(注意:这一节很多都是概念的东西,需要操作的比较少) 至于AMQP协议(Advanced Message Queuing Protocol),专业名称叫做高级消息队列协议,就是只要你遵守这个协议,那么做出来的产品就能跨平台,跨语言,很牛的一个协议,具体多么牛可以自己百度一下. 而RabbitMQ就是基于这个协议的!很多语言都可以用RabbitMQ,例如python,C语言,PHP,Java等语言,而且windo

带着新人学springboot的应用06(springboot+RabbitMQ 中)

上一节说了这么多废话,看也看烦了,现在我们就来用鼠标点点点,来简单玩一下这个RabbitMQ. 注意:这一节还是不用敲什么代码,因为上一节我们设置了那个可视化工具,我们先用用可视化工具熟悉一下流程. 打开可视化页面,http://localhost:15672 顺便说一下RabbitMQ中的持持久化:这里持久化分为三种:消息持久化,交换器持久化,队列持久化... 举个例子,就简单说说交换器持久化,其实就是为了防止将消息发到交换器了,但是RabbitMQ服务器突然暴毙,没用了,那数据不就丧失了么?

带着新人学springboot的应用13(springboot+热部署)

spring cloud我想做成一个系列,所以spring cloud+eureka后面会慢慢说到的,有兴趣的小伙伴可以关注后续! 这一节就简单说说springboot的热部署了(我一直想不通为什么叫做热部署,看到这名字就吓退了我继续学习的欲望!),但是实际上可以把这个看成是一个小技巧. 就是导入一个依赖,要用的时候,就是快捷键操作:Ctrl+F9 有什么用呢?就是避免你每次对springboot修改一点东西,就要重新启动springboot应用,贼麻烦!而且对于电脑性能不怎么样的小伙伴来说(咳

带着新人学springboot的应用12(springboot+Dubbo+Zookeeper 下)

上半节已经下载好了Zookeeper,以及新建了两个应用provider和consumer,这一节我们就结合dubbo来测试一下分布式可不可以用. 现在就来简单用一下,注意:这里只是涉及最简单的部分,新手入门用的,详细的内容要学习的可以自己查一查资料;然后再说说用Zookeeper当作注册中心的一个特点. 话说注册中心是一个类似第三方软件的东西,那么我们能不能用Dubbo+其他注册中心呢?其实也是可以的,比如redis,有兴趣的可以查查资料自己试试,原理都差不多. 1.导入依赖       两个

【spring-boot】快速构建spring-boot微框架

spring-boot是一个快速构建环境的一套框架,其设计理念是尽可能的减少xml的配置,用来简化新Spring应用的初始搭建以及开发过程.该框架使用了特定的方式来进行配置,从而使开发人员不再需要定义样板化的配置. 废话不多说,关于spring-boot是什么具体请百度. 官网:http://projects.spring.io/spring-boot 1. spring-boot是一个mavan项目,所以其使用的jar包全部是通过maven管理,当然,使用maven也是非常方便的. 首先上我的

SpringBoot系列——@Async优雅的异步调用

前言 众所周知,java的代码是同步顺序执行,当我们需要执行异步操作时我们需要创建一个新线程去执行,以往我们是这样操作的: /** * 任务类 */ class Task implements Runnable { @Override public void run() { System.out.println(Thread.currentThread().getName() + ":异步任务"); } } //新建线程并执行任务类 new Thread(new Task()).sta