SpringXD 任务、启动消息通信代码流程分析

发表于 | 本文总阅读量 次

通信流程概括

  • 任务部署时，xd-admin和container之间通过zookeeper的节点监听通信。container监听zk deployment节点，执行部署。同事绑定kafka message consumer和reactor subscriber。
  • 任务启动时，xd-admin和container通过kafka通信。container端消费到kafka的message，然后通过reactor的事件机制转发处理。

Thanks a lot.