新网创想网站建设,新征程启航
为企业提供网站建设、域名注册、服务器等服务
怎么在spring boot高并发下实现耗时操作?很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。
公司专注于为企业提供成都网站设计、成都网站制作、微信公众号开发、商城网站定制开发,重庆小程序开发,软件按需开发网站等一站式互联网企业服务。凭借多年丰富的经验,我们会仔细了解各客户的需求而做出多方面的分析、设计、整合,为客户设计出具风格及创意性的商业解决方案,创新互联建站更提供一系列网站制作和网站推广的服务。
高并发下的耗时操作
高并发下,就是请求在一个时间点比较多时,很多写的请求打过来时,你的服务器承受很大的压力,当你的一个请求处理时间长时,这些请求将会把你的服务器线程耗尽,即你的主线程池里的线程将不会再有空闲状态的,再打过来的请求,将会是502了。
请求流程图
http1 http2 http3 thread1 thread2 thread3
解决方案
使用DeferredResult来实现异步的操作,当一个请求打过来时,先把它放到一个队列时,然后在后台有一个订阅者,有相关主题的消息发过来时,这个订阅者就去消费它,这一步可以是分布式的,比如一个秒杀场景,当N多的请求打过来时,有一些请求命中后,它们进行写操作,这时写操作压力很大,1个请求可以要处理3秒,对于高并发场景这是不能容许的,因为你这样占用的服务器线程资源太长了,很快你的服务器就没有可用的线程资源了,这时就可以用到DeferredResult这处理。
代码实现
建立订单的接口,只负责简单的校验和事件的发布
/** * 异步建立高并发的订单. * * @return */ @GetMapping("/create-order") public DeferredResult
异步的订单处理核心逻辑,也是耗时的操作
@Component @EnableAsync public class OrderListener { static Logger logger = LoggerFactory.getLogger(OrderListener.class); /** * 事实上它是一个订单队列的消费者,在后台写订单,本例使用简单的事件监听器实现异步处理的功能. * * @return */ @EventListener @Async public String processOrder(DeferredResultdeferredResult) throws InterruptedException { logger.info("处理订单并返回到对应的Http上下文"); String order = UUID.randomUUID().toString(); Thread.sleep(2000);//假设处理数据需要5秒,前端需要阻塞5秒,但http主线程已经释放了,比较适合IO密集型场合 //当设置之后,create-order将成功响应 deferredResult.setResult(order); return order; } }
看完上述内容是否对您有帮助呢?如果还想对相关知识有进一步的了解或阅读更多相关文章,请关注创新互联行业资讯频道,感谢您对创新互联的支持。