let ws = new WebSocket("ws://ip:端口")
if (ws.readyState <= 0) {
    console.log('连接服务器失败！', ws)
}

// 当成功连接到服务器后执行
ws.onopen = function (event) {
    console.log('连接服务器成功！', event)
}

// 当该连接关闭后执行
ws.onclose = function (event) {
    console.log('连接关闭！')
}

// 当连接出错
ws.onerror = function (event) {
    console.log('连接出错！')
}

// 接收到服务器返回的信息
ws.onmessage = function (event) {
    console.log('服务器返回信息:' + event.data)
}

// 什么时候发送消息，自己决定
function toSend () {
    let txt = '发送内容自己搞定';
    ws.send(txt);
}

// 配置正确的IP与端口后，没打开一个该页面就是一次客户端请求

// 创建TCP类型的Socket服务
// 该扩展不能直接创建ws协议的Socket服务器,所以后面真正通信前需要升级协议
$server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);

// 配置一下(接收所有的数据包)
$res = socket_set_option($server, SOL_SOCKET, SO_REUSEADDR, 1);

// 绑定IP与端口号
// IP地址若是0.0.0.0则可以是任意客户端连接，若是127.0.0.1则只能是内网客户端连接
$res = socket_bind($server, $address, $port);

// 监听该通道
$res = socket_listen($server);

// 此时Socket服务器已经创建完成
// 需要注意： 以上每一步都有可能失败，所以严谨写法每一步都需要对结果做判断
// stream_socket_server()可以一行搞定，但不在讲解范围，感兴趣的可以自行百度

// 设置死循环防止服务器关闭
while (true) {

    // 阻塞循环等待客户端的请求
    $client = socket_accept($server);

    // 只有新的客户端请求连接时，才会继续执行
    // 而且新客户端第一次请求带协议头信息
    // 读取客户端信息，此时客户端信息只有请求头信息，设置1024防止一次读取不完
    $buffer = socket_read($client, 1024);

    // 协议不对等，无法交流，升级协议
    $fer = substr($buffer, strpos($buffer, 'Sec-WebSocket-Key:') + 18);
    $key = trim(substr($fer, 0, strpos($fer, "\r\n")));
    $enKey = base64_encode(sha1($key . "258EAFA5-E914-47DA-95CA-C5AB0DC85B11", true));
    // 按照协议组合返回头信息
    $header = "HTTP/1.1 101 Switching Protocols\r\n";
    $header .= "Upgrade: websocket\r\n";
    $header .= "Sec-WebSocket-Version: 13\r\n";
    $header .= "Connection: Upgrade\r\n";
    $header .= "Sec-WebSocket-Accept: " . $enKey . "\r\n\r\n";
    $res = socket_write($client, $header, strlen($header));

    // 此时协议对等，阻塞等待接收客户端发送的信息
    // 此处1024可能不够，可以循环读取。
    $buffer = socket_read($client, 1024);
    // 要使用客户端信息，需要先解码, 下方附带该函数
    $buffer = deCode($buffer);

    // 若上面读取缓冲区数据完成，此处向客户端做出的回应才会送到
    $msg = '直接返回数据是不行的，需要对该数据先编码，客户端才可识别';
    $msg = enCode($msg);
    $res = socket_write($client, $msg, strlen($msg));

    // 关闭该客户端资源(断开连接)
    socket_close($client);
}

// 关闭服务端资源(停止服务)
// 思维上应该这么写，但是因为此处永远执行不到，所以写了也没用
// 只能使用Linux命令杀死服务端进程
socket_close($server);

// 别问我编码解码的原理，读一下代码，自己琢磨(百度)。
// 编码
function enCode($msg){
    $frame = [];
    $frame[0] = '81';
    $len = strlen($msg);
    if ($len < 126) {
        $frame[1] = $len < 16 ? '0' . dechex($len) : dechex($len);
    } else if ($len < 65025) {
        $s = dechex($len);
        $frame[1] = '7e' . str_repeat('0', 4 - strlen($s)) . $s;
    } else {
        $s = dechex($len);
        $frame[1] = '7f' . str_repeat('0', 16 - strlen($s)) . $s;
    }
    $frame[2] = ordHex($msg);
    $data = implode('', $frame);
    return pack("H*", $data);
}

// 解码
function deCode($buffer){
    $decoded = '';
    $len = !empty($buffer[1]) ? (ord($buffer[1]) & 127) : 0;
    if ($len === 126) {
        $masks = substr($buffer, 4, 4);
        $data = substr($buffer, 8);
    } else if ($len === 127) {
        $masks = substr($buffer, 10, 4);
        $data = substr($buffer, 14);
    } else {
        $masks = substr($buffer, 2, 4);
        $data = substr($buffer, 6);
    }
    for ($index = 0; $index < strlen($data); $index++) {
        $decoded .= $data[$index] ^ $masks[$index % 4];
    }
    return $decoded;
}

// 进制转换
function ordHex($data){
    $msg = '';
    $l = strlen($data);
    for ($i = 0; $i < $l; $i++) {
        $msg .= dechex(ord($data[$i]));
    }
    return $msg;
}

// 执行PHP代码开启服务器
// Ctrl + Z 即可停止该服务
php 文件.php

// 停止Socket服务后需要手动关闭该进程
// 查看进程
lsof -i tcp:12345

// 杀死进程
kill -9 进程ID