- 论坛徽章:
- 0
|
php 服务端 代码
<?php
header ( 'Content-type:text/html;charset=utf8' );
set_time_limit(0);
echo "Starting\n";
# Create our worker object.
$gmworker= new GearmanWorker();
# Add default server (localhost).
$gmworker->addServer("127.0.0.1",4730);
$gmworker->addFunction("json_php", "json_worker_php");
print "Waiting for job...\n";
while($gmworker->work())
{
if ($gmworker->returnCode() != GEARMAN_SUCCESS)
{
echo "return_code: " . $gmworker->returnCode() . "\n";
break;
}
}
function json_worker_php($job)
{
echo $job->workload();
echo gettype($job->workload())."\n";
$jsonx=json_decode($job->workload(),true);
echo "\n";
echo "json_decode.".function_exists("json_decode")."\n";
$json2=json_decode('{"name":"123","id":"123"}',true);
echo "\n";
print_r($jsonx);
echo "\nname:";
echo $jsonx['name']."\n";
return $jsonx['name'];
}
?>
python 代码
#coding:utf-8
import gearman
gm_client = gearman.GearmanClient(['127.0.0.1:4730'])
completed_job_request = gm_client.submit_job("json_php", "{\"name\":\"rose\",\"id\",\"123\"}")
dir(gearman)
print completed_job_request.result
返回结果 为空
php worker输出
Starting
Waiting for job...
{"name":"rose","id","123"}string
json_decode.1
name:
|
|