Tomcat作为web服务器，对于每个客户端的请求将给予处理响应，但对于一台机器而言，访问请求的总流量有高峰期且服务器有物理极限，为了保证web服务器不被冲垮我们需要采取一些措施进行保护预防，需要稍微说明的此处的流量更多的是指套接字的连接数，通过控制套接字连接个数来控制流量。其中一种有效的方法就是采取流量控制，它就像在流量的入口增加了一道闸门，闸门的大小决定了流量的大小，一旦达到最大流量将关闭闸门停止接收直到有空闲通道。
创建一个流量控制器没思路？还是考虑下并发框架AQS吧，通过控制同步器的状态即可实现，如果忘了AQS框架相关知识请移步到前面多线程章节，具体思路是先初始化状态值，然后每到来一个socket就将状态加1，每关闭一个socket将状态减1，如此一来一旦状态值小于0则由AQS机制将停止对socket的接收，直到某个socket处理完释放。我们把思路拆成两部分，一是创建一个支持计数的控制器，另一个是将此控制器嵌入处理流程中。
① 控制器，整个过程是根据AQS推荐的自定义同步器的做法进行，但并没有使用AQS自带的状态变量，而是另外引入一个AtomicLong类型的count变量用于计数，其本质是一样的，不必过于纠结。控制器主要通过countUpOrAwait和countDown两个方法实现控制效果。
public class LimitLatch {
private class Sync extends AbstractQueuedSynchronizer {
public Sync() {}
@Override
protected int tryAcquireShared(int ignored) {
long newCount = count.incrementAndGet();
if (newCount > limit) {
count.decrementAndGet();
return -1;
} else {
return 1;
}
}
@Override
protected boolean tryReleaseShared(int arg) {
count.decrementAndGet();
return true;
}
}
private final Sync sync;
private final AtomicLong count;
private volatile long limit;
public LimitLatch(long limit) {
this.limit = limit;
this.count = new AtomicLong(0);
this.sync = new Sync();
}
public void countUpOrAwait() throws InterruptedException {
sync.acquireSharedInterruptibly(1);
}
public long countDown() {
sync.releaseShared(0);
long result = getCount();
return result;
}
}
② 流程嵌入控制器，伪代码如下，在接收socket前累加计数器，对socket的数据处理则交由另外的线程，它处理需要一段时间，假如这段时间又有1000个请求socket，则第1000个请求会导致停止程序阻塞，而唤醒的条件是线程池中的工作线程处理完其中一个socket并执行countDown操作。tomcat默认的大小为1000。
LimitLatch limitLatch = new LimitLatch(1000);
创建ServerSocket;
limitLatch.countUpOrAwait();//这里可能阻塞
Socket socket = ServerSocket.accept();
从线程池中获取一个空闲工作线程处理socket，处理完关闭socket并执行limitLatch.countDown();