7种方式,教你提升 SpringBoot 项目的吞吐量
点击关注公众号,实用技术文章及时了解
来源:xhcom.blog.csdn.net/article/details/88046026
一、异步执行
实现方式二种:
使用异步注解
@aysnc
、启动类:添加@EnableAsync
注解JDK 8本身有一个非常好用的Future类——
CompletableFuture
@AllArgsConstructor
public class AskThread implements Runnable{private CompletableFuture<Integer> re = null;public void run() {int myRe = 0;try {myRe = re.get() * re.get();} catch (Exception e) {e.printStackTrace();}System.out.println(myRe);}public static void main(String[] args) throws InterruptedException {final CompletableFuture<Integer> future = new CompletableFuture<>();new Thread(new AskThread(future)).start();//模拟长时间的计算过程Thread.sleep(1000);//告知完成结果future.complete(60);}
}
在该示例中,启动一个线程,此时AskThread
对象还没有拿到它需要的数据,执行到 myRe = re.get() * re.get()
会阻塞。我们用休眠1秒来模拟一个长时间的计算过程,并将计算结果告诉future
执行结果,AskThread
线程将会继续执行。
public class Calc {public static Integer calc(Integer para) {try {//模拟一个长时间的执行Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}return para * para;}public static void main(String[] args) throws ExecutionException, InterruptedException {final CompletableFuture<Void> future = CompletableFuture.supplyAsync(() -> calc(50)).thenApply((i) -> Integer.toString(i)).thenApply((str) -> "\"" + str + "\"").thenAccept(System.out::println);future.get();}
}
CompletableFuture.supplyAsync
方法构造一个CompletableFuture
实例,在supplyAsync()
方法中,它会在一个新线程中,执行传入的参数。在这里它会执行calc()
方法,这个方法可能是比较慢的,但这并不影响CompletableFuture
实例的构造速度,supplyAsync()
会立即返回。而返回的CompletableFuture
实例就可以作为这次调用的契约,在将来任何场合,用于获得最终的计算结果。
supplyAsync
用于提供返回值的情况,CompletableFuture
还有一个不需要返回值的异步调用方法runAsync(Runnable runnable)
,一般我们在优化Controller
时,使用这个方法比较多。这两个方法如果在不指定线程池的情况下,都是在ForkJoinPool.common
线程池中执行,而这个线程池中的所有线程都是Daemon
(守护)线程,所以,当主线程结束时,这些线程无论执行完毕都会退出系统。
核心代码:
CompletableFuture.runAsync(() ->this.afterBetProcessor(betRequest,betDetailResult,appUser,id)
);
异步调用使用Callable来实现
@RestController
public class HelloController { private static final Logger logger = LoggerFactory.getLogger(HelloController.class); @Autowired private HelloService hello; @GetMapping("/helloworld") public String helloWorldController() { return hello.sayHello(); } /** * 异步调用restful * 当controller返回值是Callable的时候,springmvc就会启动一个线程将Callable交给TaskExecutor去处理 * 然后DispatcherServlet还有所有的spring拦截器都退出主线程,然后把response保持打开的状态 * 当Callable执行结束之后,springmvc就会重新启动分配一个request请求,然后DispatcherServlet就重新 * 调用和处理Callable异步执行的返回结果, 然后返回视图 * * @return */ @GetMapping("/hello") public Callable<String> helloController() { logger.info(Thread.currentThread().getName() + " 进入helloController方法"); Callable<String> callable = new Callable<String>() { @Override public String call() throws Exception { logger.info(Thread.currentThread().getName() + " 进入call方法"); String say = hello.sayHello(); logger.info(Thread.currentThread().getName() + " 从helloService方法返回"); return say; } }; logger.info(Thread.currentThread().getName() + " 从helloController方法返回"); return callable; }
}
异步调用的方式 WebAsyncTask
@RestController
public class HelloController { private static final Logger logger = LoggerFactory.getLogger(HelloController.class); @Autowired private HelloService hello; /** * 带超时时间的异步请求 通过WebAsyncTask自定义客户端超时间 * * @return */ @GetMapping("/world") public WebAsyncTask<String> worldController() { logger.info(Thread.currentThread().getName() + " 进入helloController方法"); // 3s钟没返回,则认为超时 WebAsyncTask<String> webAsyncTask = new WebAsyncTask<>(3000, new Callable<String>() { @Override public String call() throws Exception { logger.info(Thread.currentThread().getName() + " 进入call方法"); String say = hello.sayHello(); logger.info(Thread.currentThread().getName() + " 从helloService方法返回"); return say; } }); logger.info(Thread.currentThread().getName() + " 从helloController方法返回"); webAsyncTask.onCompletion(new Runnable() { @Override public void run() { logger.info(Thread.currentThread().getName() + " 执行完毕"); } }); webAsyncTask.onTimeout(new Callable<String>() { @Override public String call() throws Exception { logger.info(Thread.currentThread().getName() + " onTimeout"); // 超时的时候,直接抛异常,让外层统一处理超时异常 throw new TimeoutException("调用超时"); } }); return webAsyncTask; } /** * 异步调用,异常处理,详细的处理流程见MyExceptionHandler类 * * @return */ @GetMapping("/exception") public WebAsyncTask<String> exceptionController() { logger.info(Thread.currentThread().getName() + " 进入helloController方法"); Callable<String> callable = new Callable<String>() { @Override public String call() throws Exception { logger.info(Thread.currentThread().getName() + " 进入call方法"); throw new TimeoutException("调用超时!"); } }; logger.info(Thread.currentThread().getName() + " 从helloController方法返回"); return new WebAsyncTask<>(20000, callable); } }
二、增加内嵌Tomcat的最大连接数
@Configuration
public class TomcatConfig {@Beanpublic ConfigurableServletWebServerFactory webServerFactory() {TomcatServletWebServerFactory tomcatFactory = new TomcatServletWebServerFactory();tomcatFactory.addConnectorCustomizers(new MyTomcatConnectorCustomizer());tomcatFactory.setPort(8005);tomcatFactory.setContextPath("/api-g");return tomcatFactory;}class MyTomcatConnectorCustomizer implements TomcatConnectorCustomizer {public void customize(Connector connector) {Http11NioProtocol protocol = (Http11NioProtocol) connector.getProtocolHandler();//设置最大连接数 protocol.setMaxConnections(20000);//设置最大线程数 protocol.setMaxThreads(2000);protocol.setConnectionTimeout(30000);}}}
三、使用@ComponentScan()定位扫包比@SpringBootApplication扫包更快
四、默认tomcat容器改为Undertow(Jboss下的服务器,Tomcat吞吐量5000,Undertow吞吐量8000)
<exclusions><exclusion><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-tomcat</artifactId></exclusion>
</exclusions>
改为:
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-undertow</artifactId>
</dependency>
五、使用 BufferedWriter 进行缓冲
六、Deferred方式实现异步调用
@RestController
public class AsyncDeferredController {private final Logger logger = LoggerFactory.getLogger(this.getClass());private final LongTimeTask taskService;@Autowiredpublic AsyncDeferredController(LongTimeTask taskService) {this.taskService = taskService;}@GetMapping("/deferred")public DeferredResult<String> executeSlowTask() {logger.info(Thread.currentThread().getName() + "进入executeSlowTask方法");DeferredResult<String> deferredResult = new DeferredResult<>();// 调用长时间执行任务taskService.execute(deferredResult);// 当长时间任务中使用deferred.setResult("world");这个方法时,会从长时间任务中返回,继续controller里面的流程logger.info(Thread.currentThread().getName() + "从executeSlowTask方法返回");// 超时的回调方法deferredResult.onTimeout(new Runnable(){@Overridepublic void run() {logger.info(Thread.currentThread().getName() + " onTimeout");// 返回超时信息deferredResult.setErrorResult("time out!");}});// 处理完成的回调方法,无论是超时还是处理成功,都会进入这个回调方法deferredResult.onCompletion(new Runnable(){@Overridepublic void run() {logger.info(Thread.currentThread().getName() + " onCompletion");}});return deferredResult;}
}
七、异步调用可以使用AsyncHandlerInterceptor进行拦截
@Component
public class MyAsyncHandlerInterceptor implements AsyncHandlerInterceptor {private static final Logger logger = LoggerFactory.getLogger(MyAsyncHandlerInterceptor.class);@Overridepublic boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler)throws Exception {return true;}@Overridepublic void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler,ModelAndView modelAndView) throws Exception {
// HandlerMethod handlerMethod = (HandlerMethod) handler;logger.info(Thread.currentThread().getName()+ "服务调用完成,返回结果给客户端");}@Overridepublic void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex)throws Exception {if(null != ex){System.out.println("发生异常:"+ex.getMessage());}}@Overridepublic void afterConcurrentHandlingStarted(HttpServletRequest request, HttpServletResponse response, Object handler)throws Exception {// 拦截之后,重新写回数据,将原来的hello world换成如下字符串String resp = "my name is chhliu!";response.setContentLength(resp.length());response.getOutputStream().write(resp.getBytes());logger.info(Thread.currentThread().getName() + " 进入afterConcurrentHandlingStarted方法");}}
参考
https://my.oschina.net/u/3768341/blog/3001731
https://blog.csdn.net/liuchuanhong1/article/details/78744138
推荐
主流Java进阶技术(学习资料分享)
Java面试题宝典
加入Spring技术开发社区
PS:因为公众号平台更改了推送规则,如果不想错过内容,记得读完点一下“在看”,加个“星标”,这样每次新文章推送才会第一时间出现在你的订阅列表里。点“在看”支持我们吧!
7种方式,教你提升 SpringBoot 项目的吞吐量相关推荐
- 七种方式教你在 SpringBoot 初始化时搞点事情
[CSDN 编者按]本文总结了Spring Boot容器初始化和Java Bean初始化两个维度总计七种可以由开发者自定义的Spring Boot扩展点,开发者可以根据这些扩展点实现消息监听,配置监听 ...
- 手把手教你创建springBoot项目
**# 手把手教你创建springBoot项目 千里之行 始于足下 简介 springboot是用来简化spring应用的初始搭建以及开发过程 使用特定的方式来进行配置(properties或yml文 ...
- 陈松松:三种方式教你打造一个行业内10万视频播放量
这是我写的第82篇原创视频营销文章 陈松松,6年视频营销实战经验 在任何一个行业内, 判断一个视频受不受欢迎, 不管是谁,第一个想到的就是视频播放量. 你的视频播放量高, 哪怕你的视频内容讲的不咋好, ...
- 复制百度文库的文字加什么后缀_10种方式教你复制网页中不能复制的文字
10 种方式教你复制网页中不能复制的文字 很多 seoer 写软文都会复制网页中的文字,但是很多网页中的文字都 不能复制,于是综合自己平时遇到的问题,收集了 10 种方式,仅供 大家参考,有的我自己没 ...
- GIT忽略文件三种方式教你快速解决
问题描述 当我们使用git提交代码时会产生一些多余文件,包括.idea.target文件以及一些iml配置文件等,每次提交代码的时候需要手动选择出我们真正要提交的文件,十分不方便,接下来三种方式教你解 ...
- idea 建nodejs 项目_三种方法带你新建SpringBoot项目
SpringBoot 的设计目的是简化Spring的搭建与开发,尤其是没有了好多繁琐的配置.本篇文章主要介绍如何搭建SpringBoot项目. 从官网创建 访问Spring的官方网站 start.sp ...
- 3. mysql的注解驱动的三种方式_上手spring boot项目(三)之spring boot整合mybatis进行增删改查的三种方式。...
1.引入依赖 org.springframework.boot spring-boot-starter-web org.mybatis.spring.boot mybatis-spring-boot- ...
- 三种方式快速搭建vue环境项目全过程(图解)
(一)环境搭建 1.下载源码 如果仅仅只是在项目或者某个文件中简单的使用vue,就可以直接在html中引入下列链接 <script src="https://unpkg.com/vue ...
- 直播间没人气怎么办?9种方式教你快速引流涨粉
疫情期间,上网课.看直播.线上办公,在5G即将到来的时代,人们将直播玩出了新花样,万物皆可"播". 在实体经济遭受巨大打击的当前,一大批直播人士在直播市场上狠赚了一笔.有人直播蹦迪 ...
最新文章
- 【转】linux服务器性能查看
- 【转】gdb调试多进程程序
- Oracle优化04-Optimizer优化器
- session 重写进入redis测试
- 详解BAT盘根错节的O2O矩阵格局
- GraphPad Prism 教程 :标准差与平均值的标准误差有什么区别
- cuteEditor 配置
- GitHub上已超过2900星!这份有原理、有代码、有Demo的算法资源火了
- 深度学习(四十五)条件对抗网络
- 红橙Darren视频引申 第一次写NDK项目(Android studio 4.1.1)
- python窗口怎么显示,如何使用Python在没有窗口的屏幕上显示文本
- 虚拟机VMware插入U盘操作系统崩溃死机问题及解决方法
- 四、公文流转的基本过程
- 桌面计算机找不到硬盘,bios找不到硬盘完美解决方法 选择STATConfigur
- linux安装Ice3.7 c++
- 零基础学python知乎-知乎:参与量化投资实训营是一种怎样的体验?
- 智慧天气系统 - 可视化大屏(Echarts)管理系统(HTTP(S)协议)物联网平台(MQTT协议)
- 数据库常用操作,会持续更新
- 学大伟业 Day 3 培训总结
- 石家庄地铁查询双人项目进度总结
热门文章
- 影院要求自费购买3D眼镜是“霸王条款” 官方都开始吐槽了!
- 唏嘘!这家双屏智能手机厂商宣布破产:曾被称为“俄罗斯iPhone”
- 软件测试:web渗透测试怎样入门!讲透了...
- celery实现任务统一收集、分发执行
- java实现生产者消费者问题
- 拳皇全明星伺服务器维护,拳皇全明星5月31日更新公告_拳皇全明星5月31日更新内容介绍_玩游戏网...
- mysql allowed packet_修改mysql的max_allowed_packet值
- xlsx怎么设置行高列宽_7米面宽的3栋别墅,两款复式进深达到18米,第一款主体只要16万...
- 没有找到站点_为了在家Coding,我搜集了海量的远程站点,然而...
- 使用python实现GBK转unicode码查询表