Client WebSocket in PHP?

Question

Esiste una libreria o un client per la connessione a un server WebSocket da PHP? Se no, c'è una ragione per cui?

(phpwebsocket solo sembrano avere codice client JavaScript.)

Answer 1

bene, è facile e si può fare in questa Grazie a tutte le fonti in cui abbiamo trovato le risposte (mi dispiace, non riesco a ricordare tutti)

<?php 
$host = '10.9.8.173'; //where is the websocket server 
$port = 8575; 
$local = "http://mypc"; //url where this script run 
$data = "first message"; //data to be send 

$head = "GET/HTTP/1.1"."\r\n". 
     "Upgrade: WebSocket"."\r\n". 
     "Connection: Upgrade"."\r\n". 
     "Origin: $local"."\r\n". 
     "Host: $host"."\r\n". 
     "Sec-WebSocket-Key: asdasdaas76da7sd6asd6as7d"."\r\n". 
     "Content-Length: ".strlen($data)."\r\n"."\r\n"; 
//WebSocket handshake 
$sock = fsockopen($host, $port, $errno, $errstr, 2); 
fwrite($sock, $head) or die('error:'.$errno.':'.$errstr); 
$headers = fread($sock, 2000); 
echo $headers; 
fwrite($sock, hybi10Encode($data)) or die('error:'.$errno.':'.$errstr); 
$wsdata = fread($sock, 2000); 
var_dump(hybi10Decode($wsdata)); 
fclose($sock); 


function hybi10Decode($data) 
{ 
    $bytes = $data; 
    $dataLength = ''; 
    $mask = ''; 
    $coded_data = ''; 
    $decodedData = ''; 
    $secondByte = sprintf('%08b', ord($bytes[1])); 
    $masked = ($secondByte[0] == '1') ? true : false; 
    $dataLength = ($masked === true) ? ord($bytes[1]) & 127 : ord($bytes[1]); 

    if($masked === true) 
    { 
     if($dataLength === 126) 
     { 
      $mask = substr($bytes, 4, 4); 
      $coded_data = substr($bytes, 8); 
     } 
     elseif($dataLength === 127) 
     { 
      $mask = substr($bytes, 10, 4); 
      $coded_data = substr($bytes, 14); 
     } 
     else 
     { 
      $mask = substr($bytes, 2, 4);  
      $coded_data = substr($bytes, 6);   
     } 
     for($i = 0; $i < strlen($coded_data); $i++) 
     {  
      $decodedData .= $coded_data[$i]^$mask[$i % 4]; 
     } 
    } 
    else 
    { 
     if($dataLength === 126) 
     {   
      $decodedData = substr($bytes, 4); 
     } 
     elseif($dataLength === 127) 
     {   
      $decodedData = substr($bytes, 10); 
     } 
     else 
     {    
      $decodedData = substr($bytes, 2);  
     }  
    } 

    return $decodedData; 
} 


function hybi10Encode($payload, $type = 'text', $masked = true) { 
    $frameHead = array(); 
    $frame = ''; 
    $payloadLength = strlen($payload); 

    switch ($type) { 
     case 'text': 
      // first byte indicates FIN, Text-Frame (10000001): 
      $frameHead[0] = 129; 
      break; 

     case 'close': 
      // first byte indicates FIN, Close Frame(10001000): 
      $frameHead[0] = 136; 
      break; 

     case 'ping': 
      // first byte indicates FIN, Ping frame (10001001): 
      $frameHead[0] = 137; 
      break; 

     case 'pong': 
      // first byte indicates FIN, Pong frame (10001010): 
      $frameHead[0] = 138; 
      break; 
    } 

    // set mask and payload length (using 1, 3 or 9 bytes) 
    if ($payloadLength > 65535) { 
     $payloadLengthBin = str_split(sprintf('%064b', $payloadLength), 8); 
     $frameHead[1] = ($masked === true) ? 255 : 127; 
     for ($i = 0; $i < 8; $i++) { 
      $frameHead[$i + 2] = bindec($payloadLengthBin[$i]); 
     } 

     // most significant bit MUST be 0 (close connection if frame too big) 
     if ($frameHead[2] > 127) { 
      $this->close(1004); 
      return false; 
     } 
    } elseif ($payloadLength > 125) { 
     $payloadLengthBin = str_split(sprintf('%016b', $payloadLength), 8); 
     $frameHead[1] = ($masked === true) ? 254 : 126; 
     $frameHead[2] = bindec($payloadLengthBin[0]); 
     $frameHead[3] = bindec($payloadLengthBin[1]); 
    } else { 
     $frameHead[1] = ($masked === true) ? $payloadLength + 128 : $payloadLength; 
    } 

    // convert frame-head to string: 
    foreach (array_keys($frameHead) as $i) { 
     $frameHead[$i] = chr($frameHead[$i]); 
    } 

    if ($masked === true) { 
     // generate a random mask: 
     $mask = array(); 
     for ($i = 0; $i < 4; $i++) { 
      $mask[$i] = chr(rand(0, 255)); 
     } 

     $frameHead = array_merge($frameHead, $mask); 
    } 
    $frame = implode('', $frameHead); 
    // append payload to frame: 
    for ($i = 0; $i < $payloadLength; $i++) { 
     $frame .= ($masked === true) ? $payload[$i]^$mask[$i % 4] : $payload[$i]; 
    } 

    return $frame; 
} 

?> 

Answer 2

Nessuno dei precedenti è una buona risposta. Molti di loro riguardano un server, mentre la domanda riguarda un cliente. Il codice di Rodislav non ha funzionato per me, dal momento che non parlava al mio server WebSockets su Heroku. Tuttavia, questa libreria ha funzionato molto bene:

https://github.com/Devristo/phpws

UPDATE: Anche se questo codice ha funzionato quando tutto andava bene, sembra che ci sia nessun ritorni di errore o eccezioni a tutti, e di conseguenza è inutilizzabile quando c'è un errore (ad esempio, il server non è in esecuzione, l'indirizzo è errato, la porta è bloccata, ecc.). Quindi, mentre è stato divertente sperimentare, non è utilizzabile nel codice di produzione.

Answer 3

Questa libreria sembra piuttosto buono, se sei ok con le dipendenze: https://github.com/gabrielbull/php-websocket-client

Answer 4

Una libreria PHP websocket con un esempio di applicazione di chat. Con demo e descrizione completa dell'implementazione.

http://www.techzonemind.com/php-websocket-library-two-way-real-time-communication/

Answer 5

Ho cercato di usare molti di quanto sopra da includere nel tivoka (JSON-RPC), ma o non era buono abbastanza leggere i pacchetti più grandi (non ottenere l'intera struttura o la lettura in quella successiva) o aveva grandi dipendenze.

Così, ho scritto https://github.com/Textalk/websocket-php

Invece di prima lettura tutti i dati disponibili dalla presa e poi la decodifica, si legge l'intestazione del telaio e analizza la lunghezza di carico utile, e quindi i carichi proprio questo.

Manca il supporto ping/pong, ma penso che faccia buona parte delle altre cose. Funziona bene con tivoka ed è autotest almeno al 92% :) Potrebbero essere necessarie alcune funzioni extra per verificare se c'è un altro frame senza leggerlo.

Fatemi sapere cosa ne pensate.