无法保留工作与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 

这不是文档，这似乎意味着“使用”上昭然若揭命令自动具有使用管保留命令 - 就像把自动使用该管。

希望这可以帮助其他beanstalkd新手！

Answer 2

它旨在阻止储备 - 它正在等待工作。在另一端，把作业放到管 - 您的储备命令将与新的工作回报。

Answer 3

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

这份文件更加清晰。

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

“监视”命令将命名管到观察名单当前 连接。保留命令将采取从工作中的任何 观察名单的管。对于每一个新的连接，观察名单最初由一个 管，命名为“默认”。

所以在消费者中你不需要叫“使用”，而是叫“看”