111

我正在寻找一个简单的代码来创建一个 WebSocket 服务器。我找到了 phpwebsockets，但它现在已经过时并且不支持最新的协议。我尝试自己更新它，但它似乎不起作用。

#!/php -q
<?php  /*  >php -q server.php  */

error_reporting(E_ALL);
set_time_limit(0);
ob_implicit_flush();

$master  = WebSocket("localhost",12345);
$sockets = array($master);
$users   = array();
$debug   = false;

while(true){
  $changed = $sockets;
  socket_select($changed,$write=NULL,$except=NULL,NULL);
  foreach($changed as $socket){
    if($socket==$master){
      $client=socket_accept($master);
      if($client<0){ console("socket_accept() failed"); continue; }
      else{ connect($client); }
    }
    else{
      $bytes = @socket_recv($socket,$buffer,2048,0);
      if($bytes==0){ disconnect($socket); }
      else{
        $user = getuserbysocket($socket);
        if(!$user->handshake){ dohandshake($user,$buffer); }
        else{ process($user,$buffer); }
      }
    }
  }
}

//---------------------------------------------------------------
function process($user,$msg){
  $action = unwrap($msg);
  say("< ".$action);
  switch($action){
    case "hello" : send($user->socket,"hello human");                       break;
    case "hi"    : send($user->socket,"zup human");                         break;
    case "name"  : send($user->socket,"my name is Multivac, silly I know"); break;
    case "age"   : send($user->socket,"I am older than time itself");       break;
    case "date"  : send($user->socket,"today is ".date("Y.m.d"));           break;
    case "time"  : send($user->socket,"server time is ".date("H:i:s"));     break;
    case "thanks": send($user->socket,"you're welcome");                    break;
    case "bye"   : send($user->socket,"bye");                               break;
    default      : send($user->socket,$action." not understood");           break;
  }
}

function send($client,$msg){
  say("> ".$msg);
  $msg = wrap($msg);
  socket_write($client,$msg,strlen($msg));
}

function WebSocket($address,$port){
  $master=socket_create(AF_INET, SOCK_STREAM, SOL_TCP)     or die("socket_create() failed");
  socket_set_option($master, SOL_SOCKET, SO_REUSEADDR, 1)  or die("socket_option() failed");
  socket_bind($master, $address, $port)                    or die("socket_bind() failed");
  socket_listen($master,20)                                or die("socket_listen() failed");
  echo "Server Started : ".date('Y-m-d H:i:s')."\n";
  echo "Master socket  : ".$master."\n";
  echo "Listening on   : ".$address." port ".$port."\n\n";
  return $master;
}

function connect($socket){
  global $sockets,$users;
  $user = new User();
  $user->id = uniqid();
  $user->socket = $socket;
  array_push($users,$user);
  array_push($sockets,$socket);
  console($socket." CONNECTED!");
}

function disconnect($socket){
  global $sockets,$users;
  $found=null;
  $n=count($users);
  for($i=0;$i<$n;$i++){
    if($users[$i]->socket==$socket){ $found=$i; break; }
  }
  if(!is_null($found)){ array_splice($users,$found,1); }
  $index = array_search($socket,$sockets);
  socket_close($socket);
  console($socket." DISCONNECTED!");
  if($index>=0){ array_splice($sockets,$index,1); }
}

function dohandshake($user,$buffer){
  console("\nRequesting handshake...");
  console($buffer);
  //list($resource,$host,$origin,$strkey1,$strkey2,$data) 
  list($resource,$host,$u,$c,$key,$protocol,$version,$origin,$data) = getheaders($buffer);
  console("Handshaking...");

    $acceptkey = base64_encode(sha1($key . "258EAFA5-E914-47DA-95CA-C5AB0DC85B11",true));
  $upgrade  = "HTTP/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: $acceptkey\r\n";

  socket_write($user->socket,$upgrade,strlen($upgrade));
  $user->handshake=true;
  console($upgrade);
  console("Done handshaking...");
  return true;
}

