PHP实现WebSocket详解与示例

3 浏览量更新于2024-09-01 收藏 93KB PDF 举报

"本文将详细解析PHP中WebSocket的使用方法，包括服务端的实现和相关概念，适合对PHP网络编程感兴趣的开发者参考学习。" 在PHP中，WebSocket是一种提供双向通信的协议，允许服务器主动向客户端推送数据。WebSocket使得实时应用如聊天、游戏、股票行情等变得更加高效和简单。下面我们将深入探讨如何在PHP中实现WebSocket服务端。首先，创建一个WebSocket服务器需要创建一个socket连接。在给出的代码示例中，`newSock`函数初始化了一个WebSocket服务器，并通过`WebSocket`方法与指定的IP地址（127.0.0.1）和端口（8000）建立连接。`$sk->run()`启动了服务器并进入无限循环，等待客户端的连接和通信。在`Sock`类中，有几个重要的属性用于处理WebSocket连接： 1. `$sockets`：存储所有客户端和服务器的套接字资源，初始时包含服务器套接字。 2. `$users`：通常用于存储已连接的客户端的标识，以便于管理和通信。 3. `$sda`、`$slen`、`$sjen`和`$ar`：这些数组用于处理WebSocket数据帧的接收和解析，包括已接收的数据、数据总长度、接收数据的长度以及可能的加密key。 4. `$n`：可能用于处理网络相关的变量。 `run`方法中的无限循环是服务器的核心，它通过`select`系统调用来监控套接字集合，`select`函数允许我们同时处理多个套接字的输入/输出事件，而不会阻塞。在循环中，`$changes`数组包含了可能有可读或可写事件的套接字。接下来，`select`函数会检查哪些套接字准备好了进行读取、写入或异常操作。当有新的客户端连接时，服务器会接收新的套接字，并将其添加到`$sockets`数组中。一旦有数据从客户端接收，服务器需要解析WebSocket帧，处理握手和数据传输。 WebSocket帧的解析涉及以下步骤： 1. 验证帧头，包括fin、opcode、mask和长度字段。 2. 如果帧被masking，需要解码数据。 3. 根据opcode判断是文本帧、二进制帧还是控制帧（如关闭、ping、pong）。 4. 处理数据，如文本帧则进行UTF-8验证，二进制帧则直接传递数据。 5. 对于控制帧，执行相应的操作，如关闭连接、回应ping等。在服务端，`send`函数用于向特定的客户端发送数据，`send1`可能是发送消息给指定用户，`send2`可能是处理用户的退出登录请求。 PHP中的WebSocket实现涉及到网络编程的基本概念，包括套接字、数据帧解析和网络通信协议。理解这些原理和实践可以帮助开发者构建实时交互的应用。不过，需要注意的是，PHP本身并不直接支持WebSocket，通常需要借助第三方库如Ratchet或PHP-Websocket来实现。

详解详解PHP中中websocket的使用方法的使用方法

主要为大家详细介绍了PHP中websocket的使用方法，为大家进行了详细注解,具有一定的参考价值，感兴趣的小伙伴们可以参考一下

关于PHP中websocket使用的详细注解，供大家参考。

服务端：

<?php

//send用户加入

//send1发送信息

//send2退出登录

error_reporting(E_ALL ^ E_NOTICE);

ob_implicit_flush();

//file_put_contents('lz.text','123', FILE_APPEND);

$sk=new Sock('127.0.0.1',8000);

$sk->run();

class Sock{

public $sockets;

public $users;

public $master;

private $sda=array();//已接收的数据

private $slen=array();//数据总长度

private $sjen=array();//接收数据的长度

private $ar=array();//加密key

private $n=array();

public function __construct($address, $port){

$this->master=$this->WebSocket($address, $port);//resource(2, Socket) //服务器监听

var_dump("master:");

var_dump($this->master);

$this->sockets=array($this->master);//array (size=1) 0 => resource(2, Socket) 。运行两个php还是这样

//var_dump($this->sockets);

//file_put_contents('lz.text',var_dump($this->sockets), FILE_APPEND);

}

function run(){

while(true){

$changes=$this->sockets;//$changes由多变1,但$this->sockets却只是稳定的+1;

$write=NULL;

$except=NULL;

//1.运行select()系统调用在给定阵列插座与指定的超时

//2.没有接收到数据就会一直处于阻塞状态,

//3.若没有client过来,直阻塞进程,直到有client访问,返回1。

//4.此时返回的changes,不是曾经的changes。虽然还只是一条记录,但已经不是服务器而是客户端

/*select的特殊作用：！！！！！！！

初始为array(0=>resource(2, Socket))

1,初始状态返回为array(0=>resource(2, Socket))。但socket_accept可以得到resource(3, Socket)

2,初始状态返回为array(0=>resource(2, Socket),1=>resource(3,Socket))。

客户来的客户为resource(3,Socket)。则返回的数据为resource(3,Socket).!!!

var_dump($changes);

$rr=socket_select($changes,$write,$except,NULL);

var_dump($changes);

var_dump("---*---");

//exit;

file_put_contents('lz.text',json_encode($changes), FILE_APPEND);

file_put_contents('lz.text','-----', FILE_APPEND);*/

foreach($changes as $sock){

//连接主机的client

//$this->master永远是 resource(2, Socket)。相当于一个缓存。两种情况,1:为空,使进程阻塞。2：存刚接收的client。

if($sock==$this->master){ //---此处只用来存数据了

//在socket套接字已创建使用socket_create()，必将与socket_bind()名字，告诉听连接socket_listen()，这个函数将接受传入的连接，插座。

//一旦成功连接，将返回一个!!新的套接字资源！！，该资源可用于通信。如果套接字上有多个连接，则第一个将被使用。

//如果没有挂起的连接，socket_accept()将阻塞直到连接成为现在。如果使用了非阻塞套接字已socket_set_blocking()或socket_set_nonblock()，错误将返回。

//返回socket_accept()插座资源不得用于接受新的连接。原来的听插座插座，但是,仍然是开放的，可以重复使用。

$client=socket_accept($this->master); //resource(3, Socket)。表示接受请求,并创建一个子链接!!

//var_dump($client);

//exit;

$key=uniqid();

$this->sockets[]=$client;

$this->users[$key]=array(

'socket'=>$client,

'shou'=>false

);

array (size=1)

'57d607085f92a' => //$key

array (size=2)

'socket' => resource(3, Socket) //$socket的表现都一样,只有通过$key区分

'shou' => boolean false

// file_put_contents('lz.text',json_encode($this->users), FILE_APPEND);

}else{ //---此处服务器与客户端发信息

$len=0;

$buffer='';

do{

int socket_recv ( resource socket, string &buf, int len, int flags )

resource socket 是生成的套接字

string &buf 是接收缓冲区

int len 是你打算接收的长度

int flags 是一个标志

0x1 数据应该带外发送，所谓带外数据就是TCP紧急数据

0x2 使有用的数据复制到缓冲区内，但并不从系统缓冲区内删除。

0x4 不要将包路由出去。

下载后可阅读完整内容，剩余5页未读，立即下载

weixin_38665822

粉丝: 9

PHP实现WebSocket详解与示例

小程序中的websocket接入方法详解

PHP实现WebSocket详解：从基础到实战

Ratchet实现PHP WebSocket演示代码详解

php中使用websocket详解

php使用websocket示例详解

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

PHP WebSocket连接示例与关键步骤详解

PHPWebSocket实现实例与操作技巧详解

PHP WebSocket详解：从连接到实现步骤

PHPWebSocket协议详解：原理与实战应用

最新资源