先扯些這些內容: TCP/IP TCP/IP是個協議組,可分為三個層次:網路層、傳輸層和應用層。 在網路層有IP協議、ICMP協議、ARP協議、RARP協議和BOOTP協議。 在傳輸層中有TCP協議與UDP協議。 在應用層有: TCP包括FTP、HTTP、TELNET、SMTP等協議 UDP包括DN ...
先扯些這些內容:
TCP/IP
TCP/IP是個協議組,可分為三個層次:網路層、傳輸層和應用層。
在網路層有IP協議、ICMP協議、ARP協議、RARP協議和BOOTP協議。
在傳輸層中有TCP協議與UDP協議。
在應用層有:
TCP包括FTP、HTTP、TELNET、SMTP等協議
UDP包括DNS、TFTP等協議
短連接
連接->傳輸數據->關閉連接
HTTP是無狀態的,瀏覽器和伺服器每進行一次HTTP操作,就建立一次連接,但任務結束就中斷連接。
也可以這樣說:短連接是指SOCKET連接後發送後接收完數據後馬上斷開連接。
長連接
連接->傳輸數據->保持連接 -> 傳輸數據-> 。。。 ->關閉連接。
長連接指建立SOCKET連接後不管是否使用都保持連接,但安全性較差。
http的長連接
HTTP也可以建立長連接的,使用Connection:keep-alive,HTTP 1.1預設進行持久連接。HTTP1.1和HTTP1.0相比較而言,最大的區別就是增加了持久連接支持(貌似最新的 http1.0 可以顯示的指定 keep-alive),但還是無狀態的,或者說是不可以信任的。
什麼時候用長連接,短連接?
長連接多用於操作頻繁,點對點的通訊,而且連接數不能太多情況,。每個TCP連接都需要三步握手,這需要時間,如果每個操作都是先連接,再操作的話那麼處理速度會降低很多,所以每個操作完後都不斷開,次處理時直接發送數據包就OK了,不用建立TCP連接。例如:資料庫的連接用長連接, 如果用短連接頻繁的通信會造成socket錯誤,而且頻繁的socket 創建也是對資源的浪費。
而像WEB網站的http服務一般都用短鏈接,因為長連接對於服務端來說會耗費一定的資源,而像WEB網站這麼頻繁的成千上萬甚至上億客戶端的連接用短連接會更省一些資源,如果用長連接,而且同時有成千上萬的用戶,如果每個用戶都占用一個連接的話,那可想而知吧。所以併發量大,但每個用戶無需頻繁操作情況下需用短連好。
Workerman是一款純PHP開發的開源高性能的PHP socket 伺服器框架。被廣泛的用於手機app、移動通訊,微信小程式,手游服務端、網路游戲、PHP聊天室、硬體通訊、智能家居、車聯網、物聯網等領域的開發。 支持TCP長連接,支持Websocket、HTTP等協議,支持自定義協議。擁有非同步Mysql、非同步Redis、非同步Http、非同步消息隊列等眾多高性能組件。
開始步入正題:為了達到實時通訊,很多時候我們採用了ajax輪詢機制,如圖:
後面可以採用workerman方式來實現,項目也是tp寫的,官方手冊這麼說到
與其它mvc框架結合建議以上圖的方式(ThinkPHP為例):
1、ThinkPHP與Workerman是兩個獨立的系統,獨立部署(可部署在不同伺服器),互不幹擾。
2、ThinkPHP以HTTP協議提供網頁頁面在瀏覽器渲染展示。
3、ThinkPHP提供的頁面的js發起websocket連接,連接workerman
4、連接後給Workerman發送一個數據包(包含用戶名密碼或者某種token串)用於驗證websocket連接屬於哪個用戶。
5、僅在ThinkPHP需要向瀏覽器推送數據時,才調用workerman的socket介面推送數據。
6、其餘請求還是按照原本ThinkPHP的HTTP方式調用處理。
總結:
把Workerman作為一個可以向瀏覽器推送的通道,僅僅在需要向瀏覽器推送數據時才調用Workerman介面完成推送。業務邏輯全部在ThinkPHP中完成。
ok,到這裡,把workerman容器跑起來,註意這裡是CLI模式運行
然後再我們項目接收信息中這麼玩,附上代碼
<script> // 連接服務端 var socket = io('http://127.0.0.1:2120'); // uid可以是自己網站的用戶id,以便針對uid推送 uid = 123; // socket連接後以uid登錄 socket.on('connect', function(){ socket.emit('login', uid); }); // 後端推送來消息時 socket.on('new_msg', function(msg){ console.log("收到消息:"+msg); //自己業務邏輯處理 }); </script>
接著,我們在用戶向用戶發送信息的時候添加
// 指明給誰推送,為空表示向所有線上用戶推送 $to_uid = "123"; // 推送的url地址 $push_api_url = "http://127.0.0.1:2121/"; $post_data = array( "type" => "publish", "content" => "數據", "to" => $to_uid, ); $ch = curl_init (); curl_setopt ( $ch, CURLOPT_URL, $push_api_url ); curl_setopt ( $ch, CURLOPT_POST, 1 ); curl_setopt ( $ch, CURLOPT_HEADER, 0 ); curl_setopt ( $ch, CURLOPT_RETURNTRANSFER, 1 ); curl_setopt ( $ch, CURLOPT_POSTFIELDS, $post_data ); curl_setopt ($ch, CURLOPT_HTTPHEADER, array("Expect:")); $return = curl_exec ( $ch ); curl_close ( $ch ); var_export($return);
其中,workerman裡面的推送核心代碼實現
// 全局數組保存uid線上數據 $uidConnectionMap = array(); // 記錄最後一次廣播的線上用戶數 $last_online_count = 0; // PHPSocketIO服務 $sender_io = new SocketIO(2120); // 客戶端發起連接事件時,設置連接socket的各種事件回調 // 當$sender_io啟動後監聽一個http埠,通過這個埠可以給任意uid或者所有uid推送數據 $sender_io->on('workerStart', function(){ // 監聽一個http埠 $inner_http_worker = new Worker('http://0.0.0.0:2121'); // 當http客戶端發來數據時觸發 $inner_http_worker->onMessage = function($http_connection, $data){ global $uidConnectionMap; $_POST = $_POST ? $_POST : $_GET; // 推送數據的url格式 type=publish&to=uid&content=xxxx switch(@$_POST['type']){ case 'publish': global $sender_io; $to = @$_POST['to']; $_POST['content'] = htmlspecialchars(@$_POST['content']); // 有指定uid則向uid所在socket組發送數據 if($to){ $sender_io->to($to)->emit('new_msg', $_POST['content']); // 否則向所有uid推送數據 }else{ $sender_io->emit('new_msg', @$_POST['content']); } // http介面返回,如果用戶離線socket返回fail if($to && !isset($uidConnectionMap[$to])){ return $http_connection->send('offline'); }else{ return $http_connection->send('ok'); } } return $http_connection->send('fail'); }; }); if(!defined('GLOBAL_START')) { Worker::runAll(); }
ok,大功告成!
更多學習內容請訪問:
騰訊T3-T4標準精品PHP架構師教程目錄大全,只要你看完保證薪資上升一個臺階(持續更新)