function getheaders($req){
    $r=$h=$u=$c=$key=$protocol=$version=$o=$data=null;
    if(preg_match("/GET (.*) HTTP/"   ,$req,$match)){ $r=$match[1]; }
    if(preg_match("/Host: (.*)\r\n/"  ,$req,$match)){ $h=$match[1]; }
    if(preg_match("/Upgrade: (.*)\r\n/",$req,$match)){ $u=$match[1]; }
    if(preg_match("/Connection: (.*)\r\n/",$req,$match)){ $c=$match[1]; }
    if(preg_match("/Sec-WebSocket-Key: (.*)\r\n/",$req,$match)){ $key=$match[1]; }
    if(preg_match("/Sec-WebSocket-Protocol: (.*)\r\n/",$req,$match)){ $protocol=$match[1]; }
    if(preg_match("/Sec-WebSocket-Version: (.*)\r\n/",$req,$match)){ $version=$match[1]; }
    if(preg_match("/Origin: (.*)\r\n/",$req,$match)){ $o=$match[1]; }
    if(preg_match("/\r\n(.*?)\$/",$req,$match)){ $data=$match[1]; }
    return array($r,$h,$u,$c,$key,$protocol,$version,$o,$data);
}

function getuserbysocket($socket){
  global $users;
  $found=null;
  foreach($users as $user){
    if($user->socket==$socket){ $found=$user; break; }
  }
  return $found;
}

function     say($msg=""){ echo $msg."\n"; }
function    wrap($msg=""){ return chr(0).$msg.chr(255); }
function  unwrap($msg=""){ return substr($msg,1,strlen($msg)-2); }
function console($msg=""){ global $debug; if($debug){ echo $msg."\n"; } }

class User{
  var $id;
  var $socket;
  var $handshake;
}

?>

和客户：

var connection = new WebSocket('ws://localhost:12345');
connection.onopen = function () {
  connection.send('Ping'); // Send the message 'Ping' to the server
};

// Log errors
connection.onerror = function (error) {
  console.log('WebSocket Error ' + error);
};

// Log messages from the server
connection.onmessage = function (e) {
  console.log('Server: ' + e.data);
};

如果我的代码有任何问题，你能帮我解决吗？Firefox 中的 Concole 说

Firefox 无法与位于 ws://localhost:12345/ 的服务器建立连接。

4

6 回答 6

148

我最近和你在同一条船上，这就是我所做的：

  1. 我使用phpwebsockets代码作为如何构建服务器端代码的参考。（您似乎已经这样做了，正如您所指出的，由于各种原因，该代码实际上并不能正常工作。）

  2. 我使用 PHP.net 阅读了有关phpwebsockets 代码中使用的每个套接字函数的详细信息。通过这样做，我终于能够从概念上理解整个系统是如何工作的。这是一个相当大的障碍。

  3. 我阅读了实际的WebSocket 草案。在它最终开始深入理解之前，我不得不读了很多遍。在整个过程中，你可能不得不一次又一次地回到这个文档，因为它是一个具有正确、最新的权威资源有关 WebSocket API 的信息。

  4. 我根据#3 中草稿中的说明编写了正确的握手程序。这还不错。

  5. 握手后，我不断收到从客户端发送到服务器的一堆乱码文本，直到我意识到数据已编码并且必须取消屏蔽，我才弄清楚为什么。以下链接在这里帮助了我很多：（原链接坏了)存档副本。

    请注意，此链接上提供的代码存在许多问题，如果不进一步修改将无法正常工作。

  6. 然后我遇到了以下 SO 线程，它清楚地解释了如何正确编码和解码来回发送的消息：如何在服务器端发送和接收 WebSocket 消息？

    这个链接真的很有帮助。我建议在查看 WebSocket 草案时查阅它。这将有助于更好地理解草案所说的内容。

  7. 此时我几乎完成了，但是我使用 WebSocket 制作的 WebRTC 应用程序出现了一些问题，所以我最终在 SO 上提出了自己的问题，我最终解决了这个问题：WebRTC 候选信息末尾的这些数据是什么？

  8. 在这一点上，我几乎已经完成了所有工作。我只需要添加一些额外的逻辑来处理连接的关闭，我就完成了。

