当前位置：首页 > PHP

php实现即时聊天

2026-04-03 02:34:09PHP

PHP实现即时聊天的方法

使用PHP实现即时聊天功能可以通过多种方式完成，以下是一些常见的方法：

使用WebSocket技术

WebSocket是一种在单个TCP连接上进行全双工通信的协议，适合实现即时聊天。PHP可以通过Ratchet库来实现WebSocket服务器。

安装Ratchet库：

composer require cboden/ratchet

创建WebSocket服务器：

use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
use MyApp\Chat;

require dirname(__DIR__) . '/vendor/autoload.php';

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new Chat()
        )
    ),
    8080
);

$server->run();

创建聊天处理类：

namespace MyApp;
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

class Chat implements MessageComponentInterface {
    protected $clients;

    public function __construct() {
        $this->clients = new \SplObjectStorage;
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        foreach ($this->clients as $client) {
            $client->send($msg);
        }
    }

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
    }

    public function onError(ConnectionInterface $conn, \Exception $e) {
        $conn->close();
    }
}

使用AJAX轮询

php实现即时聊天

对于不支持WebSocket的环境，可以使用AJAX轮询实现即时聊天功能。

客户端代码：

function pollMessages() {
    $.ajax({
        url: 'get_messages.php',
        success: function(data) {
            // 显示消息
            $('#chat').append(data);
            // 继续轮询
            setTimeout(pollMessages, 1000);
        }
    });
}
pollMessages();

服务器端代码（get_messages.php）：

// 查询数据库获取新消息
$messages = getNewMessages($_SESSION['last_message_id']);
foreach ($messages as $msg) {
    echo '<div>' . htmlspecialchars($msg['content']) . '</div>';
    $_SESSION['last_message_id'] = $msg['id'];
}

使用数据库存储消息

php实现即时聊天

创建消息表：

CREATE TABLE messages (
    id INT AUTO_INCREMENT PRIMARY KEY,
    sender_id INT,
    receiver_id INT,
    content TEXT,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

发送消息处理（send_message.php）：

if ($_SERVER['REQUEST_METHOD'] === 'POST') {
    $senderId = $_POST['sender_id'];
    $receiverId = $_POST['receiver_id'];
    $content = $_POST['content'];

    $stmt = $pdo->prepare("INSERT INTO messages (sender_id, receiver_id, content) VALUES (?, ?, ?)");
    $stmt->execute([$senderId, $receiverId, $content]);

    echo json_encode(['status' => 'success']);
}