我有一個(gè)守護(hù)程序,運(yùn)行我們的Web服務(wù)請(qǐng)求的后臺(tái)作業(yè).我們有4個(gè)工人同時(shí)運(yùn)行.

有時(shí),一個(gè)作業(yè)同時(shí)執(zhí)行兩次,因?yàn)閮蓚€(gè)工人決定運(yùn)行該作業(yè).為了避免這種情況,我們嘗試了幾件事：

>因?yàn)槲覀兊墓ぷ鱽碜詳?shù)據(jù)庫(kù),所以我們添加了一個(gè)稱為execute的標(biāo)志,該標(biāo)志防止其他工作獲得已經(jīng)開始執(zhí)行的工作；這不能解決問題,有時(shí)我們數(shù)據(jù)庫(kù)的延遲足以同時(shí)執(zhí)行.

>在系統(tǒng)中添加了memcached(所有工作程序都在同一個(gè)系統(tǒng)中運(yùn)行),但是由于某種原因,我們今天同時(shí)運(yùn)行了多個(gè)作業(yè)-memcached不能同時(shí)解決多臺(tái)服務(wù)器的問題.

這是我們當(dāng)前正在使用的以下邏輯：

// We create our memcached server

$memcached = new Memcached();

$memcached->addServer("127.0.0.1", 11211);

// Checkup every 5 seconds for operations

while (true) {

// Gather all operations TODO

// In this query, we do not accept operations that are set

// as executed already.

$result = findDaemonOperationsPendingQuery();

// We have some results!

if (mysqli_num_rows($result) > 0) {

$op = mysqli_fetch_assoc($result);

echo "Found an operation todo #" . $op['id'] . "\n";

// Set operation as executed

setDaemonOperationAsDone($op['id'], 'executed');

// Verifies if operation is happening on memcached

if (get_memcached_operation($memcached, $op['id'])) {

echo "\tOperation id already executing...\n";

continue;

} else {

// Set operation on memcached

set_memcached_operation($memcached, $op['id']);

}

... do our stuff

}

}

通常如何解決這種問題？

我上網(wǎng)查找了一個(gè)名為Gearman的庫(kù),但是我不相信當(dāng)我們有多臺(tái)服務(wù)器時(shí),它可以解決我的問題.

我想到的另一件事是預(yù)定義一個(gè)守護(hù)程序以在插入時(shí)運(yùn)行該操作,并創(chuàng)建一個(gè)故障安全的獨(dú)占守護(hù)程序,該守護(hù)程序運(yùn)行由停止運(yùn)行的守護(hù)程序設(shè)置的操作.

有任何想法嗎？

謝謝.

解決方法:

假設(shè)每個(gè)工作人員都有一個(gè)ID,這是使用鎖和事務(wù)的一種替代解決方案.

在循環(huán)中運(yùn)行：

UPDATE operations SET worker_id = :wid WHERE worker_id IS NULL LIMIT 1;

SELECT * FROM operations where executed = 0 and worker_id = :wid;

該更新是單個(gè)操作,它是原子操作,您僅在尚未設(shè)置worker_id的情況下進(jìn)行設(shè)置,因此不必?fù)?dān)心競(jìng)爭(zhēng)狀況.設(shè)置worker_id可以清楚地知道誰擁有該操作.由于LIMIT 1,此更新將只分配一項(xiàng)操作.

標(biāo)簽：concurrency,daemon,mysql,php

來源： https://codeday.me/bug/20191025/1928540.html

總結(jié)

以上是生活随笔為你收集整理的同时运行两个PHP吗,PHP-避免由两个工作人员同时运行后台作业的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

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