网站地图    收藏   

主页 > 系统 > linux系统 >

HTTPSQS入门学习与使用

来源:未知    时间:2015-12-04 09:39 作者:xxadmin 阅读:

[导读] 今天为大家带来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学习,下面是源码:

<?php
include_once("httpsqs_client.php");
$httpsqs = new httpsqs("59.108.228.8",1218,"ituji123", "utf-8");
  //$httpsqs = new httpsqs("59.108.228.8",80,"mypass123","utf-8");
  //var_dump($httpsqs);
 
/*  
1.  将文本信息放入一个队列(注意:如果要放入队列的PHP变量是一个数组,需要事先使用序列化、json_encode等函数转换成文本) 
    如果入队列成功,返回布尔值:true  
    如果入队列失败,返回布尔值:false  
*/  
/**/
$message = "i text queue data"; 
for($i=0; $i<100; $i++)
{
     $result = $httpsqs->put("line_test", $i.$message);
     var_dump($result);
     echo "\n\t";
}
 
/*  
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 "\n\n\n";
 
/*  
6. 查看指定队列位置点的内容 
   返回指定队列位置点的内容。 
*/
//$result = $httpsqs->view("command_line_test", 5);
//echo "###7.view result:\r\n";
//var_dump($result);  //这里没有测试通过,等一下用提供的实例运行一下看看
 
/*  
7. 重置指定队列 
    如果重置队列成功,返回布尔值:true  
    如果重置队列失败,返回布尔值:false 
    重置就是重新设置,以前的信息全部没有了 
*/ 
//$result = $httpsqs->reset("command_line_test");
//var_dump($result);   
//echo "\n\n\n";
 
/*  
8. 更改指定队列的最大队列数量 
   如果更改成功,返回布尔值:true 
   如果更改操作被取消,返回布尔值:false 
*/
/*$result = $httpsqs->maxqueue("command_line_test",10000000);   
var_dump($result);
echo "\n\n\n";
$json = $httpsqs->status_json("command_line_test");
var_dump($json);*/
 
/* 
9. 修改定时刷新内存缓冲区内容到磁盘的间隔时间 
   如果更改成功,返回布尔值:true 
   如果更改操作被取消,返回布尔值:false 
*/ 
//$result = $httpsqs->synctime($num);  //这个没试过
    
?>
  

<?php
include_once("httpsqs_client.php");
$httpsqs = new httpsqs("59.108.228.8",1218,"ituji123", "utf-8");
$name = "line_test";
while(true) {  
  $result = $httpsqs->gets($name);  
  $pos = $result["pos"]; //当前队列消息的读取位置点  
  $data = $result["data"]; //当前队列消息的内容  
  if ($data != "HTTPSQS_GET_END" && $data != "HTTPSQS_ERROR") { 
       //var_dump($data);
       //echo "\n\t"; 
       //...去做应用操作...
       //这里来做个测试
       file_put_contents("httpsqs.txt", $data."\n\t", FILE_APPEND);
  } else {  
       sleep(1); //暂停1秒钟后,再次循环  
  } 
}  
?>


自学PHP网专注网站建设学习,PHP程序学习,平面设计学习,以及操作系统学习

京ICP备14009008号-1@版权所有www.zixuephp.com

网站声明:本站所有视频,教程都由网友上传,站长收集和分享给大家学习使用,如由牵扯版权问题请联系站长邮箱904561283@qq.com

添加评论