php 聊天功能实现
实现 PHP 聊天功能的方法
使用 WebSocket 实现实时聊天
WebSocket 是一种全双工通信协议，适合实现实时聊天功能。PHP 可以通过 Ratchet 库实现 WebSocket 服务器。
安装 Ratchet：
composer require cboden/ratchet创建 WebSocket 服务器：
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) {
if ($client !== $from) {
$client->send($msg);
}
}
}
public function onClose(ConnectionInterface $conn) {
$this->clients->detach($conn);
}
public function onError(ConnectionInterface $conn, \Exception $e) {
$conn->close();
}
}
$app = new Ratchet\App('localhost', 8080);
$app->route('/chat', new Chat, ['*']);
$app->run();前端连接代码：
const conn = new WebSocket('ws://localhost:8080/chat');
conn.onmessage = e => console.log(e.data);
conn.send('Hello');使用 AJAX 轮询实现简单聊天
对于不需要实时性的简单聊天，可以使用 AJAX 轮询方式。
保存聊天消息到数据库：
// 保存消息
$message = $_POST['message'];
$stmt = $pdo->prepare("INSERT INTO messages (content) VALUES (?)");
$stmt->execute([$message]);获取消息的 API：
// 获取消息
$stmt = $pdo->query("SELECT * FROM messages ORDER BY id DESC LIMIT 50");
echo json_encode($stmt->fetchAll());前端轮询代码：
setInterval(() => {
fetch('/get-messages.php')
.then(res => res.json())
.then(messages => {
// 显示消息
});
}, 3000);使用 PHP 和 MySQL 存储聊天记录
创建消息表：
CREATE TABLE messages (
id INT AUTO_INCREMENT PRIMARY KEY,
username VARCHAR(30),
message TEXT,
created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);插入新消息：
$stmt = $pdo->prepare("INSERT INTO messages (username, message) VALUES (?, ?)");
$stmt->execute([$username, $message]);实现私聊功能
为私聊消息添加接收者字段：
ALTER TABLE messages ADD COLUMN receiver VARCHAR(30);查询私聊消息：
$stmt = $pdo->prepare("
SELECT * FROM messages
WHERE (username = ? AND receiver = ?)
OR (username = ? AND receiver = ?)
ORDER BY created_at
");
$stmt->execute([$user1, $user2, $user2, $user1]);添加消息加密
使用 OpenSSL 加密消息：
$encrypted = openssl_encrypt(
$message,
'AES-256-CBC',
$key,
0,
$iv
);解密消息：
$decrypted = openssl_decrypt(
$encrypted,
'AES-256-CBC',
$key,
0,
$iv
);实现文件传输
保存上传的文件：
$targetDir = "uploads/";
$targetFile = $targetDir . basename($_FILES["file"]["name"]);
move_uploaded_file($_FILES["file"]["tmp_name"], $targetFile);记录文件消息：
$stmt = $pdo->prepare("
INSERT INTO messages (username, message, file_path)
VALUES (?, ?, ?)
");
$stmt->execute([$username, '发送了文件', $targetFile]);用户在线状态管理
创建在线用户表：
CREATE TABLE online_users (
username VARCHAR(30) PRIMARY KEY,
last_seen TIMESTAMP
);更新用户在线状态：
$stmt = $pdo->prepare("
INSERT INTO online_users (username, last_seen)
VALUES (?, NOW())
ON DUPLICATE KEY UPDATE last_seen = NOW()
");
$stmt->execute([$username]);获取在线用户：
$stmt = $pdo->query("
SELECT username FROM online_users
WHERE last_seen > DATE_SUB(NOW(), INTERVAL 5 MINUTE)
");
