在php开发中，实现长连接推送和维持TCP长连接通信，最常用的方案是借助Swoole扩展，它内置了完整的TCP服务器和客户端能力，支持异步非阻塞模式，能够高效处理大量长连接。
Swoole TCP长连接服务端实现
首先需要搭建Swoole TCP服务端，负责监听端口、接收客户端连接、处理消息以及推送数据，核心代码如下：
<?php
// 创建TCP服务器，监听0.0.0.0:9501端口
$server = new SwooleServer('0.0.0.0', 9501);
// 配置服务器参数
$server->set([
'worker_num' => 4, // 工作进程数
'daemonize' => false, // 是否守护进程化
'heartbeat_check_interval' => 30, // 心跳检测间隔，单位秒
'heartbeat_idle_time' => 60, // 连接最大空闲时间，超过则断开
]);
// 监听连接进入事件
$server->on('Connect', function ($server, $fd) {
echo "客户端 {$fd} 连接成功" . PHP_EOL;
// 存储客户端连接信息，方便后续推送
$server->clientList[$fd] = true;
});
// 监听数据接收事件
$server->on('Receive', function ($server, $fd, $reactor_id, $data) {
$data = trim($data);
echo "收到客户端 {$fd} 的消息：{$data}" . PHP_EOL;
// 处理心跳消息，客户端发送ping时返回pong
if ($data === 'ping') {
$server->send($fd, 'pong');
}
// 处理推送消息，格式为 push:目标fd:消息内容
if (strpos($data, 'push:') === 0) {
$parts = explode(':', $data, 3);
if (count($parts) === 3) {
$targetFd = $parts[1];
$msg = $parts[2];
if (isset($server->clientList[$targetFd])) {
$server->send($targetFd, "来自客户端{$fd}的推送：{$msg}");
}
}
}
});
// 监听连接关闭事件
$server->on('Close', function ($server, $fd) {
echo "客户端 {$fd} 断开连接" . PHP_EOL;
unset($server->clientList[$fd]);
});
// 启动服务器
$server->start();
Swoole TCP长连接客户端实现
客户端需要与服务端建立长连接，并且定时发送心跳包维持连接，同时可以接收服务端的推送消息，实现代码如下：
<?php
// 创建TCP客户端
$client = new SwooleClient(SWOOLE_SOCK_TCP);
// 连接服务端
if (!$client->connect('127.0.0.1', 9501, 1)) {
die("连接失败：{$client->errCode}" . PHP_EOL);
}
echo "连接服务端成功" . PHP_EOL;
// 设置异步回调，接收服务端消息
$client->on('receive', function ($client, $data) {
echo "收到服务端消息：{$data}" . PHP_EOL;
});
// 定时发送心跳包，每30秒发送一次ping
SwooleTimer::tick(30000, function () use ($client) {
$client->send('ping');
});
// 模拟发送推送消息，给fd为2的客户端推送内容
SwooleTimer::after(5000, function () use ($client) {
$client->send('push:2:这是一条测试推送消息');
});
// 保持客户端运行
SwooleEvent::wait();
长连接核心要点说明
心跳机制的作用
TCP长连接如果长时间没有数据交互，可能会被中间网络设备断开，因此需要配置心跳机制。Swoole服务端可以通过heartbeat_check_interval和heartbeat_idle_time参数自动检测空闲连接，也可以自定义心跳逻辑，客户端定时发送心跳包，服务端收到后返回响应，确认连接有效。
连接管理与推送
服务端需要维护所有存活的客户端连接标识fd，可以通过数组或者Redis等存储连接信息，当需要推送消息时，根据目标fd调用send方法即可完成推送。如果需要广播消息，可以遍历所有存活的fd逐个发送。
异常处理
实际使用中需要处理连接断开、消息发送失败等异常情况，比如客户端断开后及时清理连接信息，发送消息时判断连接是否存在，避免推送失败。同时可以配置重连机制，客户端断开后自动尝试重新连接服务端。
常见问题解答
- 问：Swoole长连接支持多少并发？答：并发数量和服务器的内存、CPU以及配置参数有关，合理优化后支持数万甚至数十万并发长连接。
- 问：长连接和短连接的区别是什么？答：短连接每次通信都需要建立连接、断开连接，开销大；长连接建立后保持连接状态，多次通信复用同一个连接，开销小，适合实时通信场景。
- 问：除了TCP长连接，Swoole还支持其他长连接吗？答：Swoole还支持WebSocket长连接、HTTP2长连接等，实现方式和TCP类似，只是协议层不同。