聊聊流式批處理

要說流式微批處理，就不得不說一下TCP流。典型的tcp IO流模型有，bio，僞異步IO，NIO，AIO，Rector模型等。我們這裏主要是說僞異步IO。 下面我們一步步將其改造成spark Streaming的 SocketStream。 在僞異步模式，我們是客戶端通過TCP鏈接到服務端。這種在分佈式模式下不可行，對於Spark Streaming的微批處理，我們根本不知道Receiver運行在

>>阅读原文<<