php实现在线交流功能
使用PHP实现在线交流功能
在线交流功能通常涉及即时消息传递、用户状态管理和数据存储。PHP结合前端技术可以实现这一功能。
基于AJAX的轮询实现
创建基本的数据库表结构存储消息数据：
CREATE TABLE messages (
id INT AUTO_INCREMENT PRIMARY KEY,
sender_id INT NOT NULL,
receiver_id INT NOT NULL,
message TEXT NOT NULL,
timestamp TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
is_read BOOLEAN DEFAULT FALSE
);实现消息发送处理脚本send_message.php：
<?php
require 'db_connection.php';
$senderId = $_POST['sender_id'];
$receiverId = $_POST['receiver_id'];
$message = htmlspecialchars($_POST['message']);
$stmt = $pdo->prepare("INSERT INTO messages (sender_id, receiver_id, message) VALUES (?, ?, ?)");
$stmt->execute([$senderId, $receiverId, $message]);
echo json_encode(['status' => 'success']);
?>实现消息接收脚本get_messages.php：
<?php
require 'db_connection.php';
$userId = $_GET['user_id'];
$lastMessageId = $_GET['last_id'] ?? 0;
$stmt = $pdo->prepare("SELECT * FROM messages WHERE receiver_id = ? AND id > ? ORDER BY timestamp ASC");
$stmt->execute([$userId, $lastMessageId]);
$messages = $stmt->fetchAll(PDO::FETCH_ASSOC);
echo json_encode($messages);
?>使用WebSocket实现实时通信
安装Ratchet库实现WebSocket服务器：
composer require cboden/ratchet创建WebSocket服务器脚本：
<?php
use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
use MyApp\Chat;
require dirname(__DIR__) . '/vendor/autoload.php';
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) {
if ($client !== $from) {
$client->send($msg);
}
}
}
public function onClose(ConnectionInterface $conn) {
$this->clients->detach($conn);
}
public function onError(ConnectionInterface $conn, \Exception $e) {
$conn->close();
}
}
$server = IoServer::factory(
new HttpServer(
new WsServer(
new Chat()
)
),
8080
);
$server->run();
?>前端实现
HTML和JavaScript代码连接WebSocket：
<div id="chat-box"></div>
<input type="text" id="message-input">
<button id="send-button">Send</button>
<script>
const chatBox = document.getElementById('chat-box');
const messageInput = document.getElementById('message-input');
const sendButton = document.getElementById('send-button');
const socket = new WebSocket('ws://yourserver:8080');
socket.onmessage = function(event) {
chatBox.innerHTML += `<div>${event.data}</div>`;
};
sendButton.onclick = function() {
socket.send(messageInput.value);
messageInput.value = '';
};
</script>用户认证和安全措施
实现用户认证的中间件：
function authenticateUser($token) {
$stmt = $pdo->prepare("SELECT * FROM users WHERE auth_token = ?");
$stmt->execute([$token]);
return $stmt->fetch(PDO::FETCH_ASSOC);
}
$user = authenticateUser($_GET['token']);
if (!$user) {
http_response_code(401);
exit;
}消息内容过滤函数：
function filterMessage($message) {
$message = htmlspecialchars($message);
$message = preg_replace('/<script\b[^>]*>(.*?)<\/script>/is', '', $message);
return $message;
}数据库优化
为消息表添加索引提高查询性能：
CREATE INDEX idx_receiver ON messages(receiver_id);
CREATE INDEX idx_timestamp ON messages(timestamp);实现消息分页查询：
$page = $_GET['page'] ?? 1;
$limit = 20;
$offset = ($page - 1) * $limit;
$stmt = $pdo->prepare("SELECT * FROM messages WHERE receiver_id = ? ORDER BY timestamp DESC LIMIT ? OFFSET ?");
$stmt->execute([$userId, $limit, $offset]);通知系统集成
实现未读消息计数：
function getUnreadCount($userId) {
$stmt = $pdo->prepare("SELECT COUNT(*) FROM messages WHERE receiver_id = ? AND is_read = FALSE");
$stmt->execute([$userId]);
return $stmt->fetchColumn();
}标记消息为已读：
$stmt = $pdo->prepare("UPDATE messages SET is_read = TRUE WHERE id = ? AND receiver_id = ?");
$stmt->execute([$messageId, $userId]);
