重构大型业务型写接口-并行处理注意点

栏目: Java · 发布时间: 7年前

内容简介:重构大型业务型写接口-并行处理注意点

概述

为了提高接口的处理速度,通常会使用并行的方式。在 JAVA 中可以使用 ThreadPoolExecutor 或者 ForkJoinPool 。像并行查询或者并行调用外部接口,经常会用到这两种技术,基本上没什么坑。但是如果是使用这两种技术来重构大型的业务型写接口,则需要小心细致。

task切分

task粒度切分是个技术活。必须大小合适。尽量保证执行task的每个线程各自拥有自己的数据,各干各的。没什么共享的资源需要访问或者更新,不然可能产生对共享资源的竞争,影响到接口的响应速度。

task里面避免慢查询

如果task里面有慢查询SQL,线程虽然获取到了DB连接,但是影响到了线程的处理速度。尤其是并发线程比较多的情况下。

配置多一些DB连接

大型的写接口,需要频繁的操作DB,加上多线程并行处理,对DB的压力也就更大。DB连接是共享资源,如果数量太少,会造成线程获取不到DB连接,导致线程处理数据的时间拉长了。

收集数据,使用并发集合容器类

不支持并发的JAVA集合容器,在并发情况下会抛异常。如果想在各个task中统计一些数据,需要使用ConcurrentHashMap等容器。

无需保证数据一致性的,别用事务。必须使用,用短事务

事务需要DB支持,会带来一些开销。能不用尽量不用。如果一定要用事务,尽量使用短的事务。长事务会导致线程持有DB连接的时间太长了。导致其他线程无法获取到DB连接。

外部系统是否支持并发调用

如果你自己应用的接口使用了并行技术,并且在接口中调用了外部接口,一定要注意外部系统的接口是否能够支持的住并发调用。如果不行,应该要调整线程并发数或者让对方系统加服务器。

借助jvisualvm工具分析线程执行时间

使用多线程并行处理的时候,一点要观察这些线程在CPU的执行时间是否 比较平均 。如果部分线程在CPU里的执行时间长,那么肯定是线程在某些地方被阻塞住了。可以利用JAVA自带的jvisualvm来分析。

RejectedExecutionException处理

使用了 ThreadPoolExecutor 后,会有一个队列存储task。当队列满了后,会抛出 RejectedExecutionException 异常。对于业务型接口,可以抛出一个类似”队列已满,请稍后再试”这样的提示,以便让业务人员放慢操作或者不要继续操作,产生过多的流量。


以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

技术赋权

技术赋权

郑永年 / 邱道隆 / 东方出版社 / 2014-4-1 / CNY 45.00

在本书中,作者对中国互联网的历史做了一次突破性的研究,细致又全面地观察了中国互联网对于国家和社会的影响,发现互联网给中国的社会—政治变革带来了新的动力。政府权力和社会力量在以互联网为媒介的公共领域中转换。 从大量的数据梳理和事实分析中,作者得出了四重的研究结论。首先,互联网给政府和社会都增加了权力。互联网在促进政治自由化中扮演了重要的角色,使政府更加开放、透明和负责任。第二,互联网产生了大量......一起来看看 《技术赋权》 这本书的介绍吧!

HTML 压缩/解压工具
HTML 压缩/解压工具

在线压缩/解压 HTML 代码

随机密码生成器
随机密码生成器

多种字符组合密码

Markdown 在线编辑器
Markdown 在线编辑器

Markdown 在线编辑器