|
今天为大家带来httpsqs学习,下面是源码:
put("line_test", $i.$message);
var_dump($result);
echo "nt";
}
/*
2. 从一个队列中取出文本信息
返回该队列的内容
如果没有未被取出的队列,则返回文本信息:HTTPSQS_GET_END
如果发生错误,返回布尔值:false
*/
$result = $httpsqs->get("command_line_test");
var_dump($result);
/*
3. 从一个队列中取出文本信息和当前队列读取点Pos
返回数组示例:array("pos" => 7, "data" => "text message")
如果没有未被取出的队列,则返回数组:array("pos" => 0, "data" => "HTTPSQS_GET_END")
如果发生错误,返回布尔值:false
*/
//$result = $httpsqs->gets("command_line_test");
//var_dump($result);
/*
4. 查看队列状态(普通方式)
*/
$result = $httpsqs->status("line_test");
var_dump($result);
/*
5. 查看队列状态(JSON方式)
返回示例:{"name":"queue_name","maxqueue":5000000,"putpos":130,"putlap":1,"getpos":120,"getlap":1,"unread":10}
*/
//$json = $httpsqs->status_json("command_line_test");
//var_dump($json);
//echo "nnn";
/*
6. 查看指定队列位置点的内容
返回指定队列位置点的内容。
*/
//$result = $httpsqs->view("command_line_test", 5);
//echo "###7.view result:rn";
//var_dump($result); //这里没有测试通过,等一下用提供的实例运行一下看看
/*
7. 重置指定队列
如果重置队列成功,返回布尔值:true
如果重置队列失败,返回布尔值:false
重置就是重新设置,以前的信息全部没有了
*/
//$result = $httpsqs->reset("command_line_test");
//var_dump($result);
//echo "nnn";
/*
8. 更改指定队列的最大队列数量
如果更改成功,返回布尔值:true
如果更改操作被取消,返回布尔值:false
*/
/*$result = $httpsqs->maxqueue("command_line_test",10000000);
var_dump($result);
echo "nnn";
$json = $httpsqs->status_json("command_line_test");
var_dump($json);*/
/*
9. 修改定时刷新内存缓冲区内容到磁盘的间隔时间
如果更改成功,返回布尔值:true
如果更改操作被取消,返回布尔值:false
*/
//$result = $httpsqs->synctime($num); //这个没试过
?>
gets($name);
$pos = $result["pos"]; //当前队列消息的读取位置点
$data = $result["data"]; //当前队列消息的内容
if ($data != "HTTPSQS_GET_END" && $data != "HTTPSQS_ERROR") {
//var_dump($data);
//echo "nt";
//...去做应用操作...
//这里来做个测试
file_put_contents("httpsqs.txt", $data."nt", FILE_APPEND);
} else {
sleep(1); //暂停1秒钟后,再次循环
}
}
?>
|
-
上一篇:sphinx配置文件详解 下一篇:httpsqs基本用法[转]



