服务器技术

 首页 > 服务器技术 > Linux > HTTPSQS入门学习与使用

HTTPSQS入门学习与使用

分享到:
【字体:
导读:
          今天为大家带来httpsqs学习,下面是源码: ?phpinclude_once(httpsqs_client.php);$httpsqs=newhttpsqs(59.108.228.8,1218,ituji123,utf-8);//$httpsqs=newhttpsqs(59.108.228.8,80,mypass123,utf-8);//var_dump($httpsqs);/*1.将文本信息...

今天为大家带来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基本用法[转]
    分享到:
    sphinx配置文件详解
    Source 源名称1{ //指定数据源 一些配置 } Index 索引名称1{ Source=源名称1 } Source 源名称2{ 一些配置 } Index 索引名称2{ Source=源名称2 } Indexer{ mem_limit = 32M } Searchd{  //配置 searchd 守护程序本身 } 二.    Source 源名称 相关配置说明 Type=数据库类型(Mysql 或SQL); Sql_host=         ...
    httpsqs基本用法[转]
    基于 HTTP GET/POST 协议的轻量级开源简单消息队列服务 启动/停止 启动 httpsqs -d -x /opt/httpsqs/data 停止 pkill httpsqs 参数 -l  监听的IP地址,默认值为 0.0.0.0  -p  监听的TCP端口(默认值:1218) -x  数据库目录,目录不存在会自动创建(例如:/opt/httpsqs/data) -t  HTTP请求的超时时间(...
    •         php迷,一个php技术的分享社区,专属您自己的技术摘抄本、收藏夹。
    • 在这里……