作者：caozhizhao | 来源：互联网 | 2023-07-23 17:54
在做puv统计时碰到的一个问题，用户请求过来会记录为一个pv，记录到redis中，但由于pv量太大会给redis造成过大压力，所以做个缓存，当pv满10条了发一次。用了一个队列ArrayList
在做puv统计时碰到的一个问题，用户请求过来会记录为一个pv，记录到redis中，但由于pv量太大会给redis造成过大压力，所以做个缓存，当pv满10条了发一次。用了一个队列ArrayList实现，但队列的插入、删除在并发条件下不可行，所以在方法上加了synchronized:
1
2
3
4
5
6
7
8
9
10
11
| static ArrayList pvList = new ArrayList();
public synchronized void countPv(...){
//........生成一个PV对象
pvList.add(PV)
if(pvList.size()>10){
//前10个加到redis
addRedis(pvList.subList(0,10))
}
//删除10个
pvList.subList(0,10).clear();
} |
但在压力测试中，如果已满负荷的连续压测，发现会丢掉一些pv，可能是synchronized造成的堵塞导致，如何更好的实现这个需求呢？
每10个请求发一次，而后删除，同时可以满足不断累加
- synchronized放到函数里面估计提升并不大，毕竟add，size，clear方法都必须满足同步需求
- ConcurrnetLinkedQueue, Concurrent...Array删除、查找的开销都非常大，而且貌似没法用于这种场合
p.s. 您能留段伪码就最好了
京公网安备 11010802041100号