要实现php的websocket服务，必须使用异步i/o框架突破传统请求-响应模式的限制，1. 可通过ratchet等库创建常驻内存的php进程来监听端口并处理长连接；2. ratchet依赖reactphp的事件循环机制，采用分层架构（ioserver、httpserver、wsserver）实现非阻塞i/o和事件驱动的消息处理；3. 生产环境部署需使用supervisor或systemd确保进程常驻，4. 通过nginx做反向代理并配置粘性会话实现负载均衡，5. 启用ssl/tls（wss://）并在前端反向代理处进行ssl卸载以保障通信安全，6. 对消息进行输入验证与过滤以防范xss和注入攻击，7. 将用户认证与授权机制集成到websocket服务中，8. 利用redis pub/sub或rabbitmq等消息队列实现websocket服务与传统php应用之间的解耦通信，9. 配置监控和日志系统以实时跟踪连接数、资源使用情况和错误信息，从而确保服务的稳定性、安全性与可扩展性。
PHP要实现WebSocket服务，确实不能沿用传统的请求-响应模式。通常我们会借助一些PHP的异步I/O框架来突破这一限制，比如Swoole、Workerman，或者像Ratchet这样专注于WebSocket的库。Ratchet提供了一个相对轻量级且易于上手的解决方案，它允许PHP脚本长时间运行并处理实时通信，这和我们平时接触的PHP-FPM模型完全不同。
使用Ratchet构建一个WebSocket服务，核心在于创建一个常驻内存的PHP进程来监听端口并处理连接。下面是一个基本的Ratchet应用实例：
首先，你需要通过Composer安装Ratchet：
立即学习“PHP免费学习笔记（深入）”；
composer require cboden/ratchet
接下来，我们创建一个WebSocket服务器脚本，比如命名为
server.php
<?php
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
require __DIR__ . '/vendor/autoload.php';
// 这是我们自定义的WebSocket消息处理组件
class MyWebSocketServer implements MessageComponentInterface {
protected $clients; // 用于存储所有连接的客户端
public function __construct() {
$this->clients = new \SplObjectStorage; // SplObjectStorage 是一个高效存储对象的结构
echo "WebSocket服务器启动...\n";
}
// 当有新连接打开时触发
public function onOpen(ConnectionInterface $conn) {
$this->clients->attach($conn); // 将新连接添加到客户端列表中
echo "新连接! ({$conn->resourceId})\n";
}
// 当接收到客户端发送的消息时触发
public function onMessage(ConnectionInterface $from, $msg) {
$numRecv = count($this->clients) - 1;
echo sprintf('连接 %d 发送消息 "%s" 到 %d 个其他连接' . "\n"
, $from->resourceId, $msg, $numRecv);
// 遍历所有连接的客户端，将消息广播出去
foreach ($this->clients as $client) {
if ($from !== $client) { // 不发送给自己
$client->send($msg);
}
}
}
// 当连接关闭时触发
public function onClose(ConnectionInterface $conn) {
$this->clients->detach($conn); // 从客户端列表中移除连接
echo "连接 {$conn->resourceId} 已断开\n";
}
// 当发生错误时触发
public function onError(ConnectionInterface $conn, \Exception $e) {
echo "发生错误: {$e->getMessage()}\n";
$conn->close(); // 关闭出错的连接
}
}
// 组合各个层级来创建一个完整的WebSocket服务器
// IoServer 是最底层的I/O服务器，监听端口
// HttpServer 将HTTP请求（包括WebSocket握手）路由到WsServer
// WsServer 处理WebSocket协议的握手和帧解析
$server = IoServer::factory(
new HttpServer(
new WsServer(
new MyWebSocketServer() // 我们的自定义消息处理组件
)
),
8080 // 监听8080端口
);
$server->run(); // 启动服务器然后，你需要一个简单的HTML/JavaScript客户端来连接和测试这个WebSocket服务。创建一个
client.html
<!DOCTYPE html>
<html>
<head>
<title>WebSocket 客户端</title>
<style>
body { font-family: sans-serif; margin: 20px; }
#messages { border: 1px solid #ccc; padding: 10px; min-height: 150px; overflow-y: auto; margin-bottom: 10px; }
input[type="text"] { width: 80%; padding: 8px; }
button { padding: 8px 15px; }
</style>
</head>
<body>
<h1>WebSocket 聊天室</h1>
<div id="messages"></div>
<input type="text" id="messageInput" placeholder="输入消息..." />
<button onclick="sendMessage()">发送</button>
<script>
// 注意：这里使用 ws://localhost:8080，如果你的服务器IP或端口不同，请修改
const ws = new WebSocket('ws://localhost:8080');
const messagesDiv = document.getElementById('messages');
const messageInput = document.getElementById('messageInput');
ws.onopen = function(event) {
messagesDiv.innerHTML += '<p style="color: green;">连接成功！</p>';
};
ws.onmessage = function(event) {
messagesDiv.innerHTML += '<p><strong>收到:</strong> ' + event.data + '</p>';
messagesDiv.scrollTop = messagesDiv.scrollHeight; // 滚动到底部
};
ws.onclose = function(event) {
messagesDiv.innerHTML += '<p style="color: red;">连接已断开。</p>';
};
ws.onerror = function(event) {
messagesDiv.innerHTML += '<p style="color: red;">发生错误！</p>';
};
function sendMessage() {
const message = messageInput.value;
if (message) {
ws.send(message);
messagesDiv.innerHTML += '<p style="color: blue;"><strong>我:</strong> ' + message + '</p>';
messageInput.value = '';
messagesDiv.scrollTop = messagesDiv.scrollHeight;
}
}
messageInput.addEventListener('keypress', function(e) {
if (e.key === 'Enter') {
sendMessage();
}
});
</script>
</body>
</html>要运行这个例子，打开你的终端，进入
server.php
php server.php
服务器启动后，你会在终端看到 "WebSocket服务器启动..."。 接着，在浏览器中打开
client.html
这其实是个关于Web工作模式的根本性差异。传统的PHP应用，尤其是基于Apache/Nginx + PHP-FPM（或mod_php）的架构，是典型的“请求-响应”模型。每次浏览器发出HTTP请求，服务器上的PHP脚本就会被执行一次，生成HTML、JSON等内容，然后将结果返回给浏览器，整个PHP进程就结束了。这是一个无状态的、短生命周期的过程。
WebSocket则完全不同，它需要的是一个持久的、双向的通信通道。一旦握手成功，客户端和服务器之间会建立一条“长连接”，数据可以在任何一方准备好时随时发送，而不需要每次都重新发起HTTP请求。这种长连接的特性，与传统PHP的“执行一次就退出”的哲学是格格不入的。PHP-FPM池中的进程设计初衷就是处理完一个请求就释放资源，以便快速响应下一个新请求，它无法保持一个连接长时间开放并等待后续的数据传输。所以，要实现WebSocket，我们必须跳出这个传统框架，让PHP进程能够常驻内存，并且具备处理并发连接的能力。
Ratchet能够让PHP实现WebSocket，其核心秘密在于它利用了底层的事件驱动和非阻塞I/O模型。简单来说，它不是通过为每个连接创建一个新的PHP进程来工作，而是通过一个单一的（或少数几个）PHP进程，使用事件循环（Event Loop）来高效管理大量的并发连接。
Ratchet底层依赖于 ReactPHP 这个库，ReactPHP提供了一个强大的事件循环，类似于Node.js的事件循环机制。当一个WebSocket连接建立后，它会被注册到这个事件循环中。当有数据从某个连接到达时，或者需要向某个连接发送数据时，事件循环会通知Ratchet，然后Ratchet会调用相应的回调函数（比如
onMessage
具体到Ratchet的结构，它通常由几个组件层层包裹：
IoServer
HttpServer
HttpServer
WsServer
MessageComponentInterface
MyWebSocketServer
onOpen
onMessage
onClose
onError
通过这种分层和事件驱动的机制，Ratchet避免了传统PHP的阻塞式I/O和短生命周期问题，使得PHP也能高效地处理实时、双向的WebSocket通信。
将Ratchet服务部署到生产环境，远不止
php server.php
一个很实际的问题是，如果服务器重启了，或者Ratchet进程崩溃了，服务就中断了。因此，你需要一个进程管理器来确保Ratchet服务始终运行。
Supervisor
systemd
对于高并发和可伸缩性，单个Ratchet进程虽然能处理大量连接，但PHP毕竟是单线程的（在Ratchet这个上下文里），它无法充分利用多核CPU。当连接数或消息吞吐量达到瓶颈时，你就需要水平扩展。这意味着运行多个Ratchet实例，每个实例监听不同的端口，或者通过负载均衡器（如Nginx）将流量分发到多个Ratchet实例。Nginx可以作为反向代理，将
ws://
wss://
安全性是另一个重要方面。在生产环境中，你几乎总是需要使用
wss://
ws://
与现有PHP应用集成也是一个常见的挑战。你的传统Web应用（如Laravel、Symfony）和Ratchet WebSocket服务是两个独立的进程。它们之间如何通信？例如，当传统Web应用中某个事件发生时（如新订单），如何通知WebSocket服务向连接的用户广播消息？常见的解决方案是使用消息队列（如Redis Pub/Sub、RabbitMQ、Kafka）。Web应用发布消息到消息队列，Ratchet服务订阅这些消息，然后根据消息内容向相应的客户端发送WebSocket消息。
最后，监控和日志在生产环境中至关重要。你需要实时了解Ratchet服务的运行状况，包括连接数、内存使用、CPU负载以及任何错误日志。这有助于你及时发现和解决问题。
以上就是PHP如何实现WebSocket服务？Ratchet应用实例的详细内容，更多请关注php中文网其它相关文章！
PHP怎么学习？PHP怎么入门？PHP在哪学？PHP怎么学才快？不用担心，这里为大家提供了PHP速学教程(入门到精通)，有需要的小伙伴保存下载就能学习啦！
广告
收藏
收藏
收藏
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号
637
