storm通信機制

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

>>阅读原文<<