php與websocket
① php如何實現websocket
php有可用的websocket庫，不需要php-fpm。
目前比較成熟的有swoole（swoole.com），和workman（workman.net）
swoole是c寫的php擴展， 效率比nodejs還要高，workman是純php實現，兩者都號稱可以實現並發百萬TCP連接。
給你個例子：
這個要通過cmd運行的具體帶的參數有點忘記了
<?php
error_reporting(E_ALL);
set_time_limit(0);
ob_implicit_flush();
//創建一個socket連接設置參數綁定監聽並且返回
$master=WebSocket("localhost",12345);
//標示是否已經進行過握手了
$is_shaked=false;
//是否已經關閉
$is_closed=true;
//將socket變為一個可用的socket
while(true){
//如果是關閉狀態並且是沒有握手的話則創建一個可用的socket（貌似第二個條件可以去除）
if($is_closed&&!$is_shaked){
if(($sock=socket_accept($master))<0){
echo"socket_accept()failed:reason:".socket_strerror($sock)." ";
}
//將關閉狀態修改為false
$is_closed=false;
}
//開始進行數據處理
process($sock);
}
//處理請求的函數
functionprocess($socket){
//先從獲取到全局變數
global$is_closed,$is_shaked;
//從socket中獲取數據
$buffer=socket_read($socket,2048);
//如果buffer返回值為false並且已經握手的話則斷開連接
if(!$buffer&&$is_shaked){
disconnect($socket);
}else{
//如果沒有握手的話則握手並且修改握手狀態
if($is_shaked==false){
$return_str=dohandshake($buffer);
$is_shaked=true;
}else{
//如果已經握手的話則送入deal函數中進行相應處理
$data_str=decode($buffer);//解析出來的從前端送來的內容
console($data_str);
$return_str=encode(deal($socket,$data_str));
//$return_str=encode($data_str);
}
//將應該返回的字元串寫入socket返回
socket_write($socket,$return_str,strlen($return_str));
}
}
functiondeal($socket,$msgObj){
$obj=json_decode($msgObj);
foreach($objas$key=>$value){
if($key=='close'){
disconnect($socket);
console('closesuccess');
return'closesuccess';
}elseif($key=='msg'){
console($value." ");
return$value;
}
}
}
//獲取頭部信息
functiongetheaders($req){
$r=$h=$o=null;
if(preg_match("/GET(.*)HTTP/",$req,$match)){$r=$match[1];}
if(preg_match("/Host:(.*) /",$req,$match)){$h=$match[1];}
if(preg_match("/Origin:(.*) /",$req,$match)){$o=$match[1];}
if(preg_match("/Sec-WebSocket-Key:(.*) /",$req,$match)){$key=$match[1];}
if(preg_match("/ (.*?)$/",$req,$match)){$data=$match[1];}
returnarray($r,$h,$o,$key,$data);
}
functionWebSocket($address,$port){
$master=socket_create(AF_INET,SOCK_STREAM,SOL_TCP)ordie("socket_create()failed");
socket_set_option($master,SOL_SOCKET,SO_REUSEADDR,1)ordie("socket_option()failed");
socket_bind($master,$address,$port)ordie("socket_bind()failed");
socket_listen($master,20)ordie("socket_listen()failed");
echo"ServerStarted:".date('Y-m-dH:i:s')." ";
echo"Mastersocket:".$master." ";
echo"Listeningon:".$address."port".$port." ";
return$master;
}
functiondohandshake($buffer){
list($resource,$host,$origin,$key,$data)=getheaders($buffer);
echo"resourceis$resource ";
echo"originis$origin ";
echo"hostis$host ";
echo"keyis$key ";
$response_key=base64_encode(sha1($key.'258EAFA5-E914-47DA-95CA-C5AB0DC85B11',true));
$return_str="HTTP/1.1101SwitchingProtocols ".
"Upgrade:websocket ".
"Connection:Upgrade ".
"Sec-WebSocket-Accept:$response_key ";
return$return_str;
}
functionconsole($msg){
$msg=transToGBK($msg);
echo"$msg ";
return$msg;
}
functiondecode($msg=""){
$mask=array();
$data="";
$msg=unpack("H*",$msg);
$head=substr($msg[1],0,2);
if(hexdec($head{1})===8){
$data=false;
}elseif(hexdec($head{1})===1){
$mask[]=hexdec(substr($msg[1],4,2));
$mask[]=hexdec(substr($msg[1],6,2));
$mask[]=hexdec(substr($msg[1],8,2));
$mask[]=hexdec(substr($msg[1],10,2));
$s=12;
$e=strlen($msg[1])-2;
$n=0;
for($i=$s;$i<=$e;$i+=2){
$data.=chr($mask[$n%4]^hexdec(substr($msg[1],$i,2)));
$n++;
}
}
return$data;
}
functionencode($msg=""){
$frame=array();
$frame[0]="81";
$msg.='isok';
$len=strlen($msg);
$frame[1]=$len<16?"0".dechex($len):dechex($len);
$frame[2]=ord_hex($msg);
$data=implode("",$frame);
returnpack("H*",$data);
}
functiontransToGBK($s){//UTF8->GBK
//echo$s;
returniconv("UTF-8","GBK",$s);
return$s;
}
functionord_hex($data){
$msg="";
$l=strlen($data);
for($i=0;$i<$l;$i++){
//ord是返回字元串第一個字元的ascii值
//dechex把十進制轉換為十六進制
$msg.=dechex(ord($data{$i}));
}
return$msg;
}
functiondisconnect($socket){
global$is_shaked,$is_closed;
$is_shaked=false;
$is_closed=true;
socket_close($socket);
}
?>
② 如何用php實現websocket
html5自帶有websocket，這是客戶端的。
php可以使用swoole框架來實現websocket。
或則自己解析websocket協議，使用php自帶的socket。
友情提示：在以上情況的時候，php是運行在cli模式下的，這樣才能讓程序常駐內存。
③ php實現websocket實時消息推送
一、socket協議的簡介
WebSocket是什麼，有什麼優點
WebSocket是一個持久化的協議，這是相對於http非持久化來說的。應用層協議
舉個簡單的例子，http1.0的生命周期是以request作為界定的，也就是一個request，一個response，對於http來說，本次client與server的會話到此結束；而在http1.1中，稍微有所改進，即添加了keep-alive，也就是在一個http連接中可以進行多個request請求和多個response接受操作。然而在實時通信中，並沒有多大的作用，http只能由client發起請求，server才能返回信息，即server不能主動向client推送信息，無法滿足實時通信的要求。而WebSocket可以進行持久化連接，即client只需進行一次握手，成功後即可持續進行數據通信，值得關注的是WebSocket實現client與server之間全雙工通信，即server端有數據更新時可以主動推送給client端。
二、介紹client與server之間的socket連接原理
1、下面是一個演示client和server之間建立WebSocket連接時握手部分
2、client與server建立socket時握手的會話內容，即request與response
a、client建立WebSocket時向伺服器端請求的信息
GET /chat HTTP/1.1
Host: server.example.com
Upgrade: websocket //告訴伺服器現在發送的是WebSocket協議
Connection: Upgrade
Sec-WebSocket-Key: x3JJHMbDL1EzLkh9GBhXDw== //是一個Base64 encode的值，這個是瀏覽器隨機生成的，用於驗證伺服器端返回數據是否是WebSocket助理
Sec-WebSocket-Protocol: chat, superchat
Sec-WebSocket-Version: 13
Origin: http://example.com
b、伺服器獲取到client請求的信息後，根據WebSocket協議對數據進行處理並返回，其中要對Sec-WebSocket-Key進行加密等操作
HTTP/1.1 101 Switching Protocols
Upgrade: websocket //依然是固定的，告訴客戶端即將升級的是Websocket協議，而不是mozillasocket，lurnarsocket或者shitsocket
Connection: Upgrade
Sec-WebSocket-Accept: HSmrc0sMlYUkAGmm5OPpG2HaGWk= //這個則是經過伺服器確認，並且加密過後的 Sec-WebSocket-Key,也就是client要求建立WebSocket驗證的憑證
Sec-WebSocket-Protocol: chat
3、socket建立連接原理圖：
三、PHP中建立websocket的過程講解
SocketService.php:
web.html:
④ php 怎麼使用websocket推送消息
首先：WebSocket 不是一門技術，而是一種全新的協議。它應用 TCP 的 Socket（套接字），為網路應用定義了一個新的重要的能力：客戶端和伺服器端的雙全工傳輸和雙向通信。是繼 Java applets、 XMLHttpRequest、 Adobe Flash,、ActiveXObject、 各類 Comet 技術之後，伺服器推送客戶端消息的新趨勢。
其次：與http的關系
在網路分層上，websocket 與 http 協議都是應用層的協議，它們都是基於 tcp 傳輸層的，但是 websocket 在建立連接時，是借用 http 的 101 switch protocol 來達到協議轉換（Upgrade）的，從 HTTP 協議切換成 WebSocket 通信協議,這個動作協議中稱「握手」；
握手成功後，websocket 就使用自己的協議規定的方式進行通訊，跟 http 就沒有關系了。
用戶在socket檢測用戶上下線的是時候 可以http請求到自己的api層下面我貼一下我的代碼
這個地方明確表明了監聽埠，websocket跟api在同一個伺服器上面，所以用了0.0.0.0，所以你在http服務端如果想發消息給客戶端，只需要發送到這個埠上面，socket自動會監聽到發送給客戶端。
⑤ php websocket連接報錯怎麼解決
php websocket連接報錯一般是握手連接失敗導致。
php 用websocket，從連接、建立、綁定、監聽等，這些都需要手動去操作。配置錯誤會導致無法連接。
下樑棗面是client和server端建立websocket連接示意圖：
解析：
1、PHP 中處理 WEBSOCKET
WebSocket 連接是由客戶端主動發起的，所以一切要從客戶端出發。第一步是要解析拿到客戶端發過來的 Sec-WebSocket-Key 字元串。
GET /chat HTTP/1.1
Host: server.example.com
Upgrade: websocket
Connection: Upgrade
Sec-WebSocket-Key: dGhlIHNhbXBsZSBub25jZQ==
Origin: .com
Sec-WebSocket-Protocol: chat, superchat
Sec-WebSocket-Version: 13
2、提取 SEC-WEBSOCKET-KEY 信息
function getKey($req) {
$key = null;
if (preg_match("/Sec-WebSocket-Key: (.*)/r/n/", $req, $match)) {
$key = $match[1];
}
return $key;
}
3、加密 SEC-WEBSOCKET-KEY
function encry($req){
$key = $this->getKey($req);
$mask = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));
}
以上閉辯任何一個環節出錯都會導致失敗。轎渣缺
⑥ 如何用PHP實現基於websocket的實時通訊
哈哈，過了這么幾年了，websocket已經相當穩定和成熟了。
各大瀏覽器都對websocket有了很好的支持，目前微信小程序也支持websocket協議了，那些說websocket不穩定的可以暫時歇一歇了。
如果是自己開發websocket服務，可以用swoole等來實現，不過要做好還是需要花很多時間和精力的。
你可以試試【GoEasy】提供的websocket推送服務，目前算是比較流行的一款websocket推送框架，穩定性還不錯，對多種前後端都有很好的支持的。
⑦ 如何使用GoEasy實現PHP與Websocket實時通信
如何使用GoEasy實現PHP與Websocket實時通信
實現步驟如下：
1. 獲取GoEasy appkey.
在goeasy官網上注冊一個賬號，並新建一個app. APP創建好後系統會為該app自動生成兩個key, 一個既可以用來接收又可以用來推送 (supper key)，另一個只可以用來接收(subscriber key).
2. 客戶端訂閱一個channel.
a. 在客戶端引入goeasy.js， js地址：
需要注意的是，不能將goeasy.js下載到本地，因為goeasy會根據不同瀏覽器來提供不同的js. 官網上也有相隱握應說明。
b. 訂閱代碼
var goEasy = new GoEasy({appkey: 'subscriber key'});//這里我用的是subscriber key,因為在我的客戶端我不需要推送任何消息，所以沒有必要使用supper key
goEasy. subscribe({
channel: 'csdnNotification',
onMessage: function(message){
alert('Meessage received:'+message.content);//接收到推送的消息
}
});
復制代碼
3. 前台推送及後台推送
3.1. 前台往相同channel上推送
在引入了好攜孝goeasy.js的頁面，直接調用goEasy. publish('csdnNotification', '您的好友222已上線'); 用法與訂閱類似。
3.2. 後台往相同channel上推送. 用GoEasy提供的restful API實現
API url:
方式: Post
參數列表：
channel: 'csdnNotification' //與訂閱的友稿channel必須一致，否則客戶端將收不到消息。因此我們也可以根據channel來控制哪些客戶端可以接收。
appkey: 'supper key' //這里必須使用supper key
content: 'blabla…..' //要推送的內容
⑧ 如何用php實現websocket
websocket需要php監聽一個固定或尺的埠，而不是請求的時候再去執行 一般的主機服務無法實現此功能 如果你有伺服器的設置許可權，可以在伺服器上用php命令開啟埠，再用nginx做一空宏個Websocket代理 大多數虛擬主機服務商是不支持自己配置服衫虧高務器的