流控源碼

❶ 分布式限流Sentinel

眾所周知，互聯網電商的各類活動是越來越多，例如削減男同胞錢包厚度的雙十一、618、雙十二、各類秒殺活動等，幾乎所有的互聯網電商企業都會參與其中，沖擊GMV，會電商平台帶來巨大的流量與可觀的利潤。

作為互聯網電商中的一員，我自己所屬的公司雖然遠比不上淘寶、京東等，但作為社交電商領域的領頭羊，我們在上述對於電商企業及其特殊的日子，流量也是不容小覷的。

好了，讓我們進入這期的主題。例如在雙十一、或者周年慶等這種特殊的日子，當12點剛到那一刻，巨大的用戶流量湧入你們的系統，訪問量突然劇增時，我們是如何保證系統的可用性、穩定性。我們的解決方案主要是通過Sentinel的限流、降級、熔斷（增加伺服器數量就不說了）以及消息中間件的削峰（我會專門寫一期關於消息中間件的文章，到時候大家可以看看）。沒錯，本期的主角出現了，他就是 Sentinel ，阿里開源的面向分布式服務框架的輕量級流量控制框架。官網如下: https://github.com/alibaba/Sentinel

以下是另一個開源的流量控制框架 hystrix 與Sentinel的對比

分布式系統中，限流的資源可以是一個http介面，也可使是某個分布式應用中的API；一般我們針對C端的http介面進行限流，針對API進行熔斷降級。

限制請求的數量，限制某段時間內的請求總量對於超出的總量的請求，可以直接拒絕，也可以在請求的時候對請求分組，允許特殊請求進來，剩下的拒絕，也可以放入消息隊列，削峰填谷。
限流的實現方式：

服務降級是從整個系統的負荷情況出發和考慮的，對某些負荷會比較高的情況，為了預防某些功能（業務場景）出現負荷過載或者響應慢的情況，在其內部暫時舍棄對一些非核心的介面和數據的請求，而直接返回一個提前准備好的fallback（退路）錯誤處理信息。這樣，雖然提供的是一個有損的服務，但卻保證了整個系統的穩定性和可用性。例如：當雙11活動時，把無關交易的服務統統降級，如查看歷史訂單、工單等等。

在微服務架構中，微服務是完成一個單一的業務功能，這樣做的好處是可以做到解耦，每個微服務可以獨立演進。但是，一個應用可能會有多個微服務組成，微服務之間的數據交互通過遠程過程調用完成。這就帶來一個問題，假設微服務A調用微服務B和微服務C，微服務B和微服務C又調用其它的微服務。如果調用鏈路上某個微服務的調用響應時間過長或者不可用，對微服務A的調用就會佔用越來越多的系統資源，進而引起系統崩潰，所謂的「 雪崩效應 」。
熔斷機制是應對雪崩效應的一種微服務鏈路保護機制 。服務熔斷的作用類似於我們家用的保險絲，當某服務出現不可用或響應超時的情況時，為了防止整個系統出現雪崩，暫時停止對該服務的調用。熔段解決如下幾個問題：

本源碼解析以限流為例，降級具體實現可自行參考源碼 Sentinel採用滑動窗口演算法來實現限流的。限流的直接表現是在執行 Entry nodeA = SphU.entry(資源名字) 的時候拋出 FlowException 異常。FlowException 是BlockException 的子類，您可以捕捉 BlockException 來自定義被限流之後的處理邏輯。

由上可知，會先初始化一個限流規則，initFlowRule方法中將創建一個限流規則FlowRule對象，主要限流參數如下

並設置其相應的限流規則屬性，最後通過FlowRuleManager.loadRules(rules)載入限流規則。

限流規則初始化之後，通過entry= SphU.entry(resource)觸發內部初始化。
從 SphU.entry() 方法往下執行會進入到 Sph.entry() ，Sph的默認實現類是 CtSph,而最終會進入CtSph 的entry 方法

通過我們給定的資源去封裝了一個 StringResourceWrapper ，然後傳入自己的重載方法，繼而調用 entryWithPriority(resourceWrapper, count, false, args)：

由上述方法可知，主要是為了獲取該資源對應的資源處理鏈，讓我們來看下slotChain是如何獲取的

當Map緩存中不存在ProcessorSlotChain實例，則具體通過 SlotChainProvider 去構造處理鏈

繼續讓我們來看下slotChainBuilder的build方法中做了些什麼

我們可以看出上述底層源碼是一個標準的責任鏈設計模式，通過查看ProcessorSlot的具體實現類，我們可以知道該責任鏈中的具體節點如圖所示

執行對應的這些節點，具有有不同的職責，例如:

下圖所示是各個slot對應的entry方法的具體實現

我們以StatisticSlot為例，來看看這些具體實現類內部的邏輯是怎樣的。

請求通過了sentinel的流控等規則，再通過node.addPassRequest() 將當次請求記錄下來

addPassRequest方法如下

addPass方法如下

WindowWrap主要屬性如下

我們再看看獲取當前窗口的方法 data.currentWindow()

