mf4php / mf4php-beanstalk

这是Beanstalk的mf4php绑定。

1.1.3 2014-02-20 16:46 UTC

This package is not auto-updated.

Last update: 2024-09-14 12:29:18 UTC


README

这是为mf4php提供的Beanstalk绑定

注意

您必须创建自己的长运行脚本以从beanstalk保留消息并将工作转发到调度器。

原因不实现为调度器是因为它应该监视多个队列,这在单个进程中是不可能的。另一个原因是,通常需要创建一个轻量级的长运行脚本,不使用任何打开的资源(数据库等),并执行CLI程序以将消息传递给调度器。

配置

<?php
$dispatcher = new BeanstalkMessageDispatcher($pheanstalk);
$queue = new DefaultQueue('queue');

/* @var $listener MessageListener */
$dispatcher->addEventListener($queue, $listener);

发送事件

<?php
/* @var $object Serializable */
$message = new BeanstalkMessage($object);
$dispatcher->send($queue, $message);
// onMessage method in $listener is called