Semaphore信号量
在Semaphore信号量非常适合高并发访问,新系统在上线之前,要对系统的访问量进行评估,当然这个值肯定不是随便写的,是经过以往的经验、数据、历年的访问量,已经推广力度进行一个合理的评估,当然评估标准不能太大也不能太小。太大的话投入的资源达不到实际的效果,纯粹浪费资源,太小的话,某个时间高峰值的访问量上来直接可以压垮系统。
相关概念:
PV:(page view) 网站的访问量,页面浏览量或点击量/用户没刷新一次就会被记录一次。
UV:(unique Visitor)访问网站的一台电脑客户端为一个访客。一般来说,时间上24小时内相同的ip的客户端只记录一次。
QPS:(query per second),即每秒查询数,也就是吞吐量。用qps很大程度上代表了系统业务上的繁忙程度,每次请求的背后,可能对应有多次磁盘I/O,多次网络请求,多个cpu时间片等。一旦当前qps超过多设定的预警阈值,可以考虑增加机器对集群扩容,以免压力过大导致宕机。
RT:(response time)请求响应时间,这个指标非常关键,直接说明前端用户的体验,因此要降低rt.
如何解决高并发:
1、网络端的
2、服务器端的
(1) 加几台Nginx
(2) 分流 操作,把操作分给多个tomcat
(3) 业务
3、java层面
(1)限流,使用信号量做
Semaphore信号量实现限流示例:
package edu.sdut.concurrent01; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Semaphore;
public class UseSemaphore {
public static void main(String[] args) {
//线程池 ExecutorService exec = Executors.newCachedThreadPool();
//只能5个线程同时访问 final Semaphore semp = new Semaphore(5);
for (int index = 0; index < 20; index++) { final int NO = index; Runnable run = new Runnable() { public void run() { try {
//获取许可 semp.acquire(); System.out.println("Accessing: " + NO); //模拟实际业务逻辑 Thread.sleep((long) (Math.random() * 10000)); //访问结束,释放 semp.release(); } catch (InterruptedException e) { } } }; exec.execute(run); }
try { Thread.sleep(10); } catch (InterruptedException e) { e.printStackTrace(); }
//System.out.println(semp.getQueueLength()); exec.shutdown(); }
} |