生活随笔
收集整理的這篇文章主要介紹了
httpsqs消息队列
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
安裝：
??
在安裝httpsqs之前要安裝
libevent-2.0.12-stable.tar.gz和okyocabinet-1.4.47.tar.gz?? ulimit?-SHn?65535?? 1、安裝libevent-2.0.12-stable.tar.gz
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?../?? 安裝tokyocabinet-1.4.47.tar.gz
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?../?? 當執行第二步驟的會出錯，是由于缺少bzip2-1.0.6.tar.gz
?
下面進行安裝
http://www.bzip.org/1.0.6/bzip2-1.0.6.tar.gz安裝開始；??wget??http://www.bzip.org/1.0.6/bzip2-1.0.6.tar.gz??tar?-xvzf?bzip2-1.0.6.tar.gz??cd?bzip2-1.0.6.??make???make?install?? 在重復安裝tokyocabinet-1.4.47.tar.gz還是失敗，由于缺少zlib-1.2.5.tar.gz
?
下面進行安裝
http://www.winimage.com/zLibDll/zlib-1.2.5.tar.gz安裝開始；??wget??http://www.winimage.com/zLibDll/zlib-1.2.5.tar.gz??tar?-xvzf?zlib-1.2.5.tar.gz??cd?zlib-1.2.5.??./configure??make??sudo?make?instal?? 繼續第2步驟 OK
?
3、安裝httpsqs-1.7.tar.gz
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?../ ? <?php
/*
----------------------------------------------------------------------------------------------------------------
HTTP Simple Queue Service - httpsqs client class for PHP v1.7.1Author: 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='127.0.0.1', $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 = $line;list($proto, $rcode, $result) = explode(" ", $line);$len = -1;$pos_value = 0;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 = $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;}
}
?>
轉載于:https://www.cnblogs.com/canbefree/p/4126808.html
總結
以上是生活随笔為你收集整理的httpsqs消息队列的全部內容，希望文章能夠幫你解決所遇到的問題。
如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。
