如何使用Swoole实现WebSocket服务器

开发运维 2023-08-04 捡田螺的小男孩手机阅读

WebSocket已经成为现代Web应用程序中的基本元素。它提供一种全双工的通信方式，使得服务器和客户端之间可以实现实时通信。Swoole是一个基于PHP的高性能网络通信框架，它可以非常方便地实现WebSocket服务器。

本文将介绍如何使用Swoole构建WebSocket服务器。

pecl install swoole登录后复制

$server = new SwooleWebsocketServer("127.0.0.1", 9501); $server->on('open', function (SwooleWebsocketServer $server, $request) { echo "Client {$request->fd} connected "; }); $server->on('message', function (SwooleWebsocketServer $server, $frame) { echo "Received message: {$frame->data} "; // Broadcast message to all connected clients foreach ($server->connections as $fd) { $server->push($fd, $frame->data); } }); $server->on('close', function (SwooleWebsocketServer $server, $fd) { echo "Client {$fd} disconnected "; }); $server->start();登录后复制

open - 当新的WebSocket客户端连接到服务器时，将被调用。
message - 当服务器接收到来自客户端的消息时，将被调用。
close - 当客户端断开连接时，将被调用。

在open函数中，我们向控制台输出一个简单的消息，提示我们已经连接了一个新的客户端。

在message函数中，我们向控制台输出接收到的消息，并向所有已连接的客户端广播此消息。

在close函数中，我们向控制台输出一个消息，提示已断开连接的客户端的fd。

最后，我们通过调用start方法启动WebSocket服务器。

// Connect to WebSocket server const ws = new WebSocket('ws://127.0.0.1:9501'); // Send a message to the server ws.onopen = function() { ws.send('Hello, server!'); }; // Receive a message from the server ws.onmessage = function(event) { console.log('Received message:', event.data); };登录后复制