Java和ZeroMQ:一个任务控制器(主节点)和多个工作线程(任务节点)



我想知道如何实现下一个任务分配方案:

TaskController(主节点)

这个控制器可以创建作业,发送给worker, 异步地接收worker的回复。

Worker (task node)

Worker接收到一个新的job,并且异步地运行它,在job完成后Worker发送结果给TaskController。Worker可以接收多个作业并异步运行。

最后,我想让TaskController(主节点)和3个worker(任务节点)接收作业,异步运行作业并回复异步接收消息并处理的TaskController(主节点)。

在所有ZeroMQ示例中,worker都是同步的-一个worker一次可以处理一个作业。

ZeroMQ可以帮助我的任务?或者我需要另一个解?

是的,经销商和路由器套接字可以用于异步通信。http://zguide.zeromq.org/page:all#toc76

最新更新