我希望将客户端(通过post)发送的数据放在一个队列中,服务器上的php脚本首先检查队列是否为空。如果队列不为空,那么脚本将按one.How逐个处理队列中的所有数据。我要这样做吗?
发布于 2017-06-20 21:12:10
这是您可以使用enqueue库轻松完成的事情。首先,您可以从各种transports中进行选择,例如AMQP、STOMP、Redis、Amazon SQS、文件系统等。
其次,这非常容易使用。让我们从安装开始:
您必须安装enqueue/simple-client
库和one of the transports。假设您选择文件系统,请安装enqueue/fs
库。总结一下:
composer require enqueue/simple-client enqueue/fs
现在让我们看看如何从您的POST脚本发送消息:
<?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');
消费脚本:
<?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();
通过使用supervisord或其他进程管理器运行尽可能多的consumer.php
进程,在本地计算机上,您可以在没有任何额外的库或包的情况下运行它。
这是一个基本的例子,而且enqueue还有很多其他可能会派上用场的特性。如果您感兴趣,请查看enqueue documentation。
发布于 2012-07-06 14:51:59
发布于 2012-07-06 14:50:30
看看this吧。
它使用memcached实现持久性。
https://stackoverflow.com/questions/11357187
复制相似问题