Как в PHP сокет сервере передавать сообщение между клиентами и нужному клиенту?

Question

[AlexSer]

Добрый день! Возник вопрос с сокетом.
Реализация такая:
Сокет сервер принимает данные на по Tсp и передает по web -сокету клиенту.
Не могу реализовать чтобы каждое устройство обменивалось только со своим клиентом:
Устройство #1 соединяется к сокет серверу и клиент №1 соединяется c сервером через веб сокет
Вот код сервера(взял с портала php):
SocketServer.php

<?php
    $host = '127.0.0.1';
    $port = 9501;
    $path = 'C:/Certbot/live/php.net/';
    $transport = 'tcp';

    $server = stream_socket_server($transport . '://' . $host . ':' . $port, $errno, $errstr, STREAM_SERVER_BIND|STREAM_SERVER_LISTEN);
    if (!$server) {  die("$errstr ($errno)"); }
    $clients = array($server);
    $write  = NULL;
    $except = NULL;
    while (true) {
        $changed = $clients;
        stream_select($changed, $write, $except, 10);
        if (in_array($server, $changed)) {
            $client = @stream_socket_accept($server);
            if (!$client){ continue; }
            $clients[] = $client;
            $ip = stream_socket_get_name( $client, true );
            echo "New Client connected from $ip\n";

            stream_set_blocking($client, true);
            $headers = fread($client, 1500);
            handshake($client, $headers, $host, $port);
            stream_set_blocking($client, false);

            send_message($clients, mask($ip . ' connected'));
            $found_socket = array_search($server, $changed);
            unset($changed[$found_socket]);
        }
        foreach ($changed as $changed_socket) {
            $ip = stream_socket_get_name( $changed_socket, true );
            $buffer = stream_get_contents($changed_socket);
            if ($buffer == false) {
                echo "Client Disconnected from $ip\n";
                @fclose($changed_socket);
                $found_socket = array_search($changed_socket, $clients);
                unset($clients[$found_socket]);
            }
            $unmasked = unmask($buffer);
            if ($unmasked != "") { echo "\nReceived a Message from $ip:\n\"$unmasked\" \n"; }
            $response = mask($unmasked);
            send_message($clients, $response);
        }
    }
    fclose($server);

    function unmask($text) {
        $length = @ord($text[1]) & 127;
        if($length == 126) {    $masks = substr($text, 4, 4);    $data = substr($text, 8); }
        elseif($length == 127) {    $masks = substr($text, 10, 4); $data = substr($text, 14); }
        else { $masks = substr($text, 2, 4); $data = substr($text, 6); }
        $text = "";
        for ($i = 0; $i < strlen($data); ++$i) { $text .= $data[$i] ^ $masks[$i % 4];    }
        return $text;
    }
    function mask($text) {
        $b1 = 0x80 | (0x1 & 0x0f);
        $length = strlen($text);
        if($length <= 125)
            $header = pack('CC', $b1, $length);
        elseif($length > 125 && $length < 65536)
            $header = pack('CCn', $b1, 126, $length);
        elseif($length >= 65536)
            $header = pack('CCNN', $b1, 127, $length);
        return $header.$text;
    }
    function handshake($client, $rcvd, $host, $port){
        $headers = array();
        $lines = preg_split("/\r\n/", $rcvd);
        foreach($lines as $line)
        {
            $line = rtrim($line);
            if(preg_match('/\A(\S+): (.*)\z/', $line, $matches)){
                $headers[$matches[1]] = $matches[2];
            }
        }
        $secKey = $headers['Sec-WebSocket-Key'];
        $secAccept = base64_encode(pack('H*', sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
        //hand shaking header
        $upgrade  = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" .
            "Upgrade: websocket\r\n" .
            "Connection: Upgrade\r\n" .
            "WebSocket-Origin: $host\r\n" .
            "WebSocket-Location: wss://$host:$port\r\n".
            "Sec-WebSocket-Version: 13\r\n" .
            "Sec-WebSocket-Accept:$secAccept\r\n\r\n";
        fwrite($client, $upgrade);
    }
    function send_message($clients, $msg){
        foreach($clients as $changed_socket){
            @fwrite($changed_socket, $msg);
        }
    }
?>

Вопрос:
Как сделать чтобы клиент 1 обменивался с устройством 1, и клиент 2 только с устройством 2.