所以,我现在有一个正在运行的简单的减速器系统,有一个工人正在运行。
工作人员基本上只是获取有效负载(在这种情况下,是一个随机数,应该将其回显到屏幕上。从字面上看,是echo
,而不是返回给客户端。
客户端发送随机数。我尝试执行$client->doBackground( 'post', 65482, md5(uniqid()));
,但每次都返回47错误(GEARMAN_TIMEOUT
)。
[getErrNo()
返回0,error()
返回有关GEARMAN_TIMEOUT
的信息
但是,当我将其更改为$client->do(blah, blah, blah)
时,它就可以正常工作。
我什至偶尔看到它,即使在收到超时错误之后,工作人员仍在回声该数字...
public function execute()
{
$method = 'do';
if( !$this->getBlock() )
{
$method .= ( $this->getPriority() == 'Normal' ? '' : $this->getPriority() ) . 'Background';
}
else
{
$method .= $this->getPriority();
}
echo "Method: $method \t Worker: {$this->getName()} \t Payload: {$this->getPayload()} \t Hash: {$this->getHash()}\n";
$this->setResult(
$this->getClient()
->$method(
$this->getName(),
$this->getPayload(),
$this->getHash()
)
);
if( $this->getClient()->returnCode() != GEARMAN_SUCCESS )
{
echo "Code: " . $this->getClient()->returnCode() . "\t" . GEARMAN_TIMEOUT . "\n";
}
}
回声返回
Method: doHighBackground Worker: leadposter Payload: 10930 Hash: 091878f5965e4a1de2992c607b3c562b240792a6
这里显示错误信息
["error":"Uecode\GearmanBundle\Gearman\Job":private]=>
array(4) {
["attempts"]=>
int(3)
["return_code"]=>
int(47)
["error_no"]=>
int(0)
["error"]=>
string(103) "gearman_wait(GEARMAN_TIMEOUT) timeout reached, no servers were available -> libgearman/universal.cc:325"
}
已解决。
连接不会在方法之间持久存在...因此,在运行作业之前,建立服务器池并连接到服务器
如果您的gearmand
在另一个端口上,请确保AddServers
知道,否则将GEARMAN_TIMEOUT
。
gearmand -d -p 4769
$worker->addServers(127.0.0.1:4769);