建站
咨詢
售后
建站咨詢
新聞中心
說到長鏈接大家肯定不陌生，就是復(fù)用一個鏈接持續(xù)不斷的進行數(shù)據(jù)交互，它不像那些一夜情似的服務(wù)，需要頻繁的打開和關(guān)閉鏈接，效率低的同時還增加了業(yè)務(wù)的復(fù)雜度。在襠下很多互聯(lián)網(wǎng)業(yè)務(wù)場景都需要長連接的支持，比如：游戲、聊天、信息推送等等等，今天我們就一步一步來揭秘php長連接的玩法。我相信任何一項技術(shù)的實施都是因為業(yè)務(wù)場景的需要，所以這次我們還拿聊天室說事兒。
創(chuàng)新互聯(lián)建站專業(yè)為企業(yè)提供勐臘網(wǎng)站建設(shè)、勐臘做網(wǎng)站、勐臘網(wǎng)站設(shè)計、勐臘網(wǎng)站制作等企業(yè)網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計與制作、勐臘企業(yè)網(wǎng)站模板建站服務(wù)，10年勐臘做網(wǎng)站經(jīng)驗，不只是建網(wǎng)站，更提供有價值的思路和整體網(wǎng)絡(luò)服務(wù)。
0x00 初試牛刀
記得以前用php寫聊天室還是用polling的方式，毫無疑問，一提到polling,肯定會有人說long polling，沒錯！long polling也很不錯，但在nginx+fpm上面玩這個多少有些費勁，畢竟一個請求需要占一個php進程(就算是用apache+php_mod，也需要一個請求一個線程)，所以要是幾個人隨便玩玩還行，一旦放到線上人多起來，這基本就廢了。所以還是采用polling的方式，這樣不會阻塞進程，并且一個請求能立即得到響應(yīng)，但是帶來的新問題是需要不停的向服務(wù)器發(fā)送請求，而且隨著間隔的時間越大導(dǎo)致消息延遲就越大。
0x01 華麗變身
在經(jīng)歷了上面那種一秒一小卡，三秒一大卡的場面！再也看不下去了，于是決定變身為真正的男人，哦不對，應(yīng)該是真正的長連接。去他媽的polling, 去他媽的long polling,去他媽的webserver，統(tǒng)統(tǒng)靠邊站，讓flash socket(或者說websocket)來統(tǒng)治這個世界！開始了真正意義上的長連接之旅。要玩長連接總是少不了跟socket打交道吧，作為世界上最好的語言(沒有之一)，socket的封裝自然是少不了滴。抄起socket_***就開干，于是就有了下面這一托代碼，長連接是吧？延遲是吧？socket是吧？湯藥費是吧？so easy....
- $sfd = socket_create(AF_INET, SOCK_STREAM, 0);
- socket_bind($sfd, "0.0.0.0", 1234);
- socket_listen($sfd, 511);
- socket_set_option($sfd, SOL_SOCKET, SO_REUSEADDR, 1);
- socket_set_nonblock($sfd);
- $rfds = array($sfd);
- $wfds = array();
- do{
- $rs = $rfds;
- $ws = $wfds;
- $es = array();
- $ret = socket_select($rs, $ws, $es, 3);
- //read event
- foreach($rs as $fd){
- if($fd == $sfd){
- $cfd = socket_accept($sfd);
- socket_set_nonblock($cfd);
- $rfds[] = $cfd;
- echo "new client coming, fd=$cfd\n";
- }else{
- $msg = socket_read($fd, 1024);
- if($msg <= 0){
- //close
- }else{
- //recv msg
- echo "on message, fd=$fd data=$msg\n";
- }
- }
- }
- //write event
- foreach($ws as $fd){
- socket_write($fd, ........);
- }
- }while(true);
0x02 登峰造極
從玩socket的那天起，google就輕言細語的跟我說，高并發(fā)下的select不要用啊，效率底啊，win要用iocp啊, linux要用epoll啊，blablablabla...哦！好吧，既然google都這么說了，我也不能跟他老人家較真不是，又一次決定(為什么要說又呢？)要聽google話，把epoll搞起來，可總不能自己寫?。肯裎疫@么懶的人還是整個擴展好了，libevent走你！經(jīng)過瘋狂的編(co)碼(py)，神作終于出山，具體能有多高效，能撐多少并發(fā)，不造，反正沒用select了，我奏是屌！
- $sfd = stream_socket_server ('tcp://0.0.0.0:1234', $errno, $errstr);
- stream_set_blocking($sfd, 0);
- $base = event_base_new();
- $event = event_new();
- event_set($event, $sfd, EV_READ | EV_PERSIST, 'ev_accept', $base);
- event_base_set($event, $base);
- event_add($event);
- event_base_loop($base);
- function ev_accept($socket, $flag, $base)
- {
- $connection = stream_socket_accept($socket);
- stream_set_blocking($connection, 0);
- $buffer = event_buffer_new($connection, 'ev_read', NULL, 'ev_error', $connection);
- event_buffer_base_set($buffer, $base);
- event_buffer_timeout_set($buffer, 30, 30);
- event_buffer_watermark_set($buffer, EV_READ, 0, 0xffffff);
- event_buffer_priority_set($buffer, 10);
- event_buffer_enable($buffer, EV_READ | EV_PERSIST);
- }
- function ev_error($buffer, $error, $connection)
- {
- event_buffer_disable($buffer, EV_READ | EV_WRITE);
- event_buffer_free($buffer);
- fclose($connection);
- }
- function ev_read($buffer, $connection)
- {
- $read = event_buffer_read($buffer, 256);
- //do something....
- }
0x03 絕處逢生
隨著人數(shù)的增長，并發(fā)的提升，單個進程已經(jīng)滿足不了需求了，田伯光的故事告訴我們，單挑是斗不過群P的，咋整？俗話說，大事化小，小事化，停！！別化了，再化就沒了。拆吧，把單進程拆成多進程，可是拆完之后又面臨新的問題，進程間通信、負載均衡、session唯一等。既然已經(jīng)提出這樣的問題，肯定是有解決方案，現(xiàn)成的就有擴展和庫來解決這個事，比如：swoole,workerman等？相比之下swoole更屌一些，性、功能，呃！好像這樣簡寫不太雅觀，好吧，性能和功能更屌一些(桶哥，請原諒我的無聊~)。。。。等一下?。?！但是，我們在使用php來開發(fā)web的時候，也沒有使用webserver相關(guān)的庫來做開發(fā)對不對？咱只是簡單的echo而已。這些繁雜的事都交給了nginx或者是apache，是他們義無反顧的頂在前面，讓我們可以專心寫邏輯。寫web我們只需要簡單的配置nginx和fpm就好了，那寫socket服務(wù)呢？我們?yōu)槭裁床荒芟駈ginx+fpm一樣簡單配置就好了呢？？當(dāng)然能，必須能。。。。?？催@個劇情怕是廣告要來了。。。
0x04 出其不意
寫socket服務(wù)不比寫web高級，都是打碼，都是完成需求，通信那層都是固定的，只不過一個由nginx完成，另一個由自己完成。?？墒乾F(xiàn)在不需要自己完成了，類似nginx+fpm的方案，fooking+fpm=php長連接，gateway用于承載連接，router用于轉(zhuǎn)發(fā)消息，進程間通信？負載均衡？session唯一？so easy..
- $sid = $_SERVER['SESSIONID'];//這是sessionid
- $data = file_get_contents("php://input");//這樣就能拿到請求內(nèi)容了
- //想要返回消息只需要兩步
- header('Content-Length: 11');//返回給客戶端字節(jié)數(shù)
- echo "hello world";
- //想要給別的用戶發(fā)消息
- include 'api.php';
- $router = new RouterClient('router host', 'router port');
- $router->sendMsg(用戶sessionid, "fuck you");
- //想要給所有人要消息
- $router->sendAllMsg("fuck all");
- //想給指定組發(fā)消息(類似redis的pub/sub)
- $router->publish("channel name", "fuck all");
項目地址: http://git.oschina.net/scgywx/fooking
文檔地址(不定期更新)：http://my.oschina.net/scgywx/blog/465186
新聞名稱：php長連接，奏是這么簡單
轉(zhuǎn)載來源：http://www.5511xx.com/article/dpeghih.html
