我有一個守護程序,運行我們的Web服務(wù)請求的后臺作業(yè).我們有4個工人同時運行.

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

>因為我們的工作來自數(shù)據(jù)庫,所以我們添加了一個稱為execute的標志,該標志防止其他工作獲得已經(jīng)開始執(zhí)行的工作；這不能解決問題,有時我們數(shù)據(jù)庫的延遲足以同時執(zhí)行.

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

這是我們當前正在使用的以下邏輯：

// 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)查找了一個名為Gearman的庫,但是我不相信當我們有多臺服務(wù)器時,它可以解決我的問題.

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

有任何想法嗎？

謝謝.

解決方法:

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

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

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

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

該更新是單個操作,它是原子操作,您僅在尚未設(shè)置worker_id的情況下進行設(shè)置,因此不必擔心競爭狀況.設(shè)置worker_id可以清楚地知道誰擁有該操作.由于LIMIT 1,此更新將只分配一項操作.

標簽：concurrency,daemon,mysql,php

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

總結(jié)

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

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