Làm cách nào để phát hiện xem tập lệnh PHP đã chạy chưa?

Question

Tôi có một tập lệnh cron thực thi một tập lệnh PHP cứ 10 phút một lần. Kịch bản lệnh kiểm tra hàng đợi và xử lý dữ liệu trong hàng đợi. Đôi khi hàng đợi có đủ dữ liệu để kéo dài hơn 10 phút xử lý, tạo ra tiềm năng của hai tập lệnh cố gắng truy cập cùng một dữ liệu. Tôi muốn có thể phát hiện xem tập lệnh đã chạy chưa để khởi chạy nhiều bản sao của tập lệnh. Tôi nghĩ về việc tạo ra một lá cờ cơ sở dữ liệu cho biết rằng một tập lệnh đang xử lý, nhưng nếu kịch bản đã từng sụp đổ, nó sẽ để nó ở trạng thái tích cực. Có cách nào dễ dàng để biết liệu kịch bản PHP có đang chạy từ việc sử dụng một script PHP hay shell không?

Answer 1

Nếu bạn cần nó hoàn toàn chống va chạm, bạn nên sử dụng semaphores, được phát hành tự động khi php kết thúc xử lý yêu cầu cụ thể.

Cách tiếp cận đơn giản hơn là tạo bản ghi DB hoặc tệp lúc bắt đầu thực hiện và xóa tệp ở cuối. Bạn luôn có thể kiểm tra "tuổi" của bản ghi/tệp đó và nếu nó lớn hơn 3 lần so với thực thi tập lệnh thông thường, giả sử nó đã bị lỗi và xóa nó.

Không có "viên đạn bạc", nó chỉ phụ thuộc vào nhu cầu của bạn.

Answer 2

Cách phổ biến cho các trình tiện ích * nix (mặc dù không nhất thiết là các tập lệnh PHP, nhưng nó sẽ hoạt động) là sử dụng tệp .pid.

Khi tập lệnh bắt đầu kiểm tra sự tồn tại của tệp .pid được đặt tên cho tập lệnh (thường được lưu trữ trong/var/run /). Nếu nó không tồn tại, tạo ra nó thiết lập nội dung của nó đến PID của quá trình chạy kịch bản (sử dụng getmypid) sau đó tiếp tục thực hiện bình thường. Nếu nó tồn tại, hãy đọc PID từ nó và xem liệu quá trình đó vẫn đang chạy, có thể bằng cách chạy ps $pid. Nếu nó đang chạy, thoát. Nếu không, ghi đè nội dung của nó bằng PID của bạn (như trên) và tiếp tục thực hiện bình thường.

Khi thực hiện xong, hãy xóa tệp.

Answer 3

Tôi biết đây là câu hỏi cũ nhưng trong trường hợp ai đó đang xem ở đây, tôi sẽ đăng một số mã. Đây là những gì tôi đã làm gần đây trong một tình huống tương tự và nó hoạt động tốt. Đặt mã này ở đầu tệp của bạn và nếu cùng một tập lệnh đã chạy, nó sẽ để lại và kết thúc tệp mới.

Tôi sử dụng nó để giữ cho một hệ thống giám sát luôn hoạt động. Một công việc cron bắt đầu kịch bản mỗi 5 phút nhưng trừ khi người kia đã dừng lại từ một số lý do (thường là nếu nó đã bị rơi, rất hiếm!) Cái mới sẽ tự thoát ra.

// The file to store our process file 
define('PROCESS_FILE', 'process.pid'); 

// Check I am running from the command line 
if (PHP_SAPI != 'cli') { 
    log_message('Run me from the command line'); 
    exit; 
} 

