主從模式是容錯(cuò)和并行計(jì)算的主要示例。 模式背后的想法是將工作劃分為相同的子任務(wù)，然后將其委派給從屬。 這些從節(jié)點(diǎn)或?qū)嵗龑⑻幚砉ぷ魅蝿?wù)，并將結(jié)果發(fā)送回主節(jié)點(diǎn)。 然后主節(jié)點(diǎn)將編譯從所有從節(jié)點(diǎn)接收到的結(jié)果。關(guān)鍵是從節(jié)點(diǎn)僅知道如何處理任務(wù)，而不知道輸出會(huì)發(fā)生什么。

主從模式類似于網(wǎng)格計(jì)算模式，其中控制節(jié)點(diǎn)將工作分配給其他節(jié)點(diǎn)。 想法是利用網(wǎng)絡(luò)上的節(jié)點(diǎn)進(jìn)行計(jì)算。 SETI @ Home是使用此模型的最早的先驅(qū)之一。

我建立了一個(gè)類似的示例，不同之處在于工作節(jié)點(diǎn)在遠(yuǎn)程節(jié)點(diǎn)上啟動(dòng)，工作節(jié)點(diǎn)向Master（WorkServer）注冊(cè)，然后隨后開始處理工作包。 如果沒有在Master（WorkServer）上注冊(cè)的工人從屬服務(wù)器，則主服務(wù)器將等待工人進(jìn)行注冊(cè)。 工人可以隨時(shí)注冊(cè)，并從那里開始獲取工作包。

該示例演示了WorkerActor系統(tǒng)如何發(fā)送注冊(cè)請(qǐng)求。 RegisterRemoteWorker接收該請(qǐng)求，并將其轉(zhuǎn)發(fā)到JobController，在此更新RoundRobinRouter以獲得新的工作程序信息。 WorkScheduler定期向JobController發(fā)送請(qǐng)求，JobController然后將數(shù)據(jù)包發(fā)送給所有注冊(cè)的工作人員。

對(duì)于遠(yuǎn)程角色死后如何處理故障或如何重新處理尚未處理的數(shù)據(jù)包，該示例未實(shí)現(xiàn)容錯(cuò)功能。 同樣，在某些情況下，遠(yuǎn)程工作人員可能希望在處理一定數(shù)量的數(shù)據(jù)包后關(guān)閉，然后他們可以指示主機(jī)停止給他們工作。 我將盡快添加容錯(cuò)功能！

更新 ：更新了代碼庫(kù)以處理工作程序關(guān)閉。 如果遠(yuǎn)程角色死掉或關(guān)閉，則JobController使用遠(yuǎn)程角色偵聽器檢測(cè)到故障轉(zhuǎn)移，并更新路由器。

本方案的代碼庫(kù)可在以下位置- https://github.com/write2munish/Akka-Essentials的GridPatternExample下

參考：來(lái)自Akka Essentials博客的JCG合作伙伴 Munish K Gupta在Akka中 實(shí)現(xiàn)了主從/網(wǎng)格計(jì)算模式 。

翻譯自: https://www.javacodegeeks.com/2012/05/implementing-master-slave-grid.html

總結(jié)

以上是生活随笔為你收集整理的在Akka中实现主从/网格计算模式的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。