storm通訊機制

storm通訊機制 Worker間的通訊常常須要經過網絡跨節點進行，Storm使用ZeroMQ或Netty(0.9之後默認使用)做爲進程間通訊的消息框架。 Worker進程內部通訊：不一樣worker的thread通訊使用LMAX Disruptor來完成。 不一樣topologey之間的通訊，Storm不負責，須要本身想辦法實現，例如使用kafka等；node 1.Worker進程間通訊 wor

>>阅读原文<<