Spark Worker源碼

目錄   1、概述 2、LaunchDriver 3、LaunchDriver 4、總結 1、概述 worker肯定是實現RPC通信的，否則別人沒法給你發消息。他繼承的是ThreadSafeRpcEndpoint，ThreadSafeRpcEndpoint是線程安全的，意味着處理一條消息完成後再處理下一個消息。換句話說，在處理下一條消息時，可以看到對ThreadSafeRpcEndpoint的內部

>>阅读原文<<