turbine是怎麼收集指標資料的

我們通過url：http://localhost:10000/turbine.stream?cluster=default可以獲取到指標的json資料。那麼指標資料又是從何處獲取到的。

答案是：從各個服務的/manage/hystrix.stream端點獲取的

可以找到turbine的架構設計

詳細資訊參考

說明：turbine啟動的時候，會去連線需要監控的主機，建立起監聽，每乙個例項會有乙個監聽。當例項監聽從各個服務獲取到資料的時候，會將資料填充到派發器dispatcher中，由派發器將資料輸出到各個客戶端。

turbine的實現在turbine核心包下

com.netflix.turbine：turbine-core

在該包下，可以找到幾個關鍵的類

instancemonitor、handlerqueuetuple、turbinedatadispatcher、turbinestreamservlet

我們啟動除錯的時候，可以看到

例項的url其實是指向具體需要監控的例項的端點，即

檢視這個鏈結我們可以看到

instancemonitor啟動監聽

public void startmonitor() throws exception 
taskfuture = threadpool.submit(new callable() 
} catch(throwable t) finally 
cleanup();
monitorstate.set(state.cleanedup);
}return null;
}});
}

private void init() throws exception 
}

dowork()方法做了什麼呢

private void dowork() throws exception  else 
listlist = new arraylist();
list.add(instancedata);
/* send to all handlers */
//將獲取到的資料新增到dispatcher中
boolean continuerunning = dispatcher.pushdata(getstatsinstance(), list);
if(!continuerunning) 
}

getnextstatsdata讀取資料

那麼派發器是什麼呢，它的實現檢視turbinedatadispatcher

檢視它的pushdata方法

發現呼叫的是tuple.pushdata(statsdata);而tuple其實就像乙個管道，檢視handlerqueuetuple的pushdata方法

public void pushdata(k data) 
boolean success = queue.writeevent(data);
if (iscritical()) else }}

看到queue.writeevent(data)、往佇列裡寫資料

這個佇列又是什麼呢？

其實就是乙個事件佇列eventqueue，檢視它的寫事件方法

public boolean writeevent(t event) 
count.incrementandget();
queue.add(event);
return true;
}

如果佇列中的長度大於maxcapacity，將不會再往佇列裡填充資料。當客戶端連線上的時候，queue就會被消費。如果客戶端沒有連線上的時候，queue讀出來，經過一系列的操作會寫回queue中，直到佇列滿了就不在寫了。1、當沒有客戶端連線上的時候

eventhandler經過一些列的處理，資料會被寫回到queue中

2、當有客戶端連上的時候，假設我們通過瀏覽器位址列輸入了

此時我們看到eventhandler為turbinestreamingconnection，見下圖

handldata()就變成了turbinestreamingconnection中的方法

public void handledata(collectiondata) 
//將資料寫到steamhandler中
writetostream(data);
}

writetostream()中有個關鍵的操作streamhandler.writedata(jsonstringfordatahash)

writedata()方法就可以將資料寫到response中

客戶端訪問http://localhost:10000/turbine.stream?cluster=default的時候，其實就是通過turbinestreamservlet獲取到響應結果的。

turbine是怎麼收集指標資料的

網路資料是怎麼傳輸的

什麼是資料傾斜，怎麼解決資料傾斜？

怎麼來看遊戲常規指標資料 I

turbine是怎麼收集指標資料的

網路資料是怎麼傳輸的

什麼是資料傾斜，怎麼解決資料傾斜？

怎麼來看遊戲常規指標資料 I

相關推薦