首页 > 作文

PHP 实现 WebSocket 协议原理与应用详解

更新时间:2023-04-08 14:19:27 阅读：评论：0

本文实例讲述了php 实现 websocket 协议原理与应用。分享给大家供大家参考，具体如下：

下面会讲解一下什么是 websocket，以及使用 php 实现 websocket。

websocket 是什么？php 实例应用场景

一、websocket 是什么

websocket 是一种网络传输协议，可在单个 tcp 连接上进行全双工通信，位于 osi 模型的应用层。websocket 使得客户端和服务器之间的数据交换变得更加简单，允许服务端主动向客户端推送数据。

在 websocket api 中，浏览器和服务器只需要完成一次握手，两者之间就可以创建持久性的连接，并进行双向数据传输。

特点：网络协议；双向数据传输；允许服务端主动向客户端推送数据；

二、php 实例

客户端代码 index.html

<!doctype html><html lang="en"> <head> <meta chart="utf-8"课题开题报告范文> <meta name="viewport" content="width=device-width,initial-scale=1, maximum-scale=1, ur-scalable=no"> <title>websocket</title> </head> <body> <input id="text" value=""> <input type="submit" value="nd" onclick="start()"> <input type="submit" value="clo" onclick="clo()"><div id="msg"></div> <script> /** 0：未连接1：连接成功，可通讯2：正在关闭3：连接已关闭或无法打开*/ //创建一个websocket 实例 var websocket = new websocket("ws://127.0.0.1:8083"); websocket.onerror = function (event){  onerror(event); }; // 打开websocket websocket.onopen = function (event){  onopen(event); }; //监听消息 websocket.onmessage = function (event){  onmessage(event); }; websocket.onclo = function (event){  onclo(event); } //关闭监听websocket function onerror(event){  document.getelementbyid("msg").innerhtml = "<p>clo</p>";  console.log("error"+event.data); }; function onopen(event){  console.log("open:"+sockstate());  document.getelementbyid("msg").innerhtml = "<p>connect to rvice</p>"; }; function onmessage(event){  console.log("onmessage");  document.getelementbyid("msg").innerhtml += "<p>respon:"+event.data+"</p>" }; function onclo(event){  document.getelementbyid("msg").innerhtml = "<p>clo</p>";  console.log("clo:"+sockstate());  websocket.clo(); } function sockstate(){  var status = ['未连接','连接成功，可通讯','正在关闭','连接已关闭或无法打开'];   return status[websocket.readystate]; } function start(event){  console.log(websocket);  var msg = document.getelementbyid('text').value;  document.getelementbyid('text').value = '';  console.log("nd:"+sockstate());人工智能发展前景  console.log("msg="+msg);  websocket.nd("msg="+msg);  document.getelementbyid("msg").innerhtml += "<p>request"+msg+"</p>" }; function clo(event){  websocket.clo(); } </script> </body></html>

服务端代码 rver.php

