Storm通信机制(了解)

Worker间的通信:经常需要通过网络跨节点进行,Storm使用ZeroMQ或Netty(0.9以后默认使用)作为进程间通信的消息框架。 Worker进程内部通信:不同worker的thread通信使用LMAX Disruptor来完成。 不同topologey之间的通信:Storm不负责,需要自己想办法实现,例如使用kafka等;   1、worker进程间的通信 worker进程间消息传递机制
相关文章
相关标签/搜索