无法使用 beanstalkd 预订工作

Question

我已经尝试在两台不同的服务器上启动并运行 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/

有什么想法吗？提前致谢。

Answer 1

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

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

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

希望这对其他beantalkd新手有所帮助！

Answer 2

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

这个文件比较清楚。

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

“watch”命令将命名管添加到当前的观察列表中 联系。保留命令将从中的任何管中获取工作 观察名单。对于每个新连接，监视列表最初包含一个 管，命名为“默认”。

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

Answer 3

它的设计目的是阻止保留 - 它正在等待工作。在另一个终端中，将一份工作放入试管中 - 您的储备命令将与新工作一起返回。