1

我已经尝试在两台不同的服务器上启动并运行 beanstalkd 并进行一些测试(本地在 MacOSX 上从源代码编译,以及在安装了 yum 的 CentOS 服务器上)

我可以让服务器运行

sudo beanstalkd -d -p 11300

或者

sudo beanstalkd -p 11300 &

然后我尝试使用 php lib,它只是冻结了。直接连接:

telnet localhost 11300

我执行以下操作来模仿 PHP 测试脚本:

use foo
USING foo
put 0 0 120 5
hello
INSERTED 1
reserve-with-timeout 0
TIMED_OUT

如果我只是跑

reserve

它被无限期地卡住了。

PHP代码是

    /**
    * BeanStalk 0.10 - Example code
    * 
    * This is a quick example to get you started using the client.
    */

    require(dirname(__FILE__).'/../src/BeanStalk.class.php');

    /**
    * Connect to the beanstalkd server(s)
    * 
    * Option array:
    * 
    *       array(
    *           'servers'               => array( 'ip:port'[, 'ip:port'[, ...]] ),
    *           'select'                => 'random wait',
    *           'connection_timeout'    => 0.5,
    *           'peek_usleep'           => 2500,
    *           'connection_retries'    => 3,
    *           'auto_unyaml'           => true
    *       );
    * 
    * select -> this tells the client what type of blocking to use when selecting from 
    * different servers. There are currently four choices:
    * 
    *   random wait:        pick a random server from the list and wait for a job
    * 
    *   sequential wait:    pick the next server in the list and wait for a job
    * 
    *   random peek:        in a loop, pick a random server and peek-ready(), looking for a job
    *                       until a server is found that has something available.
    * 
    *   sequential peek:    in a loop, pick the next server and peek-ready() ... etc.
    * 
    * the *peek modes have a companion setting, peek_usleep, which tells the client how long
    * to usleep() for between peeks to servers.
    * 
    * auto_unyaml -> if true, this causes the client to assume the presence of the syck yaml
    * parser, and attempts to 'unyamlize' yaml output for you before returning it.
    */
echo "opening\n";
    $beanstalk = BeanStalk::open(array(
        'servers'       => array( '127.0.0.1:11300' ),
        'select'        => 'random peek'
    ));

echo "switching tube\n";

    // As in the protocol doc.
    $beanstalk->use_tube('foo');

echo "putting job\n";

    // As in the protocol doc.
    $beanstalk->put(0, 0, 120, 'say hello world');      // Add a job to the queue with highest priority, 
                                                        // no delay, 120 seconds TTR, with the contents
                                                        // 'say hello world'.

                                                        // NOTE: the put() method here supports a final optional 
                                                        // argument, a tube name. If supplied, the server will
                                                        // first switch to that tube, write the job, then switch
                                                        // back to the old tube again.

echo "trying to reserve\n";

    // As in the protocol doc.
    $job = $beanstalk->reserve();                       // Assuming there was nothing in the queue before 
                                                        // we started, this will give us our 'hello world'
                                                        // job back.

echo "about to output\n";    

    // This is a BeanQueueJob object.
    echo $job->get();                                   // Output: 'say hello world'

    Beanstalk::delete($job);                            // Delete the job.

并且只是冻结在“试图保留”上。原始代码来自:

http://sourceforge.net/projects/beanstalk/

有任何想法吗?提前致谢。

4

3 回答 3

7

要使用默认以外的管子,您似乎需要为该管子添加一个“手表”。例如:

use foo
USING foo
put 0 0 120 5
hello
INSERTED 1
reserve-with-timeout 5
TIMED_OUT
list-tubes
OK 20
---
- default
- foo

watch foo
WATCHING 2
reserve-with-timeout 5
RESERVED 1 5
hello

这在文档中并不太清楚,这似乎暗示“使用”命令自动具有使用管的保留命令 - 就像 put 自动使用该管一样。

希望这可以帮助其他beantalkd新手!

于 2010-05-12T14:48:14.010 回答
3

https://raw.github.com/kr/beanstalkd/master/doc/protocol.txt

这个文件更清楚。

“使用”命令适用于生产者。随后的 put 命令会将作业放入此命令指定的管中。如果未发出使用命令,作业将被放入名为“default”的管中。

“watch”命令将命名的管添加到当前连接的监视列表中。保留命令将从监视列表中的任何管中获取工作。对于每个新连接,监视列表最初由一个名为“default”的管组成。

所以在消费者中你不需要调用“使用”,而是调用“手表”

于 2013-06-26T07:22:15.320 回答
-1

它旨在阻止保留 - 它正在等待工作。在另一个终端中,工作放入管中 - 您的储备命令将与新工作一起返回。

于 2011-02-08T10:33:06.443 回答