当前位置：首页 > PHP

PHP用户实现聊天

2026-02-15 08:51:54PHP

PHP实现聊天功能的方法

基于WebSocket的实时聊天
安装Ratchet库（PHP WebSocket库）并通过Composer引入：

composer require cboden/ratchet

创建WebSocket服务器脚本（如chat_server.php）：

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 onClose(ConnectionInterface $conn) { $this->clients->detach($conn); }
    public function onError(ConnectionInterface $conn, \Exception $e) { $conn->close(); }
    public function onMessage(ConnectionInterface $from, $msg) {
        foreach ($this->clients as $client) {
            $client->send($msg);
        }
    }
}
$app = new Ratchet\App('localhost', 8080);
$app->route('/chat', new Chat, ['*']);
$app->run();

前端连接WebSocket
HTML/JavaScript示例：

PHP用户实现聊天

<script>
const socket = new WebSocket('ws://localhost:8080/chat');
socket.onmessage = function(e) {
    document.getElementById('messages').innerHTML += '<div>' + e.data + '</div>';
};
function sendMessage() {
    const msg = document.getElementById('messageInput').value;
    socket.send(msg);
}
</script>
<input type="text" id="messageInput" />
<button onclick="sendMessage()">Send</button>
<div id="messages"></div>

基于AJAX的长轮询方案
PHP后端（chat_backend.php）：

session_start();
if ($_POST['action'] == 'send') {
    file_put_contents('chat.log', $_POST['message'] . PHP_EOL, FILE_APPEND);
}
if ($_POST['action'] == 'poll') {
    $last = $_POST['last'] ?? 0;
    while (true) {
        clearstatcache();
        $size = filesize('chat.log');
        if ($size > $last) {
            $file = fopen('chat.log', 'r');
            fseek($file, $last);
            echo json_encode(['messages' => fread($file, $size - $last)]);
            fclose($file);
            break;
        }
        sleep(1);
    }
}

数据库存储聊天记录
MySQL表结构示例：

PHP用户实现聊天

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

PHP插入消息示例：

$stmt = $pdo->prepare("INSERT INTO messages (user_id, content) VALUES (?, ?)");
$stmt->execute([$_SESSION['user_id'], $_POST['message']]);

安全增强建议

对所有用户输入使用htmlspecialchars()过滤
WebSocket实现添加身份验证令牌
数据库操作使用预处理语句防止SQL注入
设置合理的消息频率限制（如每秒最多5条）

部署注意事项

WebSocket需确保服务器支持（如使用php-cli运行）

Nginx配置WebSocket代理示例：

location /chat {
  proxy_pass http://localhost:8080;
  proxy_http_version 1.1;
  proxy_set_header Upgrade $http_upgrade;
  proxy_set_header Connection "Upgrade";
}