代码拉取完成,页面将自动刷新
同步操作将从 pengzhile/PQP Queue Processor 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
composer require pengzhile/pqp
<?php
//require '/path/to/PQP/autoload.php'; // native autoloader
require '/path/to/vendor/autoload.php'; // composer autoloader
use PQP\Contracts\Observer;
use PQP\Contracts\Queue;
use PQP\Listener;
use PQP\Queues\RedisQueue;
class Processor1 implements Observer
{
/**
* @param Queue $queue Current queue
* @param int $workerId From 0 to $config['workerNum'] - 1
*/
public function update(Queue $queue, $workerId)
{
list($key, $content) = $queue->current();
echo 'key: ', $key, '; content: ', $content, '; from: ', $workerId, PHP_EOL;
}
}
// config.ini file copied from /path/to/PQP/config.ini.example
$listener = new Listener('config.ini');
// more processors [chain]
$listener->attach(new Processor1());
// RedisQueue require php redis extension
$listener->listen(new RedisQueue(array('queueKey1', 'queueKey2'), '127.0.0.1'));
// after listen
// send SIGHUP(kill -1 <listener pid>) to listener process will restart all workers.
// send SIGTERM(kill <listener pid>) to listener process will stop PQP.
// send SIGINT(Ctrl+C or kill -2 <listener pid>) to listener process will stop PQP.
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。