基于HTTP協(xié)議的輕量級開源簡單隊列服務(wù)：HTTPSQS（引用地址：http://zyan.cc/httpsqs/）

1. HTTPSQS 具有以下特征：

• 非常簡單，基于 HTTP GET/POST 協(xié)議纹烹。PHP谤逼、Java、Perl、Shell、Python、Ruby等支持HTTP協(xié)議的編程語言均可調(diào)用坐榆。
• 非常快速冗茸，入隊列席镀、出隊列速度超過10000次/秒。
• 高并發(fā)夏漱，支持上萬的并發(fā)連接豪诲，C10K不成問題。
• 支持多隊列挂绰。
• 單個隊列支持的最大隊列數(shù)量高達10億條屎篱。
• 低內(nèi)存消耗，海量數(shù)據(jù)存儲葵蒂，存儲幾十GB的數(shù)據(jù)只需不到100MB的物理內(nèi)存緩沖區(qū)交播。
• 可以在不停止服務(wù)的情況下便捷地修改單個隊列的最大隊列數(shù)量。
• 可以實時查看隊列狀態(tài)（入隊列位置践付、出隊列位置秦士、未讀隊列數(shù)量、最大隊列數(shù)量）永高。
• 可以查看指定隊列ID（隊列點）的內(nèi)容隧土，包括未出、已出的隊列內(nèi)容乏梁。
• 查看隊列內(nèi)容時次洼，支持多字符集編碼关贵。
• 源代碼不超過800行遇骑，適合二次開發(fā)。