// Check if I'm already running and kill myself off if I am 
$pid_running = false; 
if (file_exists(PROCESS_FILE)) { 
    $data = file(PROCESS_FILE); 
    foreach ($data as $pid) { 
     $pid = (int)$pid; 
     if ($pid > 0 && file_exists('/proc/' . $pid)) { 
      $pid_running = $pid; 
      break; 
     } 
    } 
} 
if ($pid_running && $pid_running != getmypid()) { 
    if (file_exists(PROCESS_FILE)) { 
     file_put_contents(PROCESS_FILE, $pid); 
    } 
    log_message('I am already running as pid ' . $pid . ' so stopping now'); 
    exit; 
} else { 
    // Make sure file has just me in it 
    file_put_contents(PROCESS_FILE, getmypid()); 
    log_message('Written pid with id '.getmypid()); 
} 

Nó sẽ KHÔNG hoạt động mà không sửa đổi trên Windows, nhưng sẽ ổn trong các hệ thống dựa trên Unix.

Answer 4

Điều này phù hợp với tôi. Đặt bản ghi cơ sở dữ liệu bằng cờ khóa và dấu thời gian. Kịch bản của tôi phải hoàn thành tốt trong vòng 15 phút để nói thêm rằng như một feild khóa cuối cùng để kiểm tra:

 $lockresult = mysql_query(" 
     SELECT * 
     FROM queue_locks 
     WHERE `lastlocked` > DATE_SUB(NOW() , INTERVAL 15 MINUTE)  
     AND `locked` = 'yes' 
     AND `queid` = '1' 
     LIMIT 1 
     "); 
$LockedRowCount = mysql_num_rows($lockresult); 

if($LockedRowCount>0){ 
    echo "this script is locked, try again later"; 
    exit; 
}else{ 
//Set the DB record to locked and carry on son 
$result = mysql_query(" 
      UPDATE `queue_locks` SET `locked` = 'yes', `lastlocked` = CURRENT_TIMESTAMP WHERE `queid` = 1; 
      "); 

} 

Sau đó mở khóa nó ở phần cuối của kịch bản:

$result = mysql_query("UPDATE `queue_locks` SET `locked` = 'no' WHERE `queid` = 1;"); 

Answer 5

Bạn chỉ có thể sử dụng một tập tin khóa. Chức năng flock() của PHP cung cấp một trình bao bọc đơn giản cho chức năng flock của Unix, cung cấp các khóa cố định trên các tệp.

Nếu bạn không phát hành chúng một cách rõ ràng, hệ điều hành sẽ tự động giải phóng các khóa này cho bạn khi quá trình giữ chúng chấm dứt, ngay cả khi nó chấm dứt bất thường.

Bạn cũng có thể thực hiện theo quy ước Unix làm cho tệp khóa của bạn thành 'tệp PID' - tức là, khi lấy khóa trên tệp, hãy viết tập lệnh PID của bạn vào đó. Thậm chí nếu bạn không bao giờ đọc điều này từ bên trong kịch bản của bạn, nó sẽ thuận tiện cho bạn nếu kịch bản của bạn bị treo hoặc phát điên và bạn muốn tìm PID của nó để tự tay giết nó.

Dưới đây là một sao chép/dán sẵn sàng thực hiện:

#!/usr/bin/php 
<?php 

$lock_file = fopen('path/to/yourlock.pid', 'c'); 
$got_lock = flock($lock_file, LOCK_EX | LOCK_NB, $wouldblock); 
if ($lock_file === false || (!$got_lock && !$wouldblock)) { 
    throw new Exception(
     "Unexpected error opening or locking lock file. Perhaps you " . 
     "don't have permission to write to the lock file or its " . 
     "containing directory?" 
    ); 
} 
else if (!$got_lock && $wouldblock) { 
    exit("Another instance is already running; terminating.\n"); 
} 

// Lock acquired; let's write our PID to the lock file for the convenience 
// of humans who may wish to terminate the script. 
ftruncate($lock_file, 0); 
fwrite($lock_file, getmypid() . "\n"); 

/* 
    The main body of your script goes here. 
*/ 
echo "Hello, world!"; 

// All done; we blank the PID file and explicitly release the lock 
// (although this should be unnecessary) before terminating. 
ftruncate($lock_file, 0); 
flock($lock_file, LOCK_UN); 

Chỉ cần thiết lập đường dẫn của tập tin khóa của bạn đến bất cứ nơi bạn thích và bạn thiết lập.

Answer 6

Bạn có thể sử dụng mới Symfony 2.6 LockHandler

$lock = new LockHandler('update:contents'); 
if (!$lock->lock()) { 
    echo 'The command is already running in another process.'; 
} 

Answer 7

Tôi biết đây là một câu hỏi cũ, nhưng có một cách tiếp cận mà chưa được đề cập trước đây mà tôi nghĩ là đáng xem xét.

Một trong những vấn đề với giải pháp khóa cơ sở dữ liệu hoặc khóa cơ sở dữ liệu, như đã đề cập, là nếu tập lệnh không thành công vì lý do nào đó ngoài hoàn thành bình thường, nó sẽ không giải phóng khóa. Và do đó trường hợp tiếp theo sẽ không bắt đầu cho đến khi khóa được xóa bằng tay hoặc xóa bằng chức năng dọn dẹp.

Nếu bạn chắc chắn rằng tập lệnh chỉ nên chạy một lần, thì việc kiểm tra từ bên trong tập lệnh sẽ tương đối dễ dàng dù tập lệnh đã chạy khi bạn khởi động nó. Dưới đây là một số mã:

function checkrun() { 
    exec("ps auxww",$ps); 
    $r = 0; 
    foreach ($ps as $p) { 
     if (strpos($p,basename(__FILE__))) { 
      $r++; 
      if ($r > 1) { 
       echo "too many instances, exiting\n"; 
       exit(); 
      } 
     } 
    } 
} 

Đơn giản chỉ cần gọi hàm này vào lúc bắt đầu của kịch bản, trước khi bạn làm bất cứ điều gì khác (chẳng hạn như một handler cơ sở dữ liệu mở hoặc xử lý một tập tin nhập khẩu), và nếu kịch bản tương tự cũng đã chạy rồi nó sẽ xuất hiện hai lần trong danh sách quy trình - một lần cho trường hợp trước đó và một lần cho trường hợp này. Vì vậy, nếu nó xuất hiện nhiều lần, chỉ cần thoát.

Một hình ảnh xác thực tại đây: Tôi giả định rằng bạn sẽ không bao giờ có hai tập lệnh có cùng tên cơ sở có thể chạy đồng thời một cách hợp pháp (ví dụ: cùng một tập lệnh chạy dưới hai người dùng khác nhau). Nếu đó là một khả năng, thì bạn cần phải mở rộng việc kiểm tra đến một cái gì đó tinh vi hơn một chuỗi con đơn giản trên tên tệp của tệp. Nhưng điều này hoạt động tốt nếu bạn có tên tập tin duy nhất cho kịch bản của bạn.

Answer 8

Nếu bạn đang chạy Linux, điều này sẽ làm việc ở phía trên cùng của kịch bản của bạn:

$running = exec("ps aux|grep ". basename(__FILE__) ."|grep -v grep|wc -l"); 
if($running > 1) { 
    exit; 
} 

Answer 9

Chỉ cần thêm sau trên đỉnh của kịch bản của bạn.

<?php 
    // Ensures single instance of script run at a time. 
    $fileName = basename(__FILE__); 
    $output = shell_exec("ps -ef | grep -v grep | grep $fileName | wc -l"); 
    //echo $output; 
    if ($output > 2) 
    { 
     echo "Already running - $fileName\n"; 
     exit; 
    } 

    // Your php script code. 
?> 

Answer 10

Tôi đã thử cách này. Hoạt động tốt trong Windows.

$status_file=__DIR__.'/mail_process.txt'; 
    if(file_exists($status_file) && file_get_contents($status_file)=='running'){ 
       echo 'Program running'; 
      exit; 
    } 
    file_put_contents($status_file,'running'); 

     // Code block 
     //........... 

    file_put_contents($status_file,'finished'); 

Nhờ @martinodf cho ý tưởng của mình.