程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> 網頁編程 >> PHP編程 >> 關於PHP編程 >> php長連接,奏是這麼簡單

php長連接,奏是這麼簡單

編輯:關於PHP編程

php長連接,奏是這麼簡單


說到長鏈接大家肯定不陌生,就是復用一個鏈接持續不斷的進行數據交互,它不像那些一夜情似的服務,需要頻繁的打開和關閉鏈接,效率低的同時還增加了業務的復雜度。在裆下很多互聯網業務場景都需要長連接的支持,比如:游戲、聊天、信息推送等等等,今天我們就一步一步來揭秘php長連接的玩法。我相信任何一項技術的實施都是因為業務場景的需要,所以這次我們還拿聊天室說事兒。

0x00 初試牛刀

記得以前用php寫聊天室還是用polling的方式,毫無疑問,一提到polling,肯定會有人說long polling,沒錯!long polling也很不錯,但在nginx+fpm上面玩這個多少有些費勁,畢竟一個請求需要占一個php進程(就算是用apache+php_mod,也需要一個請求一個線程),所以要是幾個人隨便玩玩還行,一旦放到線上人多起來,這基本就廢了。所以還是采用polling的方式,這樣不會阻塞進程,並且一個請求能立即得到響應,但是帶來的新問題是需要不停的向服務器發送請求,而且隨著間隔的時間越大導致消息延遲就越大。

0x01 華麗變身

在經歷了上面那種一秒一小卡,三秒一大卡的場面!再也看不下去了,於是決定變身為真正的男人,哦不對,應該是真正的長連接。去他媽的polling, 去他媽的long polling,去他媽的webserver,統統靠邊站,讓flash socket(或者說websocket)來統治這個世界!開始了真正意義上的長連接之旅。要玩長連接總是少不了跟socket打交道吧,作為世界上最好的語言(沒有之一),socket的封裝自然是少不了滴。抄起socket_***就開干,於是就有了下面這一托代碼,長連接是吧?延遲是吧?socket是吧?湯藥費是吧?so easy....

  1. $sfd = socket_create(AF_INET, SOCK_STREAM, 0); 
  2.  
  3. socket_bind($sfd, "0.0.0.0", 1234); 
  4.  
  5. socket_listen($sfd, 511); 
  6.  
  7. socket_set_option($sfd, SOL_SOCKET, SO_REUSEADDR, 1); 
  8.  
  9. socket_set_nonblock($sfd); 
  10.  
  11. $rfds = array($sfd); 
  12.  
  13. $wfds = array(); 
  14.  
  15. do{ 
  16.  
  17.     $rs = $rfds; 
  18.  
  19.     $ws = $wfds; 
  20.  
  21.     $es = array(); 
  22.  
  23.     $ret = socket_select($rs, $ws, $es, 3); 
  24.  
  25.      
  26.  
  27.     //read event 
  28.  
  29.     foreach($rs as $fd){ 
  30.  
  31.         if($fd == $sfd){ 
  32.  
  33.             $cfd = socket_accept($sfd); 
  34.  
  35.             socket_set_nonblock($cfd); 
  36.  
  37.             $rfds[] = $cfd; 
  38.  
  39.             echo "new client coming, fd=$cfd\n"; 
  40.  
  41.         }else{ 
  42.  
  43.             $msg = socket_read($fd, 1024); 
  44.  
  45.             if($msg <= 0){ 
  46.  
  47.                 //close 
  48.  
  49.             }else{ 
  50.  
  51.                 //recv msg 
  52.  
  53.                 echo "on message, fd=$fd data=$msg\n"; 
  54.  
  55.             } 
  56.  
  57.         } 
  58.  
  59.     } 
  60.  
  61.      
  62.  
  63.     //write event 
  64.  
  65.     foreach($ws as $fd){ 
  66.  
  67.         socket_write($fd, ........); 
  68.  
  69.     } 
  70.  
  71.      
  72.  
  73. }while(true); 

0x02 登峰造極

從玩socket的那天起,google就輕言細語的跟我說,高並發下的select不要用啊,效率底啊,win要用iocp啊, linux要用epoll啊,blablablabla...哦!好吧,既然google都這麼說了,我也不能跟他老人家較真不是,又一次決定(為什麼要說又呢?)要聽google話,把epoll搞起來,可總不能自己寫啊?像我這麼懶的人還是整個擴展好了,libevent走你!經過瘋狂的編(co)碼(py),神作終於出山,具體能有多高效,能撐多少並發,不造,反正沒用select了,我奏是屌!

  1. $sfd = stream_socket_server ('tcp://0.0.0.0:1234', $errno, $errstr); 
  2.  
  3. stream_set_blocking($sfd, 0); 
  4.  
  5. $base = event_base_new(); 
  6.  
  7. $event = event_new(); 
  8.  
  9. event_set($event, $sfd, EV_READ | EV_PERSIST, 'ev_accept', $base); 
  10.  
  11. event_base_set($event, $base); 
  12.  
  13. event_add($event); 
  14.  
  15. event_base_loop($base); 
  16.  
  17. function ev_accept($socket, $flag, $base) 
  18.  
  19.  
  20.     $connection = stream_socket_accept($socket); 
  21.  
  22.     stream_set_blocking($connection, 0); 
  23.  
  24.     $buffer = event_buffer_new($connection, 'ev_read', NULL, 'ev_error',  $connection);     
  25.  
  26.     event_buffer_base_set($buffer, $base); 
  27.  
  28.     event_buffer_timeout_set($buffer, 30, 30); 
  29.  
  30.     event_buffer_watermark_set($buffer, EV_READ, 0, 0xffffff); 
  31.  
  32.     event_buffer_priority_set($buffer, 10); 
  33.  
  34.     event_buffer_enable($buffer, EV_READ | EV_PERSIST); 
  35.  
  36.  
  37. function ev_error($buffer, $error, $connection) 
  38.  
  39.  
  40.     event_buffer_disable($buffer, EV_READ | EV_WRITE);                 
  41.  
  42.     event_buffer_free($buffer);                 
  43.  
  44.     fclose($connection);                 
  45.  
  46.  
  47. function ev_read($buffer, $connection) 
  48.  
  49.  
  50.     $read = event_buffer_read($buffer, 256); 
  51.  
  52.     //do something.... 
  53.  

0x03 絕處逢生

隨著人數的增長,並發的提升,單個進程已經滿足不了需求了,田伯光的故事告訴我們,單挑是斗不過群P的,咋整?俗話說,大事化小,小事化,停!!別化了,再化就沒了。拆吧,把單進程拆成多進程,可是拆完之後又面臨新的問題,進程間通信、負載均衡、session唯一等。既然已經提出這樣的問題,肯定是有解決方案,現成的就有擴展和庫來解決這個事,比如:swoole,workerman等?相比之下swoole更屌一些,性、功能,呃!好像這樣簡寫不太雅觀,好吧,性能和功能更屌一些(桶哥,請原諒我的無聊~)。。。。等一下!!!但是,我們在使用php來開發web的時候,也沒有使用webserver相關的庫來做開發對不對?咱只是簡單的echo而已。這些繁雜的事都交給了nginx或者是apache,是他們義無反顧的頂在前面,讓我們可以專心寫邏輯。寫web我們只需要簡單的配置nginx和fpm就好了,那寫socket服務呢?我們為什麼不能像nginx+fpm一樣簡單配置就好了呢??當然能,必須能。。。。。看這個劇情怕是廣告要來了。。。

0x04 出其不意

寫socket服務不比寫web高級,都是打碼,都是完成需求,通信那層都是固定的,只不過一個由nginx完成,另一個由自己完成。。可是現在不需要自己完成了,類似nginx+fpm的方案,fooking+fpm=php長連接,gateway用於承載連接,router用於轉發消息,進程間通信?負載均衡?session唯一?so easy..

  1. $sid = $_SERVER['SESSIONID'];//這是sessionid 
  2.  
  3. $data = file_get_contents("php://input");//這樣就能拿到請求內容了 
  4.  
  5. //想要返回消息只需要兩步 
  6.  
  7. header('Content-Length: 11');//返回給客戶端字節數 
  8.  
  9. echo "hello world"; 
  10.  
  11. //想要給別的用戶發消息 
  12.  
  13. include 'api.php'; 
  14.  
  15. $router = new RouterClient('router host', 'router port'); 
  16.  
  17. $router->sendMsg(用戶sessionid, "fuck you"); 
  18.  
  19. //想要給所有人要消息 
  20.  
  21. $router->sendAllMsg("fuck all"); 
  22.  
  23. //想給指定組發消息(類似redis的pub/sub) 
  24.  
  25. $router->publish("channel name", "fuck all"); 

項目地址: http://git.oschina.net/scgywx/fooking

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

php長連接

 



  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved