带着新人学springboot的应用09（springboot+异步任务）

Posted 2021-01-25 java小新人

　　本来想说说检索的，不过不知道什么鬼，下载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，可以了，运行应用，测试结果如下：

 

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