節點管理源碼
『壹』 阿里sentinel源碼解析
sentinel是阿里巴巴開源的流量整形(限流、熔斷)框架，目前在github擁有15k+的star，sentinel以流量為切入點，從流量控制、熔斷降級、系統負載保護等多個維度保護服務的穩定性。
我們以sentinel的主流程入手，分析sentinel是怎麼搜集流量指標，完成流量整形的。
首先我們先看一個sentinel的簡單使用demo，只需要調用SphU.entry獲取到entry，然後在完成業務方法之後調用entry.exit即可。
SphU.entry會調用Env.sph.entry，將name和流量流向封裝成StringResourceWrapper，然後繼續調用entry處理。
進入CtSph的entry方法，最終來到entryWithPriority，調用InternalContextUtil.internalEnter初始化ThreadLocal的物鋒Context，然後調用lookProcessChain初始化責任鏈，最終調用chain.entry進入責任鏈進行處理。
InternalContextUtil.internalEnter會調用trueEnter方法，主要是生成DefaultNode到contextNameNodeMap，然後生成Context設置到contextHolder的過程。
lookProcessChain已經做過優化，支持spi載入自定義的責任鏈bulider，如果沒有定義則使用默認的DefaultSlotChainBuilder進行載入。默認載入的slot和順序可見鎮樓圖，不再細說。
最後來到重頭戲chain.entry進入責任鏈進行處理，下面會按照順序分別對每個處理器進行分析。
首先來到NodeSelectorSlot，主要是獲取到name對應的DefaultNode並緩存起來，設置為context的當前節點，然後通知下一個節點。
下一個節點是ClusterBuilderSlot，繼續對DefaultNode設置ClusterNode與OriginNode，然頌咐後通知下一節點。
下一個節點是LogSlot，只是單純的列印日誌，不再細說。
下一個節點是StatisticSlot，是一個後置節點，先通知下一個節點處理完後，
1.如果沒有報錯，則對node、clusterNode、originNode、ENTRY_NODE的線程數、通過請求數進行增加。
2.如果報錯是PriorityWaitException，則只對線程數進行增加。
3.如果報錯是BlockException，設置報錯到node，然後對阻擋請求數進行增加。
4.如果是其他報錯，設置報錯到node即可。
下一個節點是FlowSlot，這個節點就是重要的限流處理節點，進入此節點是調用checker.checkFlow進行限流處理。
來到FlowRuleChecker的checkFlow方法，調用ruleProvider.apply獲取到資源對應的FlowRule列表，然後遍歷FlowRule調用canPassCheck校驗限流規則。
canPassCheck會根據rule的限流模式，選擇集群限流或者本地限流，這里分別作出分析。
passLocalCheck是本地限流的入口，首先會調用選出限流的node，然後調用canPass進行校驗。罩櫻晌
會根據以下規則選中node。
1.strategy是STRATEGY_DIRECT。
1.1.limitApp不是other和default，並且等於orgin時，選擇originNode。
1.2.limitApp是other，選擇originNode。
1.3.limitApp是default，選擇clusterNode。
2.strategy是STRATEGY_RELATE，選擇clusterNode。
3.strategy是STRATEGY_CHAIN，選擇node。
選擇好對應的node後就是調用canPass校驗限流規則，目前sentinel有三種本地限流規則：普通限流、勻速限流、冷啟動限流。
普通限流的實現是DefaultController，就是統計當前的線程數或者qps加上需要通過的數量有沒有大於限定值，小於等於則直接通過，否則阻擋。
勻速限流的實現是RateLimiterController，使用了AtomicLong保證了latestPassedTime的原子增長，因此停頓的時間是根據latestPassedTime-currentTime計算出來，得到一個勻速的睡眠時間。
冷啟動限流的實現是WarmUpController，是sentinel中最難懂的限流方式，其實不太需要關注這些復雜公式的計算，也可以得出冷啟動的限流思路：
1.當qps已經達到溫熱狀態時，按照正常的添加令牌消耗令牌即可。
2.當qps處於過冷狀態時，會添加令牌使得演算法繼續降溫。
3.當qps逐漸回升，大於過冷的邊界qps值時，不再添加令牌，慢慢消耗令牌使得逐漸增大單位時間可通過的請求數，讓演算法繼續回溫。
總結出一點，可通過的請求數跟令牌桶剩餘令牌數量成反比，以達到冷啟動的作用。
接下來是集群限流，passClusterCheck是集群限流的入口，會根據flowId調用clusterSerivce獲取指定數量的token，然後根據其結果判斷是否通過、睡眠、降級到本地限流、阻擋。
接下來看一下ClusterService的處理，會根據ruleId獲取到對應的FlowRule，然後調用ClusterFlowChecker.acquireClusterToken獲取結果返回。ClusterFlowChecker.acquireClusterToken的處理方式跟普通限流是一樣的，只是會將集群的請求都集中在一個service中處理，來達到集群限流的效果，不再細說。
FlowSlot的下一個節點是DegradeSlot，是熔斷處理器，進入時會調用performChecking，進而獲取到CircuitBreaker列表，然後調用其tryPass校驗是否熔斷。
來到AbstractCircuitBreaker的tryPass方法，主要是判斷熔斷器狀態，如果是close直接放行，如果是open則會校驗是否到達開啟halfopen的時間，如果成功將狀態cas成halfopen則繼續放行，其他情況都是阻攔。
那怎麼將熔斷器的狀態從close變成open呢？怎麼將halfopen變成close或者open呢？sentinel由兩種熔斷器：錯誤數熔斷器ExceptionCircuitBreaker、響應時間熔斷器ResponseTimeCircuitBreaker，都分析一遍。
當業務方法報錯時會調用Tracer.traceEntry將報錯設置到entry上。
當調用entry.exit時，會隨著責任鏈來到DegradeSlot的exit方法，會遍歷熔斷器列表調用其onRequestComplete方法。
ExceptionCircuitBreaker的onRequestComplete會記錄錯誤數和總請求數，然後調用繼續處理。
1.當前狀態是open時，不應該由熔斷器底層去轉換狀態，直接退出。
2.當前狀態是halfopen時，如果沒有報錯，則將halfopen變成close，否則將halfopen變成open。
3.當前狀態時close時，則根據是否總請求達到了最低請求數，如果達到了話再比較錯誤數/錯誤比例是否大於限定值，如果大於則直接轉換成open。
ExceptionCircuitBreaker的onRequestComplete會記錄慢響應數和總請求數，然後調用繼續處理。
1.當前狀態是open時，不應該由熔斷器底層去轉換狀態，直接退出。
2.當前狀態是halfopen時，如果當前響應時間小於限定值，則將halfopen變成close，否則將halfopen變成open。
3.當前狀態時close時，則根據是否總請求達到了最低請求數，如果達到了話再比較慢請求數/慢請求比例是否大於限定值，如果大於則直接轉換成open。
下一個節點是AuthoritySlot，許可權控制器，這個控制器就是看當前origin是否被允許進入請求，不允許則報錯，不再細說。
終於來到最後一個節點SystemSlot了，此節點是自適應處理器，主要是根據系統自身負載（qps、最大線程數、最高響應時間、cpu使用率、系統bbr）來判斷請求是否能夠通過，保證系統處於一個能穩定處理請求的安全狀態。
尤其值得一提的是bbr演算法，作者參考了tcp bbr的設計，通過最大的qps和最小的響應時間動態計算出可進入的線程數，而不是一個粗暴的固定可進入的線程數，為什麼能通過這兩個值就能計算出可進入的線程數？可以網上搜索一下tcp bbr演算法的解析，十分巧妙，不再細說。
『貳』 以太坊源碼分析--p2p節點發現
節點發現功能主要涉及 Server Table udp 這幾個數據結構，它們有獨自的事件響應循環，節點發現功能便是它們互相協作完成的。其中，每個以太坊客戶端啟動後都會在本地運行一個 Server ，並將網路拓撲中相鄰的節點視為 Node ，而 Table 是 Node 的容器， udp 則是負責維持底層的連接。下面重點描述它們中重要的欄位和事件循環處理的關鍵部分。
PrivateKey - 本節點的私鑰，用於與其他節點建立時的握手協商
Protocols - 支持的所有上層協議
StaticNodes - 預設的靜態 Peer ，節點啟動時會首先去向它們發起連接，建立鄰居關系
newTransport - 下層傳輸層實現，定義握手過程中的數據加密解密方式，默認的傳輸層實現是用 newRLPX() 創建的 rlpx ，這不是本文的重點
ntab - 典型實現是 Table ，所有 peer 以 Node 的形式存放在 Table
ourHandshake - 與其他節點建立連接時的握手信息，包含本地節點的版本號以及支持的上層協議
addpeer － 連接握手完成後，連接過程通過這個通道通知 Server
Server 的監聽循環，啟動底層監聽socket，當收到連接請求時，Accept後調用 setupConn() 開始連接建立過程
Server的主要事件處理和功能實現循環
Node 唯一表示網路上的一個節點
IP - IP地址
UDP/TCP - 連接使用的UDP/TCP埠號
ID - 以太坊網路中唯一標識一個節點，本質上是一個橢圓曲線公鑰(PublicKey)，與 Server 的 PrivateKey 對應。一個節點的IP地址不一定是固定的，但ID是唯一的。
sha - 用於節點間的距離計算
Table 主要用來管理與本節點與其他節點的連接的建立更新刪除
bucket - 所有 peer 按與本節點的距離遠近放在不同的桶(bucket)中，詳見之後的 節點維護
refreshReq - 更新 Table 請求通道
Table 的主要事件循環，主要負責控制 refresh 和 revalidate 過程。
refresh.C - 定時(30s)啟動Peer刷新過程的定時器
refreshReq - 接收其他線程投遞到 Table 的 刷新Peer連接 的通知，當收到該通知時啟動更新，詳見之後的 更新鄰居關系
revalidate.C - 定時重新檢查以連接節點的有效性的定時器，詳見之後的 探活檢測
udp 負責節點間通信的底層消息控制，是 Table 運行的 Kademlia 協議的底層組件
conn - 底層監聽埠的連接
addpending － udp 用來接收 pending 的channel。使用場景為：當我們向其他節點發送數據包後(packet)後可能會期待收到它的回復，pending用來記錄一次這種還沒有到來的回復。舉個例子，當我們發送ping包時，總是期待對方回復pong包。這時就可以將構造一個pending結構，其中包含期待接收的pong包的信息以及對應的callback函數，將這個pengding投遞到udp的這個channel。 udp 在收到匹配的pong後，執行預設的callback。
gotreply - udp 用來接收其他節點回復的通道，配合上面的addpending，收到回復後，遍歷已有的pending鏈表，看是否有匹配的pending。
Table - 和 Server 中的ntab是同一個 Table
udp 的處理循環，負責控制消息的向上遞交和收發控制
udp 的底層接受數據包循環，負責接收其他節點的 packet
以太坊使用 Kademlia 分布式路由存儲協議來進行網路拓撲維護，了解該協議建議先閱讀 易懂分布式 。更權威的資料可以查看 wiki 。總的來說該協議：
源碼中由 Table 結構保存所有 bucket ， bucket 結構如下
節點可以在 entries 和 replacements 互相轉化，一個 entries 節點如果 Validate 失敗，那麼它會被原本將一個原本在 replacements 數組的節點替換。
有效性檢測就是利用 ping 消息進行探活操作。 Table.loop() 啟動了一個定時器（0~10s），定期隨機選擇一個bucket，向其 entries 中末尾的節點發送 ping 消息，如果對方回應了 pong ，則探活成功。
Table.loop() 會定期（定時器超時）或不定期（收到refreshReq）地進行更新鄰居關系（發現新鄰居），兩者都調用 doRefresh() 方法，該方法對在網路上查找離自身和三個隨機節點最近的若干個節點。
Table 的 lookup() 方法用來實現節點查找目標節點，它的實現就是 Kademlia 協議，通過節點間的接力，一步一步接近目標。
當一個節點啟動後，它會首先向配置的靜態節點發起連接，發起連接的過程稱為 Dial ，源碼中通過創建 dialTask 跟蹤這個過程
dialTask表示一次向其他節點主動發起連接的任務
在 Server 啟動時，會調用 newDialState() 根據預配置的 StaticNodes 初始化一批 dialTask ， 並在 Server.run() 方法中，啟動這些這些任務。
Dial 過程需要知道目標節點( dest )的IP地址，如果不知道的話，就要先使用 recolve() 解析出目標的IP地址，怎麼解析？就是先要用藉助 Kademlia 協議在網路中查找目標節點。
當得到目標節點的IP後，下一步便是建立連接，這是通過 dialTask.dial() 建立連接
連接建立的握手過程分為兩個階段，在在 SetupConn() 中實現
第一階段為 ECDH密鑰建立 ：
第二階段為協議握手,互相交換支持的上層協議
如果兩次握手都通過，dialTask將向 Server 的 addpeer 通道發送 peer 的信息
『叄』 linux內核源碼解析-list.h
開頭就說明了這里的 list.h 文件來自 Linux Kernel （ */include/linux/list.h ），只是去除了列表項的硬體預載入部分。
進行宏替換後就是
Note: 沒搞懂這里為什麼加個 osn 前綴，原本是 list_add ，現在是 osn_list_add 。
可以看到就是個簡單的鏈表節點刪除過程，同時把刪除節點的前後指針設為無法訪問。
刪除節點後初始化，前後指針都指向自己
從A鏈表刪除後頭插法插入B鏈表
從A鏈表刪除後尾插法插入B鏈表
先對 list 判空，非空就把 list 鏈表除頭節點外裁剪到 head 頭節點在的鏈表中。函數不安全， list 節點可以繼續訪問其他節點。
多了一步 list 重新初始化的過程。
(unsigned long)(&((type *)0)->member))) 將0x0地址強制轉換為 type * 類型，然後取 type 中的成員 member 地址，因為起始地址為0，得到的 member 的地址就直接是該成員相對於 type 對象的偏移地址了。
所以該語句的功能是：得到 type 類型對象中 member 成員的地址偏移量。
先將 ptr 強制轉換為 char * 類型（因為 char * 類型進行加減的話，加減量為 sizeof(char)*offset ， char 佔一個位元組空間，這樣指針加減的步長就是1個位元組，實現加一減一。）
整句話的意思就是：得到指向 type 的指針，已知成員的地址，然後減去這個成員相對於整個結構對象的地址偏移量，得到這個數據對象的地址。
就是從前往後，從後往前的區別
Note: 從head節點開始（不包括head節點！）遍歷它的每一個節點！它用n先將下一個要遍歷的節點保存起來，防止刪除本節點後，無法找到下一個節點，而出現錯誤！
已知指向某個結構體的指針pos，以及指向它中member成員的指針head，從下一個結構體開始向後遍歷這個結構體鏈
Note: 同理，先保存下一個要遍歷的節點！從head下一個節點向後遍歷鏈表。
list.h使用說明
linux內核list.h分析(一)
linux內核list.h分析(二)
【Linux內核數據結構】最為經典的鏈表list
『肆』 java swing左邊樹圖，當點擊任意節點時，右邊顯示顯示數據， 求一個簡單的源碼例子
importjava.awt.BorderLayout;
importjava.awt.Container;
importjava.awt.Dimension;
importjavax.swing.JFrame;
importjavax.swing.JLabel;
importjavax.swing.JPanel;
importjavax.swing.JTree;
importjavax.swing.event.TreeSelectionEvent;
importjavax.swing.event.TreeSelectionListener;
importjavax.swing.tree.DefaultMutableTreeNode;
{
privateJPanelp;
publicTestSwingTree(Stringtitle){
super(title);
}
publicvoidinit(){
Containerc=this.getContentPane();
DefaultMutableTreeNoderoot=newDefaultMutableTreeNode("root");
DefaultMutableTreeNodechild1=newDefaultMutableTreeNode("child1");
DefaultMutableTreeNodechild11=newDefaultMutableTreeNode("child11");
DefaultMutableTreeNodechild12=newDefaultMutableTreeNode("child12");
DefaultMutableTreeNodechild2=newDefaultMutableTreeNode("child2");
DefaultMutableTreeNodechild3=newDefaultMutableTreeNode("child3");
DefaultMutableTreeNodechild31=newDefaultMutableTreeNode("child31");
root.add(child1);
root.add(child2);
root.add(child3);
child1.add(child11);
child1.add(child12);
child3.add(child31);
JTreetree=newJTree(root);
tree.setPreferredSize(newDimension(120,400));
tree.addTreeSelectionListener(newTreeSelectionListener(){
publicvoidvalueChanged(TreeSelectionEvente){
p.removeAll();
JLabell=newJLabel(e.getPath().toString());
l.setBounds(5,190,170,20);
p.add(l);
p.repaint();
}
});
c.add(tree,BorderLayout.WEST);
p=newJPanel();
p.setLayout(null);
p.setPreferredSize(newDimension(180,400));
c.add(p,BorderLayout.CENTER);
this.setLocation(400,300);
this.setSize(300,400);
this.setResizable(false);
this.setVisible(true);
this.setDefaultCloseOperation(this.DISPOSE_ON_CLOSE);
}
publicstaticvoidmain(String[]args){
newTestSwingTree("TestSwingJtree").init();
}
}