2.1 HTTPSQS 編譯安裝(軟件包下載地址 https://code.google.com/p/httpsqs/downloads/list)

cd /var/www/com.bigood

sudo mkdir httpsqs

sudo chown -R www-data:www-data httpsqs/

cd httpsqs/

sudo wget https://httpsqs.googlecode.com/files/httpsqs-1.7.tar.gz

sudo wget https://httpsqs.googlecode.com/files/libevent-2.0.12-stable.tar.gz

sudo wget https://httpsqs.googlecode.com/files/tokyocabinet-1.4.47.tar.gz

sudo wget http://fallabs.com/tokyotyrant/tokyotyrant-1.1.41.tar.gz 

2.2 安裝 libevent-2.0.12-stable

sudo tar zxvf libevent-2.0.12-stable.tar.gz 

cd libevent-2.0.12-stable/

sudo ./configure --prefix=/usr/local/libevent-2.0.12-stable/
 
sudo make 

sudo make install 

2.3 安裝 tokyocabinet-1.4.47 (此步驟必須在安裝tokyotyrant 之前揖曾。)

sudo tar zxvf tokyocabinet-1.4.47.tar.gz

cd tokyocabinet-1.4.47/

sudo ./configure --prefix=/usr/local/tokyocabinet-1.4.47/

tips: error1.  configure: error: zlib.h is required

sudo apt-get install zlib1g-dev

tips: error2. configure: error: bzlib.h is required

sudo aptitude install libbz2-dev 

sudo make 

sudo make install 

2.4 安裝 tokyotyrant-1.1.41

sudo tar zxvf tokyotyrant-1.1.41.tar.gz 

cd tokyotyrant-1.1.41/ 

sudo ./configure --prefix=/usr/local/tokyotyrant-1.1.41/ --with-tc=/usr/local/tokyocabinet-1.4.47/ --enable-lua 

tips: configure: error: lua.h is required

sudo tar zxvf lua-5.3.0.tar.gz 

cd lua-5.3.0/ 

sudo make linux

tips: lua.c:80:31: fatal error: readline/readline.h: No such file or directory

sudo apt-get install libreadline6 libreadline6-dev




sudo wget http://www.lua.org/ftp/lua-5.3.0.tar.gz

sudo make

sudo make install 

2.5 安裝 httpsqs 1.7 (httpsqs -h 查看是否安裝成功)

sudo tar zxvf httpsqs-1.7.tar.gz

cd httpsqs-1.7/

sudo make 

sudo make install 

2.6 安裝 php 擴展落萎。

sudo tar zxvf php_httpsqs_client_0.2.1.tar.gz 

sudo mkdir php_httpsqs_client

sudo mv php_httpsqs_client_0.2.1.tar.gz php_httpsqs_client

cd php_httpsqs_client/

sudo tar zxvf php_httpsqs_client_0.2.1.tar.gz 

sudo apt-get install php5-dev

sudo ./configure --enable-httpsqs --with-php-config=/usr/bin/php-config5

sudo make 

sudo make install

cd /etc/php5/mods-available/

sudo vi httpsqs.ini

extension=httpsqs.so;

 cd /etc/php5/conf.d/
 
 sudo ln -s ../mods-available/httpsqs.ini 30-httpsqs.ini
 
 sudo service php5-fpm restart 

2.7 使用(創(chuàng)建一個隊列,查看監(jiān)聽端口的情況亥啦，停止服務(wù))

httpsqs -l 127.0.0.1 -d -p 1218 -x /var/www/com.bigood/httpsqs-data -a ceca846c3dbca3fc

sudo netstat   -anp  | grep 1218

sudo killall httpsqs

2.8 php 客戶端說明文檔 (httpsqs_client.php 文件下載地址:https://code.google.com/p/httpsqs/source/browse/trunk/client/php/httpsqs_client.php)

<?php  
    include_once("httpsqs_client.php");   
    $httpsqs = new httpsqs($httpsqs_host, $httpsqs_port, $httpsqs_auth, $httpsqs_charset);   
   
    /*  
    1. 將文本信息放入一個隊列（注意：如果要放入隊列的PHP變量是一個數(shù)組，需要事先使用序列化练链、json_encode等函數(shù)轉(zhuǎn)換成文本） 
       如果入隊列成功翔脱，返回布爾值：true  
       如果入隊列失敗，返回布爾值：false  
    */   
    $result = $httpsqs->put($queue_name, $queue_data);   
   
    /*  
    2. 從一個隊列中取出文本信息 
       返回該隊列的內(nèi)容 
       如果沒有未被取出的隊列媒鼓，則返回文本信息：HTTPSQS_GET_END 
       如果發(fā)生錯誤届吁，返回布爾值：false  
    */   
    $result = $httpsqs->get($queue_name);   
      
    /*  
    3. 從一個隊列中取出文本信息和當前隊列讀取點Pos 
       返回數(shù)組示例：array("pos" => 7, "data" => "text message") 
       如果沒有未被取出的隊列，則返回數(shù)組：array("pos" => 0, "data" => "HTTPSQS_GET_END") 
       如果發(fā)生錯誤绿鸣，返回布爾值：false 
    */   
    $result = $httpsqs->gets($queue_name);  
      
    /*  
    4. 查看隊列狀態(tài)（普通方式） 
    */   
    $result = $httpsqs->status($queue_name);  
      
    /*  
    5. 查看隊列狀態(tài)（JSON方式） 
       返回示例：{"name":"queue_name","maxqueue":5000000,"putpos":130,"putlap":1,"getpos":120,"getlap":1,"unread":10} 
    */   
    $result = $httpsqs->status_json($queue_name);  
       
    /*  
    6. 查看指定隊列位置點的內(nèi)容 
       返回指定隊列位置點的內(nèi)容疚沐。 
    */   
    $result = $httpsqs->view($queue_name, $queue_pos);  
       
    /*  
    7. 重置指定隊列 
       如果重置隊列成功，返回布爾值：true  
       如果重置隊列失敗潮模，返回布爾值：false  
    */   
    $result = $httpsqs->reset($queue_name);  
       
    /*  
    8. 更改指定隊列的最大隊列數(shù)量 
       如果更改成功亮蛔，返回布爾值：true 
       如果更改操作被取消，返回布爾值：false 
    */   
    $result = $httpsqs->maxqueue($queue_name, $num);  
      
    /* 
    9. 修改定時刷新內(nèi)存緩沖區(qū)內(nèi)容到磁盤的間隔時間 
       如果更改成功擎厢，返回布爾值：true 
       如果更改操作被取消究流，返回布爾值：false 
    */  
    $result = $httpsqs->synctime($num);