我們再回到

獲取到窗口以後通過 wrap.value().addPass(count)增加統計的 QPS。而這里的 wrap.value() 得到的是之前提到的 MetricBucket ，在 Sentinel 中QPS相關數據的統計結果是維護在這個類的 LongAdder[] 中，最終由這個指標來與我們實現設置好的規則進行匹配，查看是否限流，也就是 StatisticSlot的entry 方法中的。在執行StatisticSlot的entry前都要先進入到FlowSlot的entry方法進行限流過濾：

讓我們進入checkFlow的內部

再此處我們拿到了設置的 FlowRule ，循環匹配資源進行限流過濾。這就是Sentinel 能做到限流的原因。

我們可以通過Sentinel的客戶端查看接入了sentinel的各個系統。可針對系統中的各個資源設置相應的限流規則，如QPS或者線程數；或者設置相應的降級規則，如平均RT，異常比例以及異常數。

❷ 免費串口調試助手 開源 C#

工業控制類軟體在Windows平台下，使用C#語言進行開發，既方便又快捷。在工控領域中，串口通訊是一種非常常見的需求。因此，我花費時間開發了一個通用的串口調試助手工具，並將工控調試中常用的功能集成在上面，以方便用戶進行調試。源碼已經在gitee上開源，界面採用wpf實現，源碼地址為：

接下來，我將簡單介紹一下已實現的功能。

程序功能主要分為以下四大塊：

1. 串口通訊

2. TCP通訊

3. 小工具

4. 支持中英文雙語切換

5. 檢查版本更新

6. 曲線顯示讀取的值。

一、串口通訊

串口通訊詳細功能：

1. 支持手動刷新串口設備列表。

2. 支持流控。

3. 接收發送編碼方式同時支持ASCII和HEX方式。

4. 在ASCII模式下，可設置結束符，如回車換行等。

5. 在HEX模式下，支持自動計算標准ModbusRTU的CRC16。

6. 發送支持循環發送。

7. 接收區顯示支持顯示發送和顯示接收，並可設置發送和接收的字元串顏色。

8. 接收區顯示支持顯示發送和接收的時間，時間格式可自定義。

9. 底部顯示串口狀態，總接收位元組數和總發送位元組數。各位元組數可手動清零。

10. 接收區字元串可一鍵清空。

11. 記錄發送歷史，支持記錄最新的10條歷史記錄。

12. 可將接收區顯示的字元實時保存到本地txt文檔。

13. 可將讀取到的值以實時曲線的形式顯示出來。

二、TCP通訊

TCP通訊詳細功能：

1. 支持TCP Client/TCP Server。

2. 在TCP Server模式下，可顯示當前連接客戶端列表。

3. TCP通訊採取非同步方式通訊。

4. 支持串口通訊功能中的3-13項。

5. 不支持TCP連接斷開的自動偵測。

三、小工具

包含的小工具介紹：

1. 通用校驗方法中包含常用的LRC、XOR、CheckSum、FCS、Modbus-CRC16等校驗的計算。

2. 數據轉換包含整數和小數與16進制HEX的轉換。

3. 圖片與base64互轉。

4. 數據採集中常用的模擬量與工程量轉換計算。

5. ASCII碼表。

6. C#顏色對照表。

7. 拾取屏幕顏色。該功能使用滑鼠hook實現。通過hook技術可實現攔截或修改鍵盤滑鼠等的操作，有這方面需求的可參考。

四、檢查更新

1. 檢查更新方式：

利用gitee作為更新檢查的伺服器，將版本號和下載連接寫在gitee項目文件中，實現自動檢查更新並提供下載連接的功能。

五、相關開源項目

1. 跨平台（linux/Windows）串口通訊源碼開源連接：

xuyuanbao/BaoYuanSerial: A GUI Serial Debug Tool for Linux/Microsoft Window (github.com)

❸ google為什麼要開源webrtc

google開源了WebRTC項目，網址是：http://code.google.com/p/webrtc/。

WebRTC實現了基於網頁的視頻會議，標準是WHATWG 協議，目的是通過瀏覽器提供簡單的javascript就可以達到實時通訊（Real-Time Communications (RTC)）能力。

通過對源碼的粗略分析，WebRTC提供了視頻會議的核心技術，包括音視頻的採集、編解碼、網路傳輸、顯示等功能，並且還支持跨平台：windows，linux，mac，android。

WebRTC的視頻處理分析（windows平台）

WebRTC的視頻部分，包含採集、編解碼(I420/VP8)、加密、媒體文件、圖像處理、顯示、網路傳輸與流控(RTP/RTCP)等功能。

視頻採集---video_capture

源代碼在webrtc\moles\video_capture\main目錄下，包含介面和各個平台的源代碼。
在windows平台上，WebRTC採用的是dshow技術，來實現枚舉視頻的設備信息和視頻數據的採集，這意味著可以支持大多數的視頻採集設備；對那些需要單獨驅動程序的視頻採集卡（比如海康高清卡）就無能為力了。
視頻採集支持多種媒體類型，比如I420、YUY2、RGB、UYUY等，並可以進行幀大小和幀率控制。

