php socket怎么實現長連接

小編給大家分享一下php socket怎么實現長連接，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

長連接是什么？

朋友們應該都見過很多在線聊天工具和網頁在線聊天的工具。學校內有一種熟悉的功能，如果有人回復你了，網站會馬上出現提示，此時你并沒有刷新頁面；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 ('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....  

}

?>

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

其代碼如下所示：

<?php

$sid = $_SERVER['SESSIONID'];//這是sessionid  

$data = file_get_contents("php://input");//這樣就能拿到請求內容了  

//想要返回消息只需要兩步  

header('Content-Length: 11');//返回給客戶端字節數  

echo "hello world";  

//想要給別的用戶發消息  

include 'api.php';  

$router = new RouterClient('router host', 'router port');  

$router->sendMsg(用戶sessionid, "fuck you");  

//想要給所有人要消息  

$router->sendAllMsg("fuck all");  

//想給指定組發消息(類似redis的pub/sub)  

$router->publish("channel name", "fuck all");

?>

以上是“php socket怎么實現長連接”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注億速云行業資訊頻道！