我正在編寫(xiě)一個(gè)帶有 spring(mvc,data,security) 的網(wǎng)絡(luò)服務(wù)器,它為物理設(shè)備提供任務(wù)(設(shè)備數(shù)量約為 100)。設(shè)備內(nèi)部沒(méi)有查詢(xún)實(shí)現(xiàn)。例如,要執(zhí)行某些任務(wù),您需要編寫(xiě)如下內(nèi)容:Device driver = new DeviceDriver();driver.setSettings(settingsJson);driver.open(); // noone else can't connect to this device, open() can take up to 1 seconddriver.setTask(taskJson);driver.processTask(); // each task takes a few seconds to executeString results = driver.getResults();driver.close();我并不是真正的架構(gòu)設(shè)計(jì)專(zhuān)家,所以現(xiàn)在實(shí)現(xiàn)的網(wǎng)絡(luò)服務(wù)器是這樣的:TaskController (@RestController) - 處理帶有任務(wù)的傳入 Post 請(qǐng)求并將它們持久化到數(shù)據(jù)庫(kù)。DeviceService (@Service) - 具有 init 方法,該方法從數(shù)據(jù)庫(kù)中獲取設(shè)備列表并為每個(gè)設(shè)備創(chuàng)建/啟動(dòng)一個(gè)工作人員。它將 taskRepository 傳遞給每個(gè) worker,因此內(nèi)部的 worker 可以保存任務(wù)的結(jié)果。Worker - 擴(kuò)展Thread,它在一定時(shí)期內(nèi)從數(shù)據(jù)庫(kù)中獲取下一個(gè)任務(wù)(通過(guò)帶有睡眠的循環(huán))。當(dāng)任務(wù)執(zhí)行時(shí),工作人員將結(jié)果保存到數(shù)據(jù)庫(kù)并更新任務(wù)狀態(tài)。這種方法有意義嗎?也許有更好的方法來(lái)使用彈簧組件而不是線(xiàn)程來(lái)做到這一點(diǎn)。
2 回答

蕪湖不蕪
TA貢獻(xiàn)1796條經(jīng)驗(yàn) 獲得超7個(gè)贊
我不會(huì)為每個(gè)設(shè)備(客戶(hù)端)創(chuàng)建工作人員。因?yàn)槟目刂破鲗⒛軌驗(yàn)椴渴鹪诨诿總€(gè)請(qǐng)求線(xiàn)程的服務(wù)器上的并發(fā)請(qǐng)求提供服務(wù)。此外,這根本不是可擴(kuò)展的——如果有一個(gè)新設(shè)備板載怎么辦?您需要對(duì)數(shù)據(jù)庫(kù)進(jìn)行更改,以當(dāng)前設(shè)計(jì)重新啟動(dòng)服務(wù)!
如果您需要特定于設(shè)備的操作,您可以將其傳遞給來(lái)自設(shè)備客戶(hù)端的請(qǐng)求參數(shù)。因此,沒(méi)有必要保留一組預(yù)定義的工人。
所以,設(shè)計(jì)看起來(lái)不錯(cuò),除了工人集。

幕布斯7119047
TA貢獻(xiàn)1794條經(jīng)驗(yàn) 獲得超8個(gè)贊
在你的函數(shù)上使用 @Scheduled 注釋來(lái)構(gòu)建類(lèi)似 cron 的東西
添加回答
舉報(bào)
0/150
提交
取消