这个过程总共花了我大约两周时间。好消息是我现在非常了解 WebSocket，并且我能够从头开始制作我自己的客户端和服务器脚本，它们运行良好。希望所有这些信息的高潮将为您提供足够的指导和信息来编写您自己的 WebSocket PHP 脚本。

祝你好运！

编辑：这个编辑是在我最初的回答之后的几年，虽然我仍然有一个可行的解决方案，但它还没有真正准备好分享。幸运的是，GitHub 上的其他人的代码与我的几乎相同（但更简洁），因此我建议使用以下代码作为有效的 PHP WebSocket 解决方案：
https ://github.com/ghedipunk/PHP-Websockets/blob/master/ websockets.php

编辑#2：虽然我仍然喜欢将 PHP 用于许多与服务器端相关的事情，但我不得不承认我最近对 ​​Node.js 非常感兴趣，主要原因是因为它的设计更好比 PHP（或任何其他服务器端语言）更能处理 WebSocket。因此，我最近发现在您的服务器上设置 Apache/PHP 和 Node.js 并使用 Node.js 运行 WebSocket 服务器和使用 Apache/PHP 运行其他一切要容易得多。如果您处于无法安装/使用 Node.js for WebSocket 的共享托管环境中，您可以使用Heroku等免费服务设置 Node.js WebSocket 服务器并从您的服务器向它发出跨域请求。只要确保您这样做是为了将您的 WebSocket 服务器设置为能够处理跨域请求。

于 2013-01-25T04:11:22.737 回答
32

据我所知，Ratchet是目前最好的 PHP WebSocket 解决方案。由于它是开源的，您可以看到作者是如何使用 PHP 构建这个 WebSocket 解决方案的。

于 2013-01-25T11:27:04.353 回答
7

我已经在几个小时内搜索了可能执行 PHP + WebSockets 的最小解决方案，直到找到这篇文章：

超级简单的 PHP WebSocket 示例

它不需要任何第三方库。

下面是如何做到这一点：创建一个index.html包含这个：

<html>
<body>
    <div id="root"></div>
    <script>
        var host = 'ws://<<<IP_OF_YOUR_SERVER>>>:12345/websockets.php';
        var socket = new WebSocket(host);
        socket.onmessage = function(e) {
            document.getElementById('root').innerHTML = e.data;
        };
    </script>
</body>
</html>

并在浏览器中打开它，就在你php websockets.php在命令行中启动之后（是的，这将是一个事件循环，不断运行 PHP 脚本），带有这个websockets.php文件。

于 2021-01-30T23:19:28.873 回答
3

需要在 base64_encoding 之前将密钥从十六进制转换为十进制，然后发送以进行握手。

$hashedKey = sha1($key. "258EAFA5-E914-47DA-95CA-C5AB0DC85B11",true);

$rawToken = "";
    for ($i = 0; $i < 20; $i++) {
      $rawToken .= chr(hexdec(substr($hashedKey,$i*2, 2)));
    }
$handshakeToken = base64_encode($rawToken) . "\r\n";

$handshakeResponse = "HTTP/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: $handshakeToken\r\n";
于 2016-12-11T09:12:01.037 回答
2

我在你的鞋子里呆了一段时间，最后最终使用了 node.js，因为它可以做混合解决方案，比如将 Web 和套接字服务器合二为一。所以php后端可以通过http向节点web服务器提交请求，然后用websocket广播它。非常有效的方法。

于 2019-02-22T15:52:04.217 回答
-5 
<?php

// server.php

$server = stream_socket_server("tcp://127.0.0.1:8001", $errno, $errorMessage);

if($server == false) {
    throw new Exception("Could not bind to socket: $errorMessage");

}

for(;;) {
    $client = @stream_socket_accept($server);

    if($client) {
        stream_copy_to_stream($client, $client);
        fclose($client);
    }
}

从一个终端运行：php server.php

从另一个终端运行：echo "hello woerld" | 数控 127.0.0.1 8002

于 2013-11-30T15:21:10.073 回答