視頻編解碼---video_coding
源代碼在webrtc\moles\video_coding目錄下。
WebRTC採用I420/VP8編解碼技術。VP8是google收購ON2後的開源實現，並且也用在WebM項目中。VP8能以更少的數據提供更高質量的視頻，特別適合視頻會議這樣的需求。

視頻加密--video_engine_encryption
視頻加密是WebRTC的video_engine一部分，相當於視頻應用層面的功能，給點對點的視頻雙方提供了數據上的安全保證，可以防止在Web上視頻數據的泄漏。
視頻加密在發送端和接收端進行加解密視頻數據，密鑰由視頻雙方協商，代價是會影響視頻數據處理的性能；也可以不使用視頻加密功能，這樣在性能上會好些。
視頻加密的數據源可能是原始的數據流，也可能是編碼後的數據流。估計是編碼後的數據流，這樣加密代價會小一些，需要進一步研究。

視頻媒體文件--media_file
源代碼在webrtc\moles\media_file目錄下。
該功能是可以用本地文件作為視頻源，有點類似虛擬攝像頭的功能；支持的格式有Avi。
另外，WebRTC還可以錄制音視頻到本地文件，比較實用的功能。

視頻圖像處理--video_processing
源代碼在webrtc\moles\video_processing目錄下。
視頻圖像處理針對每一幀的圖像進行處理，包括明暗度檢測、顏色增強、降噪處理等功能，用來提升視頻質量。

視頻顯示--video_render
源代碼在webrtc\moles\video_render目錄下。
在windows平台，WebRTC採用direct3d9和directdraw的方式來顯示視頻，只能這樣，必須這樣。

網路傳輸與流控
對於網路視頻來講，數據的傳輸與控制是核心價值。WebRTC採用的是成熟的RTP/RTCP技術。

WebRTC的音頻處理分析（windows平台）

WebRTC的音頻部分，包含設備、編解碼(iLIBC/iSAC/G722/PCM16/RED/AVT、NetEQ)、加密、聲音文件、聲音處理、聲音輸出、音量控制、音視頻同步、網路傳輸與流控(RTP/RTCP)等功能。

音頻設備---audio_device
源代碼在webrtc\moles\audio_device\main目錄下，包含介面和各個平台的源代碼。
在windows平台上，WebRTC採用的是Windows Core Audio和Windows Wave技術來管理音頻設備，還提供了一個混音管理器。
利用音頻設備，可以實現聲音輸出，音量控制等功能。

音頻編解碼---audio_coding
源代碼在webrtc\moles\audio_coding目錄下。
WebRTC採用iLIBC/iSAC/G722/PCM16/RED/AVT編解碼技術。
WebRTC還提供NetEQ功能---抖動緩沖器及丟包補償模塊，能夠提高音質，並把延遲減至最小。
另外一個核心功能是基於語音會議的混音處理。

聲音加密--voice_engine_encryption
和視頻一樣，WebRTC也提供聲音加密功能。

聲音文件
該功能是可以用本地文件作為音頻源，支持的格式有Pcm和Wav。
同樣，WebRTC也可以錄制音頻到本地文件。

聲音處理--audio_processing
源代碼在webrtc\moles\audio_processing目錄下。
聲音處理針對音頻數據進行處理，包括回聲消除(AEC)、AECM、自動增益(AGC)、降噪處理等功能，用來提升聲音質量。

網路傳輸與流控
和視頻一樣，WebRTC採用的是成熟的RTP/RTCP技術。

WebRTC的官網是http://www.webrtc.org/，其中的FAQ解答了很多大家關心的問題。有這么幾點可以關註：
1.license
採用BSD licenses，可以用於商業軟體；即使你修改了源代碼，也不必公開你修改的部分。

2.為什麼WebRTC要免費
音視頻針對目前的互聯網應用，還是至關重要的。google這樣做的目的，無非是吸引大量的開發者在chrome平台上開發音視頻相關應用，和當年微軟windows集成IE是一個道理。

3.下載和編譯
a).下載google的源碼工具depot_tools：
svn co http://src.chromium.org/svn/trunk/tools/depot_tools
並把depot_tools添加到系統的環境變數PATH里；
b).下載git工具：並把git添加到系統的環境變數PATH里；
c).創建webrtc工作目錄，並在該目錄下運行：
gclient config https://webrtc.googlecode.com/svn/trunk
gclient sync --force

sync命令也會產生基於本地環境(Linux:make, OSX: XCode, Windows: Visual Studio)的build文件。

也可以用命令：
gclient runhooks --force

對windows平台，在trunk目錄下，已經有針對Visual Studio的工程文件：
webrtc.sln

好了，打開它，這就可以編譯了。

註：webrtc默認使用了C:\Program Files\Microsoft SDKs\Windows\v7.1\Samples\multimedia\directshow\baseclasses。我的機器上只有v7.0的sdk，於是構造了一個v7.1的目錄，僅包含Samples\multimedia\directshow\baseclasses。