長連線是什麼？
朋友應該都看過很多線上聊天工具和網頁線上聊天的工具。學校內有一種熟悉的功能，如果有人回覆你了，網站會馬上出現提示，此時你並沒有刷新頁面；Gmail也有此功能，如果郵箱裡收到了新的郵件，網站會馬上提醒你，即使你的網頁一直未刷新過。說到這裡大家肯定不陌生，就是複用一個連結持續不斷的進行資料互動。在現下許多網路商業場景都需要長連線的支持，例如：遊戲、聊天、資訊推送等等等，這麼多類似的功能都離不開長連線。前一章節介紹了php socket通訊，本章來介紹一下php socket長連結。
長連線和短連結
短連線一般都是單一請求數據，伺服器不能主動把資料「推」想客戶端，但有了長連線就好多了，利用後端與前端的技術組合起來，可以實現伺服器的“推送資訊”功能，如果資料庫裡面有更新，後端程式可以立即把資料“推送出來”，而不要多次反覆請求，多次建立連接，多次斷開。
其大概有以下的幾種解釋：
所謂長連接指建立SOCKET連接後不管是否使用都保持連接，但安全性較差；所謂短連接指建立SOCKET連接後發送後接收完資料後馬上斷開連接，一般銀行都使用短連接
長連接就是指在基於tcp的通訊中，一直保持連接，不管當前是否發送或接收資料。而短連接就是只有在有資料傳輸的時候才進行連接，客戶－伺服器通訊/傳輸資料完畢就關閉連接。
通訊方式
各網路元件之間共有兩種連接方式：長連接和短連接。所謂長連接，指在一個TCP連接上可以連續發送多個資料包，在TCP連接保持期間，如果沒有資料包發送，需 要雙方發檢測包以維持此連接。短連接是指通信雙方有數據交互時，就建立一個TCP連接，數據發送完成後，則斷開此TCP連接，即每次TCP連接只完成一對 CMPP消息的發送。
現階段，要求ISMG之間必須採用長連結的通訊方式，建議SP與ISMG之間採用長連結的通訊方式。
短連線：例如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");
?>登入後複製
【相關教學推薦】
1. 《php.cn獨孤九賤（4 ）－php影片教學》
2. php程式設計從入門到精通全套教學
#
以上是php socket如何實現長連接的詳細內容。更多資訊請關注PHP中文網其他相關文章！
