让运维加监控,被问到Requests Per Second(见下图)的具体含义是什么?我一时竟回答不上来,虽然大概知道它是指每秒Region Server的请求数,但是具体是怎么算的呢,不清楚。于是决定通过研究源码深入了解下。下面便记录了这个过程。
1,先在代码库中全局搜索Requests Per Second关键字,发现在几个jamon结尾的文件找到了。于是google了一下,这个到底是什么东东,发现是一个模板引擎。
2,查看RegionServerListTmpl.jamon内容,需要传入参数List<ServerName> servers和HMaster master。并且这个模板引擎是在MasterStatusServlet.java的doGet方法中被render的。抛开这些,看下面一段代码,就知道Requests Per Second是怎么来的呢?
1 <%java> 2 int totalRegions = 0; 3 int totalRequests = 0; 4 for (ServerName serverName: serverNames) { 5 6 ServerLoad sl = master.getServerManager().getLoad(serverName); 7 double requestsPerSecond = 0.0; 8 int numRegionsOnline = 0; 9 10 if (sl != null) {11 requestsPerSecond = sl.getRequestsPerSecond();12 numRegionsOnline = sl.getNumberOfRegions();13 totalRegions += sl.getNumberOfRegions();14 // Is this correct? Adding a rate to a measure.15 totalRequests += sl.getNumberOfRequests();16 }17 long startcode = serverName.getStartcode();18
其中requestsPerSecond变量的值就是我们要找的。可以看出来是来自ServerLoad中的getRequestsPerSecond函数。
3,继续查看ServerLoad中的getRequestsPerSecond函数,经过getRequestsPerSecond-》getNumberofRequests发现是serverLoad.getNumberOfRequests中的numberOfRequests_变量的值。
4, 那ClusterStatusProtos.ServerLoad中的numberOfRequests_是怎么来的呢?在HRegionServer中buildServerLoad函数中,可以看到是从MetricsRegionServerWrapperImpl中的requestsPerSecond获取的
1 serverLoad.setNumberOfRequests((int) regionServerWrapper.getRequestsPerSecond());
5,那MetricsRegionServerWrapperImpl中的requestsPerSecond是怎么算的呢?从下面代码可以看出是根据上次的总的请求次数和请求时间,以及当前总的请求次数和请求时间,通过相减,然后除以时间差计算出来的。
if (lastRan == 0) { lastRan = currentTime - period; } //If we've time traveled keep the last requests per second. if ((currentTime - lastRan) > 0) { long currentRequestCount = getTotalRequestCount(); requestsPerSecond = (currentRequestCount - lastRequestCount) / ((currentTime - lastRan) / 1000.0); lastRequestCount = currentRequestCount; } lastRan = currentTime;