轻量级简单队列服务HTTPSQS安装与使用
生活随笔
收集整理的這篇文章主要介紹了
轻量级简单队列服务HTTPSQS安装与使用
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
原文地址：http://blog.s135.com/httpsqs
1.安裝
wget http://httpsqs.googlecode.com/files/libevent-2.0.12-stable.tar.gz
tar zxvf libevent-2.0.12-stable.tar.gz
cd libevent-2.0.12-stable/
./configure --prefix=/usr/local/libevent-2.0.12-stable/
make
make install
cd ../
wget http://httpsqs.googlecode.com/files/tokyocabinet-1.4.47.tar.gz
tar zxvf tokyocabinet-1.4.47.tar.gz
cd tokyocabinet-1.4.47/
./configure --prefix=/usr/local/tokyocabinet-1.4.47/
#注：在32位Linux操作系統上編譯Tokyo cabinet，請使用./configure --enable-off64代替./configure，可以使數據庫文件突破2GB的限制。
#./configure --enable-off64 --prefix=/usr/local/tokyocabinet-1.4.47/
make
make install
cd ../
wget http://httpsqs.googlecode.com/files/httpsqs-1.7.tar.gz
tar zxvf httpsqs-1.7.tar.gz
cd httpsqs-1.7/
make
make install
cd ../
性能調優（可選）
#ulimit -SHn 65535
2.啟動
#httpsqs -d -p 1218 -x /data0/queue
請使用命令“killall httpsqs”、“pkill httpsqs”和“kill `cat /tmp/httpsqs.pid`”來停止httpsqs。
注意：請不要使用命令“pkill -9 httpsqs”和“kill -9 httpsqs的進程ID”來結束httpsqs，否則，內存中尚未保存到磁盤的數據將會丟失。
3.調用
(1)、入隊列（將文本消息放入隊列）：
HTTP GET 協議（以curl命令為例）：
HTTP POST 協議（以curl命令為例）：
curl -d "經過URL編碼的文本消息" "http://host:port/?name=your_queue_name&opt=put&auth=mypass123"
(2)、出隊列（從隊列中取出文本消息）：
HTTP GET 協議（以curl命令為例）：
curl "http://host:port/?charset=gb2312&name=your_queue_name&opt=get&auth=mypass123"
httpsqs_client.php
<?php
/* ----------------------------------------------------------------------------------------------------------------
HTTP Simple Queue Service - httpsqs client class for PHP v1.7.1
Author: Zhang Yan (http://blog.s135.com), E-mail: net@s135.com
This is free software, and you are welcome to modify and redistribute it under the New BSD License
----------------------------------------------------------------------------------------------------------------
Useage:
<?php include_once("httpsqs_client.php");
$httpsqs = new httpsqs($httpsqs_host, $httpsqs_port, $httpsqs_auth, $httpsqs_charset);
$result = $httpsqs->put($queue_name, $queue_data); //1. PUT text message into a queue. If PUT successful, return boolean: true. If an error occurs, return boolean: false. If queue full, return text: HTTPSQS_PUT_END
$result = $httpsqs->get($queue_name); //2. GET text message from a queue. Return the queue contents. If an error occurs, return boolean: false. If there is no unread queue message, return text: HTTPSQS_GET_END
$result = $httpsqs->gets($queue_name); //3. GET text message and pos from a queue. Return example: array("pos" => 7, "data" => "text message"). If an error occurs, return boolean: false. If there is no unread queue message, return: array("pos" => 0, "data" => "HTTPSQS_GET_END")
$result = $httpsqs->status($queue_name); //4. View queue status
$result = $httpsqs->status_json($queue_name); //5. View queue status in json. Return example: {"name":"queue_name","maxqueue":5000000,"putpos":130,"putlap":1,"getpos":120,"getlap":1,"unread":10}
$result = $httpsqs->view($queue_name, $queue_pos); //6. View the contents of the specified queue pos (id). Return the contents of the specified queue pos.
$result = $httpsqs->reset($queue_name); //7. Reset the queue. If reset successful, return boolean: true. If an error occurs, return boolean: false
$result = $httpsqs->maxqueue($queue_name, $num); //8. Change the maximum queue length of per-queue. If change the maximum queue length successful, return boolean: true. If it be cancelled, return boolean: false
$result = $httpsqs->synctime($num); //9. Change the interval to sync updated contents to the disk. If change the interval successful, return boolean: true. If it be cancelled, return boolean: false
?>
---------------------------------------------------------------------------------------------------------------- */
class httpsqs {
public $httpsqs_host;
public $httpsqs_port;
public $httpsqs_auth;
public $httpsqs_charset;
public function __construct() {
$host='192.168.20.59';$port=1218; $auth=''; $charset='utf-8';
$this->httpsqs_host = $host;
$this->httpsqs_port = $port;
$this->httpsqs_auth = $auth;
$this->httpsqs_charset = $charset;
return true;
} public function http_get($query)
{
$socket = fsockopen($this->httpsqs_host, $this->httpsqs_port, $errno, $errstr, 5);
if (!$socket)
{
return false;
}
$out = "GET ${query} HTTP/1.1\r\n";
$out .= "Host: ".$this->httpsqs_host."\r\n";
$out .= "Connection: close\r\n";
$out .= "\r\n";
fwrite($socket, $out);
$line = trim(fgets($socket));
$header="";
$header .= $line;
list($proto, $rcode, $result) = explode(" ", $line);
$len = -1;
while (($line = trim(fgets($socket))) != "")
{
$header .= $line;
if (strstr($line, "Content-Length:"))
{
list($cl, $len) = explode(" ", $line);
}
if (strstr($line, "Pos:"))
{
list($pos_key, $pos_value) = explode(" ", $line);
}
if (strstr($line, "Connection: close"))
{
$close = true;
}
}
if ($len < 0)
{
return false;
}
$body = fread($socket, $len);
$fread_times = 0;
while(strlen($body) < $len){
$body1 = fread($socket, $len);
$body .= $body1;
unset($body1);
if ($fread_times > 100)
{
break;
}
$fread_times++;
}
//if ($close) fclose($socket);
fclose($socket);
$result_array["pos"] = (int)$pos_value;
$result_array["data"] = $body;
return $result_array;
} public function http_post($query, $body)
{
$socket = fsockopen($this->httpsqs_host, $this->httpsqs_port, $errno, $errstr, 1);
if (!$socket)
{
return false;
}
$out = "POST ${query} HTTP/1.1\r\n";
$out .= "Host: " . $this->httpsqs_host . "\r\n";
$out .= "Content-Length: " . strlen($body) . "\r\n";
$out .= "Connection: close\r\n";
$out .= "\r\n";
$out .= $body;
fwrite($socket, $out);
$line = trim(fgets($socket));
$header="";
$header .= $line;
list($proto, $rcode, $result) = explode(" ", $line);
$len = -1;
while (($line = trim(fgets($socket))) != "")
{
$header .= $line;
if (strstr($line, "Content-Length:"))
{
list($cl, $len) = explode(" ", $line);
}
if (strstr($line, "Pos:"))
{
list($pos_key, $pos_value) = explode(" ", $line);
}
if (strstr($line, "Connection: close"))
{
$close = true;
}
}
if ($len < 0)
{
return false;
}
$body = @fread($socket, $len);
//if ($close) fclose($socket);
fclose($socket);
$result_array["pos"] = (int)$pos_value;
$result_array["data"] = $body;
return $result_array;
} public function put($queue_name, $queue_data)
{
$result = $this->http_post("/?auth=".$this->httpsqs_auth."&charset=".$this->httpsqs_charset."&name=".$queue_name."&opt=put", $queue_data);
if ($result["data"] == "HTTPSQS_PUT_OK")
{
return true;
}
else if ($result["data"] == "HTTPSQS_PUT_END")
{
return $result["data"];
}
return false;
} public function get($queue_name)
{
$result = $this->http_get("/?auth=".$this->httpsqs_auth."&charset=".$this->httpsqs_charset."&name=".$queue_name."&opt=get");
if ($result == false || $result["data"] == "HTTPSQS_ERROR" || $result["data"] == false)
{
return false;
}
return $result["data"];
} public function gets($queue_name)
{
$result = $this->http_get("/?auth=".$this->httpsqs_auth."&charset=".$this->httpsqs_charset."&name=".$queue_name."&opt=get");
if ($result == false || $result["data"] == "HTTPSQS_ERROR" || $result["data"] == false)
{
return false;
}
return $result;
} public function status($queue_name)
{
$result = $this->http_get("/?auth=".$this->httpsqs_auth."&charset=".$this->httpsqs_charset."&name=".$queue_name."&opt=status");
if ($result == false || $result["data"] == "HTTPSQS_ERROR" || $result["data"] == false)
{
return false;
}
return $result["data"];
} public function view($queue_name, $queue_pos)
{
$result = $this->http_get("/?auth=".$this->httpsqs_auth."&charset=".$this->httpsqs_charset."&name=".$queue_name."&opt=view&pos=".$pos);
if ($result == false || $result["data"] == "HTTPSQS_ERROR" || $result["data"] == false)
{
return false;
}
return $result["data"];
} public function reset($queue_name)
{
$result = $this->http_get("/?auth=".$this->httpsqs_auth."&charset=".$this->httpsqs_charset."&name=".$queue_name."&opt=reset");
if ($result["data"] == "HTTPSQS_RESET_OK")
{
return true;
}
return false;
} public function maxqueue($queue_name, $num)
{
$result = $this->http_get("/?auth=".$this->httpsqs_auth."&charset=".$this->httpsqs_charset."&name=".$queue_name."&opt=maxqueue&num=".$num);
if ($result["data"] == "HTTPSQS_MAXQUEUE_OK")
{
return true;
}
return false;
} public function status_json($queue_name)
{
$result = $this->http_get("/?auth=".$this->httpsqs_auth."&charset=".$this->httpsqs_charset."&name=".$queue_name."&opt=status_json");
if ($result == false || $result["data"] == "HTTPSQS_ERROR" || $result["data"] == false)
{
return false;
}
return $result["data"];
} public function synctime($num)
{
$result = $this->http_get("/?auth=".$this->httpsqs_auth."&charset=".$this->httpsqs_charset."&name=httpsqs_synctime&opt=synctime&num=".$num);
if ($result["data"] == "HTTPSQS_SYNCTIME_OK")
{
return true;
}
return false;
}
}
?> <?phpinclude_once("httpsqs_client.php");
$httpsqs = new httpsqs();
$result = $httpsqs->put("city", date('Y-m-d H:i:s',time()));
echo $result;
echo "</br>";
$result = $httpsqs->get("city");
echo $result;
?><?php
include_once("httpsqs_client.php");
$httpsqs = new httpsqs($httpsqs_host, $httpsqs_port, $httpsqs_auth, $httpsqs_charset); /*
1. 將文本信息放入一個隊列（注意：如果要放入隊列的PHP變量是一個數組，需要事先使用序列化、json_encode等函數轉換成文本）如果入隊列成功，返回布爾值：true 如果入隊列失敗，返回布爾值：false
*/
$result = $httpsqs->put($queue_name, $queue_data); /*
2. 從一個隊列中取出文本信息返回該隊列的內容如果沒有未被取出的隊列，則返回文本信息：HTTPSQS_GET_END如果發生錯誤，返回布爾值：false
*/
$result = $httpsqs->get($queue_name); /*
3. 從一個隊列中取出文本信息和當前隊列讀取點Pos返回數組示例：array("pos" => 7, "data" => "text message")如果沒有未被取出的隊列，則返回數組：array("pos" => 0, "data" => "HTTPSQS_GET_END")如果發生錯誤，返回布爾值：false
*/
$result = $httpsqs->gets($queue_name);/*
4. 查看隊列狀態（普通方式）
*/
$result = $httpsqs->status($queue_name);/*
5. 查看隊列狀態（JSON方式）返回示例：{"name":"queue_name","maxqueue":5000000,"putpos":130,"putlap":1,"getpos":120,"getlap":1,"unread":10}
*/
$result = $httpsqs->status_json($queue_name);/*
6. 查看指定隊列位置點的內容返回指定隊列位置點的內容。
*/
$result = $httpsqs->view($queue_name, $queue_pos);/*
7. 重置指定隊列如果重置隊列成功，返回布爾值：true 如果重置隊列失敗，返回布爾值：false
*/
$result = $httpsqs->reset($queue_name);/*
8. 更改指定隊列的最大隊列數量如果更改成功，返回布爾值：true如果更改操作被取消，返回布爾值：false
*/
$result = $httpsqs->maxqueue($queue_name, $num);/*
9. 修改定時刷新內存緩沖區內容到磁盤的間隔時間如果更改成功，返回布爾值：true如果更改操作被取消，返回布爾值：false
*/
$result = $httpsqs->synctime($num);
?>總結
以上是生活随笔為你收集整理的轻量级简单队列服务HTTPSQS安装与使用的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 关于 ulimit -SHn 65535
- 下一篇： FAST-CGI安装与使用