<?php/** * created by xwx * date: 2017/10/18 * time: 14:33 */class socketrvice{ private $address = '0.0.0.0'; private $port = 8083; private $_sockets; public function __construct($address = '', $port='') {   if(!empty($address)){    $this->address = $address;   }   if(!empty($port)) {    $this->port = $port;   } } public function rvice(){  //获取tcp协议号码。  $tcp = getprotobyname("tcp");  $sock = socket_create(af_inet, sock_stream, $tcp);  socket_t_option($sock, sol_socket, so_reuaddr, 1);  if($sock < 0)  {   throw new exception("failed to create socket: ".socket_strerror($sock)."\n");  }  socket_bind($sock, $this->address, $this->port);  socket_listen($sock, $this->port);  echo "listen on $this->address $this->port ... \n";  $this->_sockets = $sock; } public function run(){  $this->rvice();  $clients[] = $this->_sockets;  while (true){   $changes = $clients;   $write = null;   $except = null;   socket_lect($changes, $write, $except, null);   foreach ($changes as $key => $_sock){    if($this->_sockets == $_sock){ //判断是不是新接入的socket     if(($newclient = socket_accept($_sock)教师节活动主题) === fal){      die('failed to accept socket: '.socket_strerror($_sock)."\n");     }     $line = trim(socket_read($newclient, 1024));     $this->handshaking($newclient, $line);     //获取client ip     socket_getpeername ($newclient, $ip);     $clients[$ip] = $newclient;     echo "client ip:{$ip} \n";     echo "client msg:{$line} \n";    } el {     socket_recv($_sock, $buffer, 2048, 0);     $msg = $this->message($buffer);     //在这里业务代码     echo "{$k与众不同的联想作文ey} clinet msg:",$msg,"\n";     fwrite(stdout, 'plea input a argument:');     $respon = trim(fgets(stdin));     $this->nd($_sock, $respon);     echo "{$key} respon to client:".$respon,"\n";    }   }  } } /**  * 握手处理  * @param $newclient socket  * @return int 接收到的信息  */ public function handshaking($newclient, $line){  $headers = array();  $lines = preg_split("/\r\n/", $line);  foreach($lines as $line)  {   $line = chop($line);   if(preg_match('/\a(\s+): (.*)\z/', $line, $matches))   {    $headers[$matches[1]] = $matches[2];   }  }  $ckey = $headers['c-websocket-key'];  $caccept = ba64_encode(pack('h*', sha1($ckey . '258eafa5-e914-47da-95ca-c5ab0dc85b11')));  $upgrade = "http/1.1 101 web socket protocol handshake\r\n" .   "upgrade: websocket\r\n" .   "connection: upgrade\r\n" .   "websocket-origin: $this->address\r\n" .   "websocket-location: ws://$this->address:$this->port/websocket/websocket\r\n".   "c-websocket-accept:$caccept\r\n\r\n";  return socket_write($newclient, $upgrade, strlen($upgrade)); } /**  * 解析接收数据  * @param $buffer  * @return null|string  */ public function message($buffer){  $len = $masks = $data = $decoded = null;  $len = ord($buffer[1]) & 127;  if ($len === 126) {   $masks = subst第一演播室r($buffer, 4, 4);   $data = substr($buffer, 8);  } el if ($len === 127) {   $masks = substr($buffer, 10, 4);   $data = substr($buffer, 14);  } el {   $masks = substr($buffer, 2, 4);   $data = substr($buffer, 6);  }  for ($index = 0; $index < strlen($data); $index++) {   $decoded .= $data[$index] ^ $masks[$index % 4];  }  return $decoded; } /**  * 发送数据  * @param $newclinet 新接入的socket  * @param $msg 要发送的数据  * @return int|string  */ public function nd($newclinet, $msg){  $msg = $this->frame($msg);  socket_write($newclinet, $msg, strlen($msg)); } public function frame($s) {  $a = str_split($s, 125);  if (count($a) == 1) {   return "\x81" . chr(strlen($a[0])) . $a[0];  }  $ns = "";  foreach ($a as $o) {   $ns .= "\x81" . chr(strlen($o)) . $o;  }  return $ns; } /**  * 关闭socket  */ public function clo(){  return socket_clo($this->_sockets); }}$sock = new socketrvice();$sock->run();

先使用命令行运行 rver.php，然后在浏览器打开 index.html 即可运行

三、应用场景

聊天室实时推送弹幕多玩家游戏协同编辑股票基金实时报价体育实况更新视频会议/聊天基于位置的应用在线教育智能家居等需要高实时的场景

由轮询到websocket

轮询

客户端和服务器之间会一直进行连接，每隔一段时间就询问一次。客户端会轮询，有没有新消息。这种方式连接数会很多，一个接受，一个发送。而且每次发送请求都会有http的header，会很耗流量，也会消耗cpu的利用率。

长轮询

长轮询是对轮询的改进版，客户端发送http给服务器之后，有没有新消息，如果没有新消息，就一直等待。当有新消息的时候，才会返回给客户端。在某种程度上减小了网络带宽和cpu利用率等问题。但是这种方式还是有一种弊端：例如假设服务器端的数据更新速度很快，服务器在传送一个数据包给客户端后必须等待客户端的下一个get请求到来，才能传递第二个更新的数据包给客户端，那么这样的话，客户端显示实时数据最快的时间为2×rtt（往返时间），而且如果在网络拥塞的情况下，这个时间用户是不能接受的，比如在股市的的报价上。另外，由于http数据包的头部数据量往往很大（通常有400多个字节），但是真正被服务器需要的数据却很少（有时只有10个字节左右），这样的数据包在网络上周期性的传输，难免对网络带宽是一种浪费。