PHP 函数如何使用 WebSockets 调用外部函数？

function myFunction($param) {
  // 函数逻辑
}

// 使用 Ratchet 作为示例

use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
use React\Promise\Deferred;

class WebSocketServer implements MessageComponentInterface {
  private $deferred = []; // 存储挂起的请求

  public function onOpen(ConnectionInterface $conn) {
    // 处理连接建立
  }

  public function onMessage(ConnectionInterface $conn, $msg) {
    try {
      // 解析消息
      $data = json_decode($msg);

      if (isset($data->function) && isset($data->param)) {
        // 从 deferred 中获取挂起的请求
        $deferred = $this->deferred[$conn->resourceId];

        // 调用外部函数
        $result = myFunction($data->param);

        // 返回结果
        $deferred->resolve($result);
      }
    } catch (Exception $e) {
      // 处理异常
    }
  }

  public function onClose(ConnectionInterface $conn) {
    // 处理连接关闭
  }

  public function onError(ConnectionInterface $conn, \Exception $e) {
    // 处理连接错误
  }
}

// 使用 WebSocket 客户端建立连接

const ws = new WebSocket("ws://localhost:8080");

ws.addEventListener("open", () => {
  // 创建请求对象
  const request = {
    function: "myFunction",
    param: "someParam",
  };

  // 发送请求
  ws.send(JSON.stringify(request));
});

ws.addEventListener("message", (event) => {
  // 处理返回的结果
  console.log(JSON.parse(event.data));
});

// 设置 WebSocket 服务器
$ws = new WebSocketServer();
$ws->setName("WebSocket Server");

// 创建 WebSocket 监听器
$app = new Ratchet\App("localhost", 8080, "0.0.0.0");
$app->route("/", $ws);
$app->run();

// 设置 WebSocket 客户端
const ws = new WebSocket("ws://localhost:8080");

// 处理请求和响应
ws.addEventListener("open", () => {
  const request = {
    function: "myFunction",
    param: "someParam",
  };

  ws.send(JSON.stringify(request));
});

ws.addEventListener("message", (event) => {
  console.log(JSON.parse(event.data));
});