導航:首頁 > 編程語言 > php56使用websocket

php56使用websocket

發布時間:2023-05-23 09:43:43

php服務端使用WebSocket客戶端Android用什麼 Socket可以嗎

理論上客戶端也是需要用socket的,socket是tcp/udp協議通信的,過程比較繁瑣。
為何不採用基於http協議的webservice呢

⑵ 如何用PHP實現基於websocket的實時通訊

哈哈,過了這么幾年了,websocket已經相當穩定和成熟了。

各大瀏覽器都對websocket有了很好的支持,目前微信小程序也支持websocket協議了,那些說websocket不穩定的可以暫時歇一歇了。

如果是自己開發websocket服務,可以用swoole等來實現,不過要做好還是需要花很多時間和精力的。

你可以試試【GoEasy】提供的websocket推送服務,目前算是比較流行的一款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

websocket需要php監聽一個固定的埠,而不是請求的時候再去執行 一般的主機服務無法實現此功能 如果你有伺服器的設置許可權,可以在伺服器上用php命令開啟埠,再用nginx做一個Websocket代理 大多數虛擬主機服務商是不支持自己配置伺服器的

⑸ php 怎麼使用websocket推送消息

自己寫個socket服務端文件或者用workerman框架 。架設一個socket
然後h5 鏈接socket 寫邏輯

具體可以參考workerman的演示

⑹ php 怎麼使用websocket推送消息

我使用的工具是基於wokman的web-msg-sender是一款web長連接推送框架,採用PHPSocket.IO開發,基於WebSocket長連接通訊,如果瀏覽器不支持WebSocket則自動轉用comet推送。 通過後台推送消息,消息可以即時推送到客戶端,非輪詢,實時性非常好,性能很高。

下載和demo地址http://www.workerman.net/web-sender

這裡面區分服務端和客戶端,去上面地址下載源代碼,放到你服務端。使用相關命令開啟服務。

其中有一個文件是start_io.php,這個文件算是核心,裡面有怎麼發送socket消息的代碼,也會有監控用戶上下線的介面,在這個地方可以根據業務需要拓展自己的代碼需求。類似:用戶在socket檢測用戶上下線的是時候,可以http請求到自己的api層

下面我貼一下我的代碼

這個地方明確表明了監聽埠,websocket跟api在同一個伺服器上面,所以用了0.0.0.0,所以你在http服務端如果想發消息給客戶端,只需要發送到這個埠上面,socket自動會監聽到發送給客戶端。

⑺ 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:

閱讀全文

與php56使用websocket相關的資料

熱點內容
單片機定時電路 瀏覽:672
山西平台伺服器雲主機 瀏覽:700
按摩肚臍解壓視頻 瀏覽:989
php55安裝教程 瀏覽:137
雲伺服器怎麼查找本機域名 瀏覽:22
qd123y壓縮機參數 瀏覽:385
程序員媽媽懷孕 瀏覽:490
金普國際編程 瀏覽:537
java什麼是引用類型 瀏覽:944
這是命令嗎txt 瀏覽:314
支付寶android包名 瀏覽:154
eclipsemaven命令 瀏覽:68
24路伺服器配什麼cpu 瀏覽:466
壓縮文件和解壓文件哪個快 瀏覽:675
亞馬遜雲伺服器視頻通話 瀏覽:912
金融知識app哪個好 瀏覽:978
農行理財app收益在哪裡 瀏覽:969
暗淡的命令名項目表示該命令 瀏覽:212
串口轉乙太網程序源碼 瀏覽:970
兩位數乘兩位數的快速運演算法 瀏覽:907