php实现在线交流功能

实现基础聊天功能

使用PHP结合WebSocket或Ajax轮询实现实时通信。WebSocket更高效但需要服务器支持，Ajax轮询兼容性更好但资源消耗较大。

WebSocket服务器示例（需安装Ratchet库）：

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();
    }
}

数据库存储消息

创建MySQL表存储聊天记录：

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

PHP消息存储示例：

$pdo = new PDO('mysql:host=localhost;dbname=chat', 'username', 'password');
$stmt = $pdo->prepare("INSERT INTO messages (user_id, content) VALUES (?, ?)");
$stmt->execute([$userId, $message]);

前端界面实现

使用JavaScript处理实时消息显示：

const socket = new WebSocket('ws://yourserver:8080');
socket.onmessage = function(e) {
    const chatBox = document.getElementById('chat-box');
    chatBox.innerHTML += `<div>${e.data}</div>`;
};

function sendMessage() {
    const input = document.getElementById('message-input');
    socket.send(input.value);
    input.value = '';
}

用户认证与安全

实现基本的用户认证系统：

session_start();

function authenticate($username, $password) {
    // 验证逻辑
    $_SESSION['user_id'] = $user['id'];
    $_SESSION['username'] = $user['username'];
}

function isAuthenticated() {
    return isset($_SESSION['user_id']);
}

消息发送前的XSS过滤：

function sanitizeMessage($message) {
    return htmlspecialchars($message, ENT_QUOTES, 'UTF-8');
}

扩展功能实现

添加私聊功能数据库表：

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

消息已读状态追踪：

ALTER TABLE private_messages ADD COLUMN is_read BOOLEAN DEFAULT FALSE;

实现消息推送通知：

Notification.requestPermission().then(perm => {
    if (perm === "granted") {
        new Notification("新消息", {body: message});
    }
});