php socket如何實現長鏈接

時間 2019-11-20

標籤 php socket 如何實現鏈接欄目 PHP 简体版

原文原文鏈接

長鏈接是什麼？php

朋友們應該都見過不少在線聊天工具和網頁在線聊天的工具。學校內有一種熟悉的功能，若是有人回覆你了，網站會立刻出現提示，此時你並無刷新頁面；Gmail也有此功能，若是郵箱裏收到了新的郵件，網站會立刻提醒你，即便你的網頁一直未刷新過。說到這裏你們確定不陌生，就是複用一個連接持續不斷的進行數據交互。在現下不少互聯網業務場景都須要長鏈接的支持，好比：遊戲、聊天、信息推送等等等，這麼多相似的功能都離不開長鏈接。前一章節介紹了php socket通訊，本章來介紹一下php socket長鏈接。html

長鏈接和短連接前端

短鏈接通常都是單項請求數據，服務器不能主動把數據「推」想客戶端，但有了長鏈接就好多了，利用後端與前端的技術組合起來，能夠實現服務器的「推送信息」功能，若是數據庫裏面有更新，後端程序能夠當即把數據「推送出來」，而不要屢次反覆請求，屢次創建鏈接，屢次斷開。nginx

其大概有以下的幾種解釋：web

所謂長鏈接指創建SOCKET鏈接後不論是否使用都保持鏈接，但安全性較差；所謂短鏈接指創建SOCKET鏈接後發送後接收完數據後立刻斷開鏈接，通常銀行都使用短鏈接redis
長鏈接就是指在基於tcp的通信中，一直保持鏈接，無論當前是否發送或者接收數據。而短鏈接就是隻有在有數據傳輸的時候才進行鏈接，客戶－服務器通訊/傳輸數據完畢就關閉鏈接。數據庫
通訊方式
各網元之間共有兩種鏈接方式：長鏈接和短鏈接。所謂長鏈接，指在一個TCP鏈接上能夠連續發送多個數據包，在TCP鏈接保持期間，若是沒有數據包發送，需要雙方發檢測包以維持此鏈接。短鏈接是指通訊雙方有數據交互時，就創建一個TCP鏈接，數據發送完成後，則斷開此TCP鏈接，即每次TCP鏈接只完成一對 CMPP消息的發送。
現階段，要求ISMG之間必須採用長鏈接的通訊方式，建議SP與ISMG之間採用長鏈接的通訊方式。apache
短鏈接：好比http的，只是鏈接、請求、關閉，過程時間較短,服務器如果一段時間內沒有收到請求便可關閉鏈接。長鏈接：有些服務須要長時間鏈接到服務器，好比CMPP，通常須要本身作在線維持。後端

實現socket長鏈接api

每次咱們訪問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");
?>

相關標籤/搜索

每日一句

每一个你不满意的现在，都有一个你没有努力的曾经。