首頁  >  文章  >  後端開發  >  php socket如何實現長連接

php socket如何實現長連接

伊谢尔伦
伊谢尔伦原創
2018-05-14 17:13:3825439瀏覽

長連線是什麼?

朋友應該都看過很多線上聊天工具和網頁線上聊天的工具。學校內有一種熟悉的功能,如果有人回覆你了,網站會馬上出現提示,此時你並沒有刷新頁面;Gmail也有此功能,如果郵箱裡收到了新的郵件,網站會馬上提醒你,即使你的網頁一直未刷新過。說到這裡大家肯定不陌生,就是複用一個連結持續不斷的進行資料互動。在現下許多網路商業場景都需要長連線的支持,例如:遊戲、聊天、資訊推送等等等,這麼多類似的功能都離不開長連線。前一章節介紹了php socket通訊,本章來介紹一下php socket長連結。

長連線和短連結

短連線一般都是單一請求數據,伺服器不能主動把資料「推」想客戶端,但有了長連線就好多了,利用後端與前端的技術組合起來,可以實現伺服器的“推送資訊”功能,如果資料庫裡面有更新,後端程式可以立即把資料“推送出來”,而不要多次反覆請求,多次建立連接,多次斷開。

其大概有以下的幾種解釋:

  1.  所謂長連接指建立SOCKET連接後不管是否使用都保持連接,但安全性較差;所謂短連接指建立SOCKET連接後發送後接收完資料後馬上斷開連接,一般銀行都使用短連接

  2. 長連接就是指在基於tcp的通訊中,一直保持連接,不管當前是否發送或接收資料。而短連接就是只有在有資料傳輸的時候才進行連接,客戶-伺服器通訊/傳輸資料完畢就關閉連接。

  3. 通訊方式   
    各網路元件之間共有兩種連接方式:長連接和短連接。所謂長連接,指在一個TCP連接上可以連續發送多個資料包,在TCP連接保持期間,如果沒有資料包發送,需 要雙方發檢測包以維持此連接。短連接是指通信雙方有數據交互時,就建立一個TCP連接,數據發送完成後,則斷開此TCP連接,即每次TCP連接只完成一對 CMPP消息的發送。   
    現階段,要求ISMG之間必須採用長連結的通訊方式,建議SP與ISMG之間採用長連結的通訊方式。

  4. 短連線:例如http的,只是連線、請求、關閉,過程時間較短,伺服器若是一段時間內沒有收到請求即可關閉連線。長連線:有些服務需要長時間連接到伺服器,例如CMPP,一般需要自己做線上維持。

實作socket長連線

 每次我們造訪PHP腳本的時候,都是當所有的PHP腳本執行完成後,我們才得到回傳結果。如果我們需要一個腳本持續的運行,那麼我們就要透過php長連接的方式,來達到運行目的。

想要玩長連接就需要跟socket打交道,socket的封裝自然是少不的了。下面就透過程式碼來進行socket長連線。

其實例程式碼如下:

<?php
$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);        
    //读取事件 
    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{                 
                echo "on message, fd=$fd data=$msg\n";  
            }  
        }  
    } 
  
    //写入事件 
    foreach($ws as $fd){  
        socket_write($fd, ........);  
    }       
}while(true);
?>

下面來提高下效率:

<?php
$sfd = stream_socket_server (&#39;tcp://0.0.0.0:1234&#39;, $errno, $errstr);  
stream_set_blocking($sfd, 0);  
$base = event_base_new();  
$event = event_new();  
event_set($event, $sfd, EV_READ | EV_PERSIST, &#39;ev_accept&#39;, $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, &#39;ev_read&#39;, NULL, &#39;ev_error&#39;,  $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....  
}
?>

隨著人數的成長,並發的提升,單一進程已經滿足不了需求了,現成的就有擴展和函式庫來解決這個事,比如:swoole,workerman等?但是,我們在使用php來開發web的時候,也沒有使用webserver相關的函式庫來做開發對不對?咱只是簡單的echo而已。這些繁雜的事都交給了nginx或是apache,是他們義無反顧的頂在前面,讓我們可以專心寫邏輯。寫socket服務不比寫web高級,都是打碼,都是完成需求,通信那層都是固定的,只不過一個由nginx完成,另一個由自己完成。 。可是現在不需要自己完成了,類似nginx+fpm的方案,fooking+fpm=php長連接,gateway用來承載連接,router用來轉送訊息。

其程式碼如下:

<?php
$sid = $_SERVER[&#39;SESSIONID&#39;];//这是sessionid  
$data = file_get_contents("php://input");//这样就能拿到请求内容了  
//想要返回消息只需要两步  
header(&#39;Content-Length: 11&#39;);//返回给客户端字节数  
echo "hello world";  
//想要给别的用户发消息  
include &#39;api.php&#39;;  
$router = new RouterClient(&#39;router host&#39;, &#39;router port&#39;);  
$router->sendMsg(用户sessionid, "fuck you");  
//想要给所有人要消息  
$router->sendAllMsg("fuck all");  
//想给指定组发消息(类似redis的pub/sub)  
$router->publish("channel name", "fuck all");
?>

【相關教學推薦】

1. 《php.cn獨孤九賤(4 )-php影片教學

2.   php程式設計從入門到精通全套教學

#

以上是php socket如何實現長連接的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn