說(shuō)到長(zhǎng)鏈接大家肯定不陌生，就是復(fù)用一個(gè)鏈接持續(xù)不斷的進(jìn)行數(shù)據(jù)交互，它不像那些一夜情似的服務(wù)，需要頻繁的打開(kāi)和關(guān)閉鏈接，效率低的同時(shí)還增加了業(yè)務(wù)的復(fù)雜度。在襠下很多互聯(lián)網(wǎng)業(yè)務(wù)場(chǎng)景都需要長(zhǎng)連接的支持，比如：游戲、聊天、信息推送等等等，今天我們就一步一步來(lái)揭秘php長(zhǎng)連接的玩法。我相信任何一項(xiàng)技術(shù)的實(shí)施都是因?yàn)闃I(yè)務(wù)場(chǎng)景的需要，所以這次我們還拿聊天室說(shuō)事兒。

0x00 初試牛刀

記得以前用php寫聊天室還是用polling的方式，毫無(wú)疑問(wèn)，一提到polling,肯定會(huì)有人說(shuō)long polling，沒(méi)錯(cuò)！long polling也很不錯(cuò)，但在nginx+fpm上面玩這個(gè)多少有些費(fèi)勁，畢竟一個(gè)請(qǐng)求需要占一個(gè)php進(jìn)程(就算是用apache+php_mod，也需要一個(gè)請(qǐng)求一個(gè)線程)，所以要是幾個(gè)人隨便玩玩還行，一旦放到線上人多起來(lái)，這基本就廢了。所以還是采用polling的方式，這樣不會(huì)阻塞進(jìn)程，并且一個(gè)請(qǐng)求能立即得到響應(yīng)，但是帶來(lái)的新問(wèn)題是需要不停的向服務(wù)器發(fā)送請(qǐng)求，而且隨著間隔的時(shí)間越大導(dǎo)致消息延遲就越大。

0x01 華麗變身

在經(jīng)歷了上面那種一秒一小卡，三秒一大卡的場(chǎng)面！再也看不下去了，于是決定變身為真正的男人，哦不對(duì)，應(yīng)該是真正的長(zhǎng)連接。去他媽的polling, 去他媽的long polling,去他媽的webserver，統(tǒng)統(tǒng)靠邊站，讓flash socket(或者說(shuō)websocket)來(lái)統(tǒng)治這個(gè)世界！開(kāi)始了真正意義上的長(zhǎng)連接之旅。要玩長(zhǎng)連接總是少不了跟socket打交道吧，作為世界上最好的語(yǔ)言(沒(méi)有之一)，socket的封裝自然是少不了滴。抄起socket_***就開(kāi)干，于是就有了下面這一托代碼，長(zhǎng)連接是吧？延遲是吧？socket是吧？湯藥費(fèi)是吧？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就輕言細(xì)語(yǔ)的跟我說(shuō)，高并發(fā)下的select不要用啊，效率底啊，win要用iocp啊, linux要用epoll啊，blablablabla...哦！好吧，既然google都這么說(shuō)了，我也不能跟他老人家較真不是，又一次決定(為什么要說(shuō)又呢？)要聽(tīng)google話，把epoll搞起來(lái)，可總不能自己寫啊？像我這么懶的人還是整個(gè)擴(kuò)展好了，libevent走你！經(jīng)過(guò)瘋狂的編(co)碼(py)，神作終于出山，具體能有多高效，能撐多少并發(fā)，不造，反正沒(méi)用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ù)的增長(zhǎng)，并發(fā)的提升，單個(gè)進(jìn)程已經(jīng)滿足不了需求了，田伯光的故事告訴我們，單挑是斗不過(guò)群P的，咋整？俗話說(shuō)，大事化小，小事化，停！！別化了，再化就沒(méi)了。拆吧，把單進(jìn)程拆成多進(jìn)程，可是拆完之后又面臨新的問(wèn)題，進(jìn)程間通信、負(fù)載均衡、session唯一等。既然已經(jīng)提出這樣的問(wèn)題，肯定是有解決方案，現(xiàn)成的就有擴(kuò)展和庫(kù)來(lái)解決這個(gè)事，比如：swoole,workerman等？相比之下swoole更屌一些，性、功能，呃！好像這樣簡(jiǎn)寫不太雅觀，好吧，性能和功能更屌一些(桶哥，請(qǐng)?jiān)徫业臒o(wú)聊~)。。。。等一下！！！但是，我們?cè)谑褂胮hp來(lái)開(kāi)發(fā)web的時(shí)候，也沒(méi)有使用webserver相關(guān)的庫(kù)來(lái)做開(kāi)發(fā)對(duì)不對(duì)？咱只是簡(jiǎn)單的echo而已。這些繁雜的事都交給了nginx或者是apache，是他們義無(wú)反顧的頂在前面，讓我們可以專心寫邏輯。寫web我們只需要簡(jiǎn)單的配置nginx和fpm就好了，那寫socket服務(wù)呢？我們?yōu)槭裁床荒芟駈ginx+fpm一樣簡(jiǎn)單配置就好了呢？？當(dāng)然能，必須能。。。。。看這個(gè)劇情怕是廣告要來(lái)了。。。

0x04 出其不意

寫socket服務(wù)不比寫web高級(jí)，都是打碼，都是完成需求，通信那層都是固定的，只不過(guò)一個(gè)由nginx完成，另一個(gè)由自己完成。。可是現(xiàn)在不需要自己完成了，類似nginx+fpm的方案，fooking+fpm=php長(zhǎng)連接，gateway用于承載連接，router用于轉(zhuǎn)發(fā)消息，進(jìn)程間通信？負(fù)載均衡？session唯一？so easy..

$sid = $_SERVER['SESSIONID'];//這是sessionid 
 
$data = file_get_contents("php://input");//這樣就能拿到請(qǐng)求內(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"); 

項(xiàng)目地址: http://git.oschina.net/scgywx/fooking

文檔地址(不定期更新)：http://my.oschina.net/scgywx/blog/465186