PHP WebSocket 客户端类 WebSocketClient
程序员文章站
2023-12-24 23:04:03
...
* @version 2011-10-18 */class WebSocketClient{ private $_host; private $_port; private $_path; private $_origin; private $_Socket = null; private $_connected = false; public function __construct() { } public function __destruct() { $this->disconnect(); } public function sendData($data, $type = 'text', $masked = true) { if($this->_connected === false) { trigger_error("Not connected", E_USER_WARNING); return false; } if( !is_string($data)) { trigger_error("Not a string data was given.", E_USER_WARNING); return false; } if (strlen($data) == 0) { return false; } $res = @fwrite($this->_Socket, $this->_hybi10Encode($data, $type, $masked)); if($res === 0 || $res === false) { return false; } $buffer = ' '; while($buffer !== '') { $buffer = fread($this->_Socket, 512); } return true; } public function connect($host, $port, $path, $origin = false) { $this->_host = $host; $this->_port = $port; $this->_path = $path; $this->_origin = $origin; $key = base64_encode($this->_generateRandomString(16, false, true)); $header = "GET " . $path . " HTTP/1.1\r\n"; $header.= "Host: ".$host.":".$port. "\r\n"; $header.= "Upgrade: websocket\r\n"; $header.= "Connection: Upgrade\r\n"; //$header.= "Sec-WebSocket-Extensions: permessage-deflate; client_max_window_bits\r\n"; $header.= "Sec-WebSocket-Key: " . $key . "\r\n"; if($origin !== false) { $header.= "Sec-WebSocket-Origin: " . $origin . "\r\n"; } $header.= "Sec-WebSocket-Version: 13\r\n\r\n"; $this->_Socket = fsockopen($host, $port, $errno, $errstr, 2); socket_set_timeout($this->_Socket, 2, 10000); //socket_write($this->_Socket, $header); $res = @fwrite($this->_Socket, $header); if( $res === false ){ echo "fwrite false \n"; } $response = @fread($this->_Socket, 1500); //$response = socket_read($this->_Socket); preg_match('#Sec-WebSocket-Accept:\s(.*)$#mU', $response, $matches); if ($matches) { $keyAccept = trim($matches[1]); $expectedResonse = base64_encode(pack('H*', sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11'))); $this->_connected = ($keyAccept === $expectedResonse) ? true : false; } return $this->_connected; } public function checkConnection() { $this->_connected = false; // send ping: $data = 'ping?'; @fwrite($this->_Socket, $this->_hybi10Encode($data, 'ping', true)); $response = @fread($this->_Socket, 300); if(empty($response)) { return false; } $response = $this->_hybi10Decode($response); if(!is_array($response)) { return false; } if(!isset($response['type']) || $response['type'] !== 'pong') { return false; } $this->_connected = true; return true; } public function disconnect() { $this->_connected = false; is_resource($this->_Socket) and fclose($this->_Socket); } public function reconnect() { sleep(10); $this->_connected = false; fclose($this->_Socket); $this->connect($this->_host, $this->_port, $this->_path, $this->_origin); } private function _generateRandomString($length = 10, $addSpaces = true, $addNumbers = true) { $characters = 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ!"ยง$%&/()=[]{}'; $useChars = array(); // select some random chars: for($i = 0; $i 65535) { $payloadLengthBin = str_split(sprintf('%064b', $payloadLength), 8); $frameHead[1] = ($masked === true) ? 255 : 127; for($i = 0; $i 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
使用示例:
// 使用 WebSocket 通知客户端 $client = new \Common\Library\WebSocketClient(); $client->connect($_SERVER['HTTP_HOST'], 943, '/'); $payload = json_encode(array( 'code' => 'xxx', 'id' => '1' )); $rs = $client->sendData($payload); if( $rs !== true ){ echo "sendData error...\n"; }else{ echo "ok\n"; }
来自: http://my.oschina.net/skq/blog/552923