用戶中心USER CENTER
摘要：中使用那一套，線程的速度，你知道的而對于分布式數據流來說，本來就是并行的，這種參數意義就不大了。函數種類一般作用在數據流上的函數，會分為兩類。中的程序是實現在數據流上的。可以看作是的更新日志，數據流中的每一個記錄對應數據庫中的每一次更新。最近入職一個有趣的年輕同事，提交了大量大量的代碼。翻開git記錄一看，原來是用了非常多的java8的語法特性，重構了代碼。用的最多的，就是map、flatM...
番茄西紅柿
發布于
摘要：公平鎖為了保證時間上的絕對順序，需要頻繁的上下文切換，而非公平鎖會降低一定的上下文切換，降低性能開銷。因此，默認選擇的是非公平鎖，則是為了減少一部分上下文切換，保證了系統更大的吞吐量。ReentrantLock簡介ReentrantLock重入鎖，是實現Lock接口的一個類，也是在實際編程中使用頻率很高的一個鎖， 支持重入性，表示能夠對共享資源能夠重復加鎖，即當前線程獲取該鎖再次獲取不會被阻...
番茄西紅柿
發布于
摘要：主題和分區的悄息通過主題進行分類。在給定的分區里，每個悄息的偏移量都是唯一的。消費者把每個分區最后讀取的悄息偏移量保存在或上，如果悄費者關閉或重啟，它的讀取狀態不會丟失。主題可以配置自己的保留策略，可以將悄息保留到不再使用它們為止。發布與訂閱消息系統 在正式討論Apache Kafka (以下簡稱Kafka)之前，先來了解發布與訂閱消息系統的概念， 并認識這個系統的重要性。數據(消息)的發送...
番茄西紅柿
發布于
摘要：本文這里主要來講述的三個版本的消息格式的演變，文章偏長，建議先關注后鑒定。消息格式版本號，此版本的值為。表示消息的的長度。實際消息體的長度。外層消息保存了內層消息中最后一條消息的絕對位移，絕對位移是指相對于整個而言的。 摘要 對于一個成熟的消息中間件而言，消息格式不僅關系到功能維度的擴展，還牽涉到性能維度的優化。隨著Kafka的迅猛發展，其消息格式也在不斷的升級改進，從0.8.x版本開始到現...
番茄西紅柿
發布于
摘要：實現接口通過源碼可以看到繼承自實現了接口接口接口接口。因此也說明類是線程不安全的類。插入指定位置插入元素，其邏輯如下校驗是否有效范圍，否則拋出數組越界異常擴容確保能有效插入。雙指針的思路，一個讀指針，一個寫指針。ArrayList是最常用的一種集合類型。今天通過閱讀源碼的方式來加深對它的學習和理解。 ##實現接口 public class ArrayList extends Abstract...
番茄西紅柿
發布于
