附錄D Metrics簡介

注：本文是為了配合《

spark核心設計的藝術——架構設計與實現

》一書的內容而編寫，目的是為了節省成本、方便讀者查閱。書中附錄d的內容都在本文呈現。

metrics是codahale提供的第三方度量倉庫。metrics作為一款監控指標的度量類庫，可以為第三方庫提供輔助統計資訊，還可以將度量資料傳送給ganglia和graphite以提供圖形化的監控。

本文將對metrics中的核心類進行介紹，方便讀者對spark度量系統更加細緻深入的理解。

metricregistry是metrics提供的度量容器，這裡先列出metricregistry的主要結構。

public class metricregistry implements metricset

從上面**可以看出metricregistry中會快取各種度量和***，下面對metricregistry中的一些方法進行介紹。

功能描述：構建形如「字串1.字串2…字串n-1.字串n」這樣的字串。任何空值或空字串都將被過濾。

public static string name(string name, string... names) 
}return builder.tostring();
}

功能描述：當有新的metric新增到concurrentmapmetrics時，呼叫此方法。根據metric的子介面的不同，呼叫不同方法。例如：gauge則呼叫***的ongaugeadded；counter則呼叫***的oncounteradded；histogram則呼叫***的onhistogramadded。

private void notifylistenerofaddedmetric(metricregistrylistener listener, metric metric, string name)  else if (metric instanceof counter)  else if (metric instanceof histogram)  else if (metric instanceof meter)  else if (metric instanceof timer)  else 
}

功能描述：當有新的metric新增到concurrentmapmetrics時，呼叫此方法。遍歷呼叫***快取listlisteners中的所有***，呼叫notifylistenerofaddedmetric。

private void onmetricadded(string name, metric metric) 
}

功能描述：如果metric的型別是metric並且metrics中還沒有此metric，則將它新增到metrics；

如果metric的型別是metricset，則metricset中包含的所有新的metric新增到快取concurrentmapmetrics；以上新增過程都伴隨onmetricadded的呼叫。

public t register(string name, t metric) throws illegalargumentexception  else  else 
}return metric;
} private void registerall(string prefix, metricset metrics) throws illegalargumentexception else }}

gauge是metrics提供的用於估計度量值的特質，其實現如下：

public inte***ce gaugeextends metric

slf4jreporter是metrics提供的使用實現了slf4j介面的實現類的方法，將度量輸出到日誌的類。

功能描述：將度量輸出到日誌的方法。

@override
public void report(sortedmapgauges,
sortedmapcounters,
sortedmaphistograms,
sortedmapmeters,
sortedmaptimers) 
for (entryentry : counters.entryset()) 
for (entryentry : histograms.entryset()) 
for (entryentry : meters.entryset()) 
for (entryentry : timers.entryset()) }}

功能描述：將估計度量輸出到日誌的方法。（備註：

slf4jreporter的

report

方法中分別對

gauge

、counter

、histogram

、meter

及timer

進行輸出，為說明問題，附錄

d只挑選了對

gauge

metrics

原始碼。）

private void loggauge(string name, gauge gauge) , value={}", prefix(name), gauge.getvalue());
}

slf4jreporter的日誌輸出依賴於loggerproxy，根據loggerproxy的類名，我們知道這是乙個有關日誌輸出的**類，其實現如下：

/* private class to allow logger configuration */
static abstract class loggerproxy 
abstract void log(marker marker, string format, object... arguments);
abstract boolean isenabled(marker marker);
}

可以看到loggerproxy實際上不過是**了org.slf4j.logger介面對日誌輸出。

scheduledreporter是consolereporter、csvreporter、slf4jreporter及graphitereporter的共同父類，scheduledreporter中的很多方法被子類所共用。

功能描述：啟動度量輸出工作，實質為定時器不斷地呼叫report方法輸出。

public void start(long period, timeunit unit)  catch (runtimeexception ex) #report. exception was suppressed.", scheduledreporter.this.getclass().get******name(), ex);}}
}, period, period, unit);
}

功能描述：停止度量輸出工作，實質為停止定時器。

public void stop() 
}} catch (interruptedexception ie) 
}

經過近一年的準備，《

spark核心設計的藝術架構設計與實現

》一書現已出版發行，圖書如圖：

京東：

附錄D Metrics簡介

附錄養城之戰

Storm入門之附錄A

附錄A 術語表

附錄D Metrics簡介

附錄 養城之戰

Storm入門之附錄A

附錄A 術語表

相關推薦

附錄養城之戰