在咱们的平常开发中都涉及到使用tomcat作为服务器,可是咱们该设置多大的线程池呢?以及根据什么原则来设计这个线程池呢?接下来,我将介绍本人是怎么设计以及计算的。java
众所周知,tomcat接受一个request后处理过程当中,会涉及到cpu和IO时间。其中IO等待时间,cpu被动放弃执行,其余线程就能够利用这段时间片进行操做。因此咱们能够采用服务器IO优化的通用规则。线程大小 = ( (线程io时间 + 线程cpu) / 线程cpu time) * cpu核数
数据库
线程io时间为100ms(IO操做好比数据库查询,同步远程调用等),线程cpu时间10ms,服务器物理机核数为4个。经过上面的公式,咱们计算出来的大小是 ((100 + 10 )/10 ) *4 = 44
。理论上咱们有依据,可是实际计算过程当中咱们怎么知道线程IO时间和cpu时间呢? 这个就涉及到实际编码过程当中的怎么样监控处理时间啦。tomcat
经过java 实现内置的filter接口,咱们能够拿到一个request消耗的总时间服务器
public class MoniterFilter implements Filter { @Override public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { long start = System.currentTimeMillis(); String params = getQueryString(httpRequest); try { chain.doFilter(httpRequest, httpResponse); } finally { logger.info("access url [{}{}], cost time [{}] ms )", uri, params, cost); } private String getQueryString(HttpServletRequest req) { StringBuilder buffer = new StringBuilder("?"); Enumeration<String> emParams = req.getParameterNames(); try { while (emParams.hasMoreElements()) { String sParam = emParams.nextElement(); String sValues = req.getParameter(sParam); buffer.append(sParam).append("=").append(sValues).append("&"); } return buffer.substring(0, buffer.length() - 1); } catch (Exception e) { } return ""; } }
经过添加切面来监控线程IO耗时(jdk,cglib)app
public class DaoInterceptor implements MethodInterceptor { private static final Logger logger = LoggerFactory.getLogger(DaoInterceptor.class); @Override public Object invoke(MethodInvocation invocation) throws Throwable { StopWatch watch = new StopWatch(); watch.start(); Object result = null; Throwable t = null; try { result = invocation.proceed(); } catch (Throwable e) { t = e == null ? null : e.getCause(); throw e; } finally { watch.stop(); logger.info("({}ms)", watch.getTotalTimeMillis()); } return result; } }
经过上述代码就能够计算出相应时间,从而计算出线程大小啦。可是咱们就到此为止了吗?
其实尚未,计算出的数值只是存在理论状况下,咱们仍是须要经过压测工具(Jmeter)来压测一下线服务器,同时根据qps值来动态微调刚才计算出的线程池大小。ide