PHP Làm cách nào để thực hiện xử lý hàng đợi trong php

Question

Tôi muốn dữ liệu được khách hàng gửi (qua bài đăng) được đặt trong hàng đợi và tập lệnh php trên máy chủ của tôi trước tiên sẽ kiểm tra nếu hàng đợi trống. Nếu hàng đợi không trống, thì tập lệnh sẽ xử lý tất cả dữ liệu trong hàng đợi một. Làm cách nào để làm điều này?

Answer 1

Hãy xem this.

Nó sử dụng memcached để kiên trì.

Answer 2

Bạn có thể sử dụng giống như Zero MQ

Xem Example by Rasmus Lerdorf.

Bạn cũng có thể xem xét sử dụng Gearman để phân phối tải.

Answer 3

Dưới đây là một hướng dẫn tuyệt vời cho việc này:

http://squirrelshaterobots.com/programming/php/building-a-queue-server-in-php-part-1-understanding-the-project/

Các giải pháp khác là sử dụng gearman mà họ dường như đã đưa vào PHP (nó không phải là lần cuối cùng tôi chơi với nó): http://php.net/manual/en/book.gearman.php

Answer 4

Vấn đề với cách tiếp cận cronjob là cronjob có thể ở mức tối đa là 1 phút, vì vậy có thể trì hoãn 1 phút trong quá trình thực hiện công việc, nếu được chấp nhận thì tốt hơn là sử dụng hàng đợi với tập lệnh bỏ phiếu.

Answer 5

Kể từ khi DB quan hệ (Ví dụ: MySQL) rất linh hoạt và được các nhà phát triển web hiểu rõ, chúng được sử dụng cho nhiều loại hàng đợi công việc. Nhiều ứng dụng PHP sử dụng giải pháp này làm dự phòng khi bộ nhớ đệm đối tượng không được định cấu hình. Đó là phương pháp cuối cùng bởi vì đó là một cách rất tốn kém để thực hiện một hàng đợi.

Nếu bạn phải sử dụng MySQL làm hàng đợi, một trong những kỹ sư của Percona đã viết điều này blog entry về việc quản lý các điểm đau tiềm ẩn.

Nếu bạn muốn triển khai khả năng mở rộng nhất, tôi rất muốn giới thiệu ZeroMQ. Tuy nhiên nó không phải là một phần mở rộng PHP mặc định hoặc đặc biệt phổ biến. Vì vậy, đối với một dự án mà bạn sẽ không được kiểm soát ngăn xếp máy chủ web: Sử dụng đối tượng APC, Memcache hoặc Memcached, và sau đó dự phòng vào một bảng bộ nhớ cache MySQL.

Answer 6

Đây là điều bạn có thể dễ dàng thực hiện với thư viện enqueue. Đầu tiên, bạn có thể chọn từ nhiều loại transports, chẳng hạn như AMQP, STOMP, Redis, Amazon SQS, Hệ thống tệp và v.v.

Thứ hai, Rất dễ sử dụng. Hãy bắt đầu cài đặt:

Bạn phải cài đặt thư viện enqueue/simple-client và one of the transports. Giả sử bạn chọn hệ thống tập tin, hãy cài đặt thư viện enqueue/fs.Để tóm tắt:

composer require enqueue/simple-client enqueue/fs 

Bây giờ chúng ta hãy xem làm thế nào bạn có thể gửi tin nhắn từ kịch bản POST của bạn:

<?php 
// producer.php 

use Enqueue\SimpleClient\SimpleClient; 

include __DIR__.'/vendor/autoload.php'; 

$client = new SimpleClient('file://'); // the queue will store messages in tmp folder 

$client->sendEvent('a_topic', 'aMessageData'); 

Kịch bản tiêu thụ:

<?php 
// consumer.php 

use Enqueue\SimpleClient\SimpleClient; 
use Enqueue\Psr\PsrProcessor; 
use Enqueue\Psr\PsrMessage; 

include __DIR__.'/vendor/autoload.php'; 

$client = new SimpleClient('file://'); 

$client->bind('a_topic', 'a_processor_name', function(PsrMessage $psrMessage) { 
    // processing logic here 

    return PsrProcessor::ACK; 
}); 

// this call is optional but it worth to mention it. 
// it configures a broker, for example it can create queues and excanges on RabbitMQ side. 
$client->setupBroker(); 

$client->consume(); 

Run as nhiều consumer.php quá trình như bạn bằng cách sử dụng supervisord hoặc các trình quản lý quy trình khác, trên máy tính cục bộ, bạn có thể chạy nó mà không cần bất kỳ gói hoặc lib bổ sung nào.

Đó là một ví dụ cơ bản và enqueue có rất nhiều tính năng khác có thể có ích. Nếu bạn quan tâm, hãy kiểm tra số enqueue documentation.