php使用zeromq
Zeromq是個(gè)啥玩意？
Connect your code in any language, on any platform.
Carries messages across inproc, IPC, TCP, TPIC, multicast.
Smart patterns like pub-sub, push-pull, and router-dealer.
High-speed asynchronous I/O engines, in a tiny library.
Backed by a large and active open source community.
Supports every modern language and platform.
Build any architecture: centralized, distributed, small, or large.
Free software with?full commercial support
以上是官方頁(yè)面的介紹，大意是說(shuō)一種跨平臺(tái)，可以使用任何語(yǔ)言使用的消息中間件，可以通過(guò)inproc，IPC,TCP,TPIC,多播的消息傳遞消息，包括多種模式，pub-sub（分發(fā)-訂閱），push-pull（推送模式），router-dealer（路由模式）等等等等。極高的處理速度是其重要的特性之一。
官方詳細(xì)介紹請(qǐng)?jiān)L問(wèn)：http://zeromq.org/
安裝：
#wget?http://download.zeromq.org/zeromq-4.0.4.tar.gz
#tar zxvf zeromq-4.0.4.tar.gz
#cd zeromq-4.0.4
#./configure=/usr/local/zeromq404
#make
#make install
安裝PHP擴(kuò)展：
#git clone git://github.com/mkoppanen/php-zmq.git
#cd php-zmq
#/usr/local/php/bin/phpize ? ? ? ? //自己PHP的安裝目錄，根據(jù)需要更改
#./configure --with-php-config=/usr/local/php/bin/php-config --with-zmq=/usr/local/zeromq404 ? ?//php-config需要根據(jù)自己的情況進(jìn)行更改
#make
#make install
安裝好之后會(huì)在/usr/local/php/lib/php/extensions/no-debug-zts-20090626/目錄下面生成zmq.so
修改配置文件：
#vim /etc/php.ini
修改extension_dir="/usr/local/php/lib/php/extensions/no-debug-zts-20090626/"
增加extension=zmq.so
重啟apache
訪問(wèn)phpinfo，如果看到zmq的相關(guān)信息表明已經(jīng)OK了
測(cè)試：
系統(tǒng)分兩部分：client和server端
server端一般由phpcli來(lái)執(zhí)行，常駐后臺(tái)，監(jiān)聽(tīng)一個(gè)端口，此例中使用5555，代碼如下：
zmqserver.php
<?php
/*
?* * Hello World server
?* * Binds REP socket to tcp://*:5555
?* * Expects "Hello" from client, replies with "World"
?* * @author Ian Barber <ian(dot)barber(at)gmail(dot)com>
?* */
$context = new ZMQContext(1);
// Socket to talk to clients
$responder = new ZMQSocket($context, ZMQ::SOCKET_REP);
$responder->bind("tcp://*:5555");
while (true) {
? ? $request = $responder->recv();
? ? printf ("Received request: [%s]\n", $request);
? ? logtxt($request);
? ? usleep (100);
? ? $responder->send("World");
}
function logtxt($msg){
? ? $handler = fopen("/tmp/log/zmq.log","a+");
? ? fwrite($handler,date('Y-m-d H:i:s').' ? ?'.$msg."\r\n");
? ? fclose($handler);
}
當(dāng)我執(zhí)行
#php zmqserver.php
的時(shí)候，報(bào)錯(cuò)，找不到"ZMQContext"的類
使用
#php -m
查看加載的類，發(fā)現(xiàn)木有，只有一些默認(rèn)的
繼續(xù)使用
#php --ini
發(fā)現(xiàn)加載INI的路徑并不是/etc/php.ini
于是cp /etc/php.ini /usr/local/php/lib/php.ini
再次執(zhí)行
#php zmqserver.php
ok
查看一下5555端口是否被監(jiān)聽(tīng)：
#lsof -i:5555
在我的機(jī)器上出現(xiàn)了
COMMAND ? PID USER ? FD ? TYPE DEVICE SIZE/OFF NODE NAME
php ? ? 35145 root ? ?9u ?IPv4 272314 ? ? ?0t0 ?TCP *:personal-agent (LISTEN)
表明監(jiān)聽(tīng)成功.
下面編寫(xiě)client端
zmqclient.php
<?php
/*
?* * Hello World client
?* * Connects REQ socket to tcp://localhost:5555
?* * Sends "Hello" to server, expects "World" back
?* * @author Ian Barber <ian(dot)barber(at)gmail(dot)com>
?* */
$context = new ZMQContext();
// Socket to talk to server
echo "Connecting to hello world server…\n";
$requester = new ZMQSocket($context, ZMQ::SOCKET_REQ);
$requester->connect("tcp://localhost:5555");
$date = mktime();
if($requester->send($date) !== false){
? ? echo "send success\n";
}
$reply = $requester->recv();
printf ("Received:[%s]\n",$reply);
從瀏覽器訪問(wèn)zmqclient.php
可以正確接收到World的數(shù)據(jù)，同時(shí)在/tmp/log/zmq.log下面有新生成的日志文件
表明一切正常。
PS：
此例中使用了簡(jiǎn)單的：rep/req的請(qǐng)求應(yīng)答模式，其實(shí)zmq支持的模式非常多，使用的場(chǎng)景也不盡相同，可以根據(jù)自己的實(shí)際情況靈活的選擇合適的模式。
一些有用的資源：
官網(wǎng):http://zeromq.org/
http://blog.fity.cn/post/382/
http://iyuan.iteye.com/category/148998
轉(zhuǎn)載于:https://blog.51cto.com/skindx/1441658
總結(jié)
以上是生活随笔為你收集整理的php使用zeromq的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： SQL server中的SELECT查询
- 下一篇： 刷题06