storm通讯机制

storm通讯机制 Worker间的通讯常常须要经过网络跨节点进行,Storm使用ZeroMQ或Netty(0.9之后默认使用)做为进程间通讯的消息框架。 Worker进程内部通讯:不一样worker的thread通讯使用LMAX Disruptor来完成。 不一样topologey之间的通讯,Storm不负责,须要本身想办法实现,例如使用kafka等;node 1.Worker进程间通讯 wor
相关文章
相关标签/搜索