Community Learn Tools Library Leisure
search
English
Home > php教程 > php手册 > PHP消息队列httpsqs安装与使用无错版

PHP消息队列httpsqs安装与使用无错版

WBOY
Release： 2016-06-06 19:54:29
Original
2050 people have browsed it

项目网址 ：http://code.google.com/p/httpsqs/ 使用文档 ：http://blog.s135.com/httpsqs/ 说明：由于需要安装的东西有些多，原文可能写的有些简略，所以适当补充了 1.安装libevent-2.0.12-stable.tar.gz wget http://httpsqs.googlecode.com/files/libeven

项目网址：http://code.google.com/p/httpsqs/
使用文档：http://blog.s135.com/httpsqs/

说明：由于需要安装的东西有些多，原文可能写的有些简略，所以适当补充了

 

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 ../ 


2.安装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 ../ 


4.测试

如果安装成功 执行httpsqs –h 会出现
------------------------------------------------------------------------------------------------

-- 
HTTP Simple Queue Service - httpsqs v1.7 (April 14, 2011) 
 
 
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 
 
 
-l   interface to listen on, default is 0.0.0.0 
-p       TCP port number to listen on (default: 1218) 
-x      database directory (example: /opt/httpsqs/data) 
-t    keep-alive timeout for an http request (default: 60) 
-s    the interval to sync updated contents to the disk (default: 5) 
-c       the maximum number of non-leaf nodes to be cached (default: 1024) 
-m      database memory cache size in MB (default: 100) 
-i      save PID in (default: /tmp/httpsqs.pid) 
-a      the auth password to access httpsqs (example: mypass123) 
-d            run as a daemon 
-h            print this help and exit 

 

5.设置

存储目录

#mkdir /usr/local/httpsqs_queue

mkdir /home/bf
vi /home/bf/httpsqs.sh
内容如下：
#! /bin/sh
ulimit -SHn 65535

启动方法

带密码

# /usr/bin/httpsqs -d -p 1218 -t 10 -c 10000 -m 512 -x /usr/local/httpsqs_queue -a pwd123

无密码

# /usr/bin/httpsqs -d -p 1218 -t 10 -c 10000 -m 512 -x /usr/local/httpsqs_queue

干掉的方法
# killall httpsqs 

 

注意需要打开防火墙端口

vim /etc/sysconfig/iptables

添加下面一行，打开防火墙1218端口:

-A INPUT -m state --state NEW -m tcp -p tcp --dport 1218 -j ACCEPT

重启防火墙

#/etc/init.d/iptables restart

 

 

6.使用

写队列
http://192.168.2.103:1218/?name=your_queue_name&opt=put&data=TEXT&auth=pwd123

 

读队列
http://192.168.2.103:1218/?charset=utf-8&name=your_queue_name&opt=get&auth=pwd123

 

写队列无密码
http://192.168.2.103:1218/?name=your_queue_name&opt=put&data=TEXT

读队列无密码
http://192.168.2.103:1218/?charset=utf-8&name=your_queue_name&opt=get


 

 

 


写队列
http://192.168.2.103:1218/?name=your_queue_name&opt=put&data=TEXT&auth=pwd123

读队列
http://192.168.2.103:1218/?charset=utf-8&name=your_queue_name&opt=get&auth=pwd123

 

7.php扩展

参考：http://code.google.com/p/php-httpsqs-client/

安装说明

<span># mkdir php_httpsqs_client 
# cd php_httpsqs_client 
# wget http://php-httpsqs-client.googlecode.com/files/php_httpsqs_client_0.2.1.tar.gz
# tar vzxf php_httpsqs_client_0.2.1.tar.gz
# /usr/local/php/bin/phpize 
</span>
Copy after login
<span>如果</span>
Copy after login
<p>运行/usr/local/webserver/php/bin/phpize时出现：
Configuring for:
PHP Api Version:         20041225
Zend Module Api No:      20060613
Zend Extension Api No:   220060519
Cannot find autoconf. Please check your autoconf installation and the
$PHP_AUTOCONF environment variable. Then, rerun this script.
根据网上的解决办法是：
yum install m4
yum install autoconf</p><p> </p>
Copy after login
<span># ./configure --enable-httpsqs --with-php-config=/usr/local/php/bin/php-config 
# make && make install</span>
Copy after login
<span>#接着在php.ini中添加一行</span><span> 
extension</span><span>=</span><span>httpsqs</span><span>.</span><span>so</span><span>;</span>
Copy after login

 

函数说明

<span>/** 
 * 创建httpsqs连接 
 * @param string $host 服务器地址，可以为空，默认为127.0.0.1 
 * @param int    $port 服务器端口，可以为空，默认为1218 
 * @return resource 
 */</span><span> 
$hr </span><span>=</span><span> httpsqs_connect</span><span>(</span><span>"127.0.0.1"</span><span>,</span><span>1218</span><span>);</span>
Copy after login
<span>/** 
 * 写入队列数据 
 * @param resource $hr      服务器连接句柄 
 * @param string   $queue   队列名称 
 * @param string   $data    写入数据 
 * @param string   $charset 字符集，可以为空，默认为utf-8 
 * @return boolean 
 */</span><span> 
$putRes </span><span>=</span><span> httpsqs_put</span><span>(</span><span>$hr</span><span>,</span><span>"testQueue"</span><span>,</span><span>"This is a test Data"</span><span>,</span><span>"UTF-8"</span><span>);</span>
Copy after login
<span>/**  
 * 获取队列最后一条数据 
 * @param resource $hr 
 * @param string   $queue 
 * @param boolean  $return_array 是否返回数组，可以为空，默认为false 
          返回数组格式：array('pos'=>'队列插入点', 'data'=>'数据值') 
 * @param string   $charset 可以为空 
 * @return mixed 
 */</span><span> 
$content </span><span>=</span><span> httpsqs_get</span><span>(</span><span>$hr</span><span>,</span><span>"testQueue"</span><span>,</span><span>true</span><span>,</span><span>"UTF-8"</span><span>);</span>
Copy after login
<span>/** 
 * 获取队列状态 
 * @param resource $hr 
 * @param string   $queue 
 * @param boolean  $return_json 是否返回状态的json格式，可以为空，默认为false 
 * @return string 
 */</span><span> 
$status </span><span>=</span><span> httpsqs_status</span><span>(</span><span>$hr</span><span>,</span><span>"testQueue"</span><span>,</span><span>true</span><span>);</span>
Copy after login
<span>/** 
 * 获取队列某个点数据 
 * @param resource $hr 
 * @param string   $queue 
 * @param int      $pos 要获取的某条数据的位置 
 * @param string   $charset 可以为空 
 * @return string 
 */</span><span> 
$posData </span><span>=</span><span> httpsqs_view</span><span>(</span><span>$hr</span><span>,</span><span>"testQueue"</span><span>,</span><span>10</span><span>,</span><span>"UTF-8"</span><span>);</span>
Copy after login
<span>/** 
 * 队列重置 
 * @param resource $hr 
 * @param string   $queue 
 * @return boolean 
 */</span><span> 
$resetRes </span><span>=</span><span> httpsqs_reset</span><span>(</span><span>$hr</span><span>,</span><span>"testQueue"</span><span>);</span>
Copy after login
<span>/** 
 * 设置队列最大数据条数 
 * @param resource $hr 
 * @param string   $queue 
 * @param int      $maxqueue 队列最大数据条数 
 * @return boolean 
 */</span><span> 
$maxqueueRes </span><span>=</span><span> httpsqs_maxqueue</span><span>(</span><span>$hr</span><span>,</span><span>"testQueue"</span><span>,</span><span>10000</span><span>);</span>
Copy after login
<span>/** 
 * 修改定时刷新内存缓冲区内容到磁盘的间隔时间 
 * @param resource $hr 
 * @param string   $queue 
 * @param int      $synctime 间隔时间 
 * @return boolean 
 */</span><span> 
$synctimeRes </span><span>=</span><span> httpsqs_synctime</span><span>(</span><span>$hr</span><span>,</span><span>"testQueue"</span><span>,</span><span>10</span><span>);</span>
Copy after login

 

对象调用

<span>// 参数与httpsqs_connect对应</span><span> 
$hr </span><span>=</span><span>new</span><span>HttpSQS</span><span>(</span><span>$host</span><span>,</span><span> $port</span><span>);</span><span> 
 
</span><span>// 参数与httpsqs_get对应</span><span> 
$hr</span><span>-></span><span>get</span><span>(</span><span>$queuename</span><span>,</span><span> $return_array</span><span>,</span><span> $charset</span><span>);</span><span> 
 
</span><span>// 参数与httpsqs_put对应</span><span> 
$hr</span><span>-></span><span>put</span><span>(</span><span>$queuename</span><span>,</span><span> $data</span><span>,</span><span> $charset</span><span>);</span><span> 
 
</span><span>// 参数与httpsqs_status对应</span><span> 
$hr</span><span>-></span><span>status</span><span>(</span><span>$queuename</span><span>,</span><span> $return_json</span><span>);</span><span> 
 
</span><span>// 参数与httpsqs_view对应</span><span> 
$hr</span><span>-></span><span>view</span><span>(</span><span>$queuename</span><span>,</span><span> $pos</span><span>);</span><span> 
 
</span><span>// 参数与httpsqs_reset对应</span><span> 
$hr</span><span>-></span><span>reset</span><span>(</span><span>$queuename</span><span>);</span><span> 
 
</span><span>// 参数与httpsqs_maxqueue对应</span><span> 
$hr</span><span>-></span><span>maxqueue</span><span>(</span><span>$queuename</span><span>);</span><span> 
 
</span><span>// 参数与httpsqs_synctime对应</span><span> 
$hr</span><span>-></span><span>synctime</span><span>(</span><span>$queuename</span><span>);</span>
Copy after login

 

示例

<span>// 取数据Daemon</span><span> 
$hr </span><span>=</span><span> httpsqs_connect</span><span>(</span><span>$host</span><span>,</span><span> $port</span><span>);</span><span> 
</span><span>while</span><span>(</span><span>1</span><span>)</span><span>{</span><span> 
    $data </span><span>=</span><span> httpsqs_get</span><span>(</span><span>$hr</span><span>,</span><span> $queuename</span><span>,</span><span> $charset</span><span>);</span><span> 
    </span><span>if</span><span>(</span><span>$data </span><span>===</span><span>false</span><span>)</span><span>{</span><span> 
       sleep</span><span>(</span><span>1</span><span>);</span><span> 
    </span><span>}</span><span>else</span><span>{</span><span> 
      </span><span>// do something...</span><span> 
    </span><span>}</span><span> 
</span><span>}</span><span> 
 
</span><span>// 或者</span><span> 
$hr </span><span>=</span><span>new</span><span>HttpSQS</span><span>(</span><span>$host</span><span>,</span><span> $port</span><span>);</span><span> 
</span><span>while</span><span>(</span><span>1</span><span>)</span><span>{</span><span> 
    $data </span><span>=</span><span> $hr</span><span>-></span><span>get</span><span>(</span><span>$queuename</span><span>,</span><span> $charset</span><span>);</span><span> 
    </span><span>if</span><span>(</span><span>$data </span><span>===</span><span>false</span><span>)</span><span>{</span><span> 
        sleep</span><span>(</span><span>1</span><span>);</span><span> 
    </span><span>}</span><span>else</span><span>{</span><span> 
      </span><span>// do something...</span><span> 
    </span><span>}</span><span> 
</span><span>}</span><span> 
 
</span><span>// 写数据</span><span> 
$hr </span><span>=</span><span> httpsqs_connect</span><span>(</span><span>$hort</span><span>,</span><span> $port</span><span>);</span><span> 
httpsqs_put</span><span>(</span><span>$hr</span><span>,</span><span> $queuename</span><span>,</span><span> $data</span><span>,</span><span> $charset</span><span>);</span><span> 
 
</span><span>// 或者</span><span> 
$hr </span><span>=</span><span>new</span><span>HttpSQS</span><span>(</span><span>$hort</span><span>,</span><span> $port</span><span>);</span><span> 
$hr</span><span>-></span><span>put</span><span>(</span><span>$queuename</span><span>,</span><span> $data</span><span>,</span><span> $charset</span><span>);</span>
Copy after login

 

写入

$hr = httpsqs_connect("127.0.0.1", 1218);
$putRes = httpsqs_put($hr, "testQueue", "Text", "UTF-8");
?>

读取

$hr = httpsqs_connect("127.0.0.1", 1218);
$content = httpsqs_get($hr, "testQueue", true, "UTF-8");
//print_r($content);
echo $content['data'];

?>

Related labels：
php use Install information queue project
source：php.cn
Previous article：［ 转］PHP中VC6 X86和VC9 X86的区别及 Non Thread Safe的意思 Next article：php读mysql中文乱码问题解决方法
Statement of this Website
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
Latest Articles by Author
Latest Issues
PHP arrays obtained from URL parameters do not behave as expected I have a URL parameter that contains the category ID and I want to treat it as an array li...
From 2024-04-06 22:09:02
0
1
1428
Where should I place CustomLog directive in apache I'm using php:7.2-apachedocker. I need to disable health check url login access log. Based...
From 2024-04-06 22:03:59
0
1
990
What is the format of the variables in the return value? I am a new learner of php. I found a piece of code: if($x<time()){return[false,'error']...
From 2024-04-06 21:55:20
0
1
778
Problems encountered when using opentbs to generate odt files: values ​​of the same key are displayed in the same row instead of separate columns. I'm using a library called OpenTbs to create odt using PHP, I'm using it because columns a...
From 2024-04-06 20:18:18
0
1
483
Group MySQL results by ID for looping over I have a table with flight data in mysql. I'm writing a php code that will group and displ...
From 2024-04-06 17:27:56
0
1
406
Related Topics
More>
Popular Recommendations
Popular Tutorials
More>
Related Tutorials
Popular Recommendations
Latest courses
Latest Downloads
More>
Web Effects
Website Source Code
Website Materials
Front End Template