PHP中Socket服务器搭建和测试方法教程

<?php/** * Socket服务器 * @author wuchangliang 2018/1/17 */class SocketServer{    private $sockets; //连接池    private $master;    private $handshake;    /**     * @param $address     * @param $port     */    public function run($address, $port)    {        //配置错误级别、运行时间、刷新缓冲区        echo iconv('UTF-8', 'GBK', "欢迎来到PHP Socket测试服务。 \n");        error_reporting(0);        set_time_limit(0);        ob_implicit_flush();        //创建socket        $this->master = $this->_connect($address, $port);        $this->sockets[] = $this->master;        //运行socket        while (true) {            $sockets = $this->sockets;            $write = NULL;            $except = NULL;            socket_select($sockets, $write, $except, NULL); //$write,$except传引用            foreach ($sockets as $socket) {                if ($socket == $this->master) {                    $client = socket_accept($socket);                    $this->handshake = false;                    if ($client) {                        $this->sockets[] = $client; //加入连接池                    }                } else {                    //接收信息                    $bytes = @socket_recv($socket, $buffer, 2048, 0);                    if ($bytes <= 6) {                        $this->_disConnect($socket);                        continue;                    };                    //处理信息                    if (!$this->handshake) {                        $this->_handshake($socket, $buffer);                    } else {                        $buffer = $this->_decode($buffer);                        $this->_sendMsg($buffer, $socket);                    }                }            }        }    }    /**     * 创建socket连接     * @param $address     * @param $port     * @return resource     */    private function _connect($address, $port)    {        //创建socket        $master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)        or die("socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n");        socket_bind($master, $address, $port)        or die("socket_bind() failed: reason: " . socket_strerror(socket_last_error($master)) . "\n");        socket_listen($master, 5)        or die("socket_listen() failed: reason: " . socket_strerror(socket_last_error($master)) . "\n");        return $master;    }    /**     * 握手动作     * @param $socket     * @param $buffer     */    private function _handshake($socket, $buffer)    {        //握手动作信息        $buf = substr($buffer, strpos($buffer, 'Sec-WebSocket-Key:') + 18);        $key = trim(substr($buf, 0, strpos($buf, "\r\n")));        $new_key = base64_encode(sha1($key . "258EAFA5-E914-47DA-95CA-C5AB0DC85B11", true));        $new_message = "HTTP/1.1 101 Switching Protocols\r\n";        $new_message .= "Upgrade: websocket\r\n";        $new_message .= "Sec-WebSocket-Version: 13\r\n";        $new_message .= "Connection: Upgrade\r\n";        $new_message .= "Sec-WebSocket-Accept: " . $new_key . "\r\n\r\n";        //记录握手动作        socket_write($socket, $new_message, strlen($new_message));        $this->handshake = true;    }    /**     * 断开socket连接     * @param $socket     */    private function _disConnect($socket)    {        $index = array_search($socket, $this->sockets);        socket_close($socket);        if ($index >= 0) {            array_splice($this->sockets, $index, 1);        }    }    /**     * 发送信息     * @param $buffer     * @param $client     */    private function _sendMsg($buffer, $client)    {        $send_buffer = $this->_frame(json_encode($buffer));        foreach ($this->sockets as $socket) {            if ($socket != $this->master && $socket != $client) { //广播发送（除了自己）                socket_write($socket, $send_buffer, strlen($send_buffer));            }        }    }    /**     * 解析数据帧     * @param $buffer     * @return null|string     */    private function _decode($buffer)    {        $len = $masks = $data = $decoded = null;        $len = ord($buffer[1]) & 127;        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;    }    /**     * 处理返回帧     * @param $buffer     * @return string     */    private function _frame($buffer)    {        $len = strlen($buffer);        if ($len <= 125) {            return "\x81" . chr($len) . $buffer;        } else if ($len <= 65535) {            return "\x81" . chr(126) . pack("n", $len) . $buffer;        } else {            return "\x81" . char(127) . pack("xxxxN", $len) . $buffer;        }    }}$sc = new SocketServer();$sc->run('127.0.0.1', 2046);

<!DOCTYPE html><html><head>    <meta charset="utf-8" />    <title>WebSocket Test</title>    <script language="javascript"type="text/javascript">        websocket = new WebSocket('ws://127.0.0.1:2046/');        websocket.onopen = function(evt) {            console.log('connect');            websocket.send('{"data":"您好，世界！"}');        };        websocket.onclose = function(evt) {            console.log('onclose');            console.log(evt);        };        websocket.onmessage = function(evt) {            console.log('onmessage');            if (evt.data) {                console.log(JSON.parse(JSON.parse(evt.data)));            }        };        websocket.onerror = function(evt) {            console.log('onerror');            console.log(evt);        };        function sendMsg(){            var sendData = { 'data': document.getElementById('name').value};            websocket.send(JSON.stringify(sendData));        }    </script></head><body>    <h2>WebSocket Test</h2>    <input type="text" name="name" id="name" />    <a href="javascript:;" onclick="sendMsg()">点击发送</a></body></html>