javaweb产品补丁更新技术_JavaWeb并发：FORUPDATE实战，监测并解决。

Writer&＃xff1a;BYSocket(泥沙砖瓦浆木匠)

一、前言

针对并发&＃xff0c;老生常谈了。目前一个通用的做法有两种&＃xff1a;锁机制&＃xff1a;1.悲观锁&＃xff1b;2.乐观锁。

但是这篇我主要用于记录我这次处理的经历&＃xff0c;另外希望能看的大神&＃xff0c;大牛&＃xff0c;技师者&＃xff0c;学长&＃xff0c;兄长&＃xff0c;大哥们能在评论中发表自己的看法和解决技巧等。

二、故事是这样的

一个表&＃xff0c;暂且叫 wallet,其中3个字段是 金额。初始值为0,如下图所示&＃xff1a;

然后我们写了一个极为简单的Controller&＃xff0c;并写了下面的Service代码&＃xff1a;

就简单的通过主键读取到一个对象&＃xff0c;注意这个对象是没加锁的。也就是说&＃xff0c;所对应的SQL如下&＃xff1a;

我这边是MyBiatis&＃xff0c;大家应该看得懂的。然后一个增加1 一个减少2 一个增加 3。

三、测试是这样

我用了Web应用压力测试工具&＃xff1a;Boom。https://github.com/rakyll/boomGo编写的HTTP(S)负载生成器&＃xff0c;ApacheBench(AB)的替代工具。Boom是一个微型程序&＃xff0c;能够对Web应用程序进行负载测试。它类似于 Apache Bench &＃xff0c;但在不同的平台上有更好的可用性&＃xff0c;安装使用也比较简单。

简单使用方式如下&＃xff1a;

所以我就如图进行压力测试&＃xff0c;可见这个小工具还挺美的&＃xff0c;这里我连接数1000&＃xff0c;并发数100&＃xff1a;

可见后台程序报错了。什么错误呢&＃xff1f;

原来并发导致update死表了。数据库的数据不用看了肯定是错误的。

四、FOR UPDATE的使用

先补一下其知识&＃xff1a;利用select * for update 可以锁表/锁行。自然锁表的压力远大于锁行。所以我们采用锁行。什么时候锁表呢&＃xff1f;

假设有个表单products &＃xff0c;里面有id跟name二个栏位&＃xff0c;id是主键。

例1: (明确指定主键&＃xff0c;并且有此笔资料&＃xff0c;row lock)

SELECT * FROM wallet WHERE id&＃61;’3′ FOR UPDATE;

例2: (明确指定主键&＃xff0c;若查无此笔资料&＃xff0c;无lock)

SELECT * FROM wallet WHERE id&＃61;’-1′ FOR UPDATE;

例2: (无主键&＃xff0c;table lock)

SELECT * FROM wallet WHERE name&＃61;’Mouse’ FOR UPDATE;

例3: (主键不明确&＃xff0c;table lock)

SELECT * FROM wallet WHERE id<>’3′ FOR UPDATE;

例4: (主键不明确&＃xff0c;table lock)

SELECT * FROM wallet WHERE id LIKE ‘3’ FOR UPDATE;

因此我们更新了下Service层的Mapper方法&＃xff1a;

所对应的SQL如下&＃xff1a;

自然大家可以看到&＃xff0c;我这边加了锁&＃xff0c;是通过主键锁行。

按着上面的测试连接数1000&＃xff0c;并发数100&＃xff0c;控制台没报错。

数据库结果也是很不错。

五、加大压力

按着上面的测试连接数5000&＃xff0c;并发数350&＃xff0c;控制台还是没报错。

数据库结果却是很出错了&＃xff01;&＃xff01;&＃xff01;

少update了很多值。为什么呢&＃xff1f;

六、jvisualvm 小工具检测&＃xff0c;发现Tomcat线程连接数默认不够

然后我用jvisualvm 小工具检测。多测了几次&＃xff0c;发现连接数5000&＃xff0c;并发数350&＃xff0c;并发数上升。有一个图的值始终不变。如图&＃xff1a;

发现图中 tomcat的守护线程一直在200左右。后来我去找了下tomcat的server.xml发现了&＃xff0c;使用了默认&＃xff0c;大概就是200左右。

所以就配置了一下&＃xff0c;大致配置方法有两种如下&＃xff1a;

第1种方式&＃xff1a;配置Connector

maxThreads&＃xff1a;tomcat可用于请求处理的最大线程数

minSpareThreads&＃xff1a;tomcat初始线程数&＃xff0c;即最小空闲线程数

maxSpareThreads&＃xff1a;tomcat最大空闲线程数&＃xff0c;超过的会被关闭

acceptCount&＃xff1a;当所有可以使用的处理请求的线程数都被使用时&＃xff0c;可以放到处理队列中的请求数&＃xff0c;超过这个数的请求将不予处理

第2种方式&＃xff1a;配置Executor和Connector

name&＃xff1a;线程池的名字

class&＃xff1a;线程池的类名

namePrefix&＃xff1a;线程池中线程的命名前缀

maxThreads&＃xff1a;线程池的最大线程数

minSpareThreads&＃xff1a;线程池的最小空闲线程数

maxIdleTime&＃xff1a;超过最小空闲线程数时&＃xff0c;多的线程会等待这个时间长度&＃xff0c;然后关闭

threadPriority&＃xff1a;线程优先级

maxThreads&＃xff1a;线程池的最大线程数&＃xff0c;直接配置1000&＃xff0c;然后用连接数10000&＃xff0c;并发数800测试。轻松见图&＃xff1a;

七、总结

感谢帮助我的人。希望有大牛在此讨论相关。小生感激不尽。