PHP实时聊天功能的多设备同步与消息推送

连接数据库：使用PHP连接数据库，并创建消息表以存储聊天记录。

$db = new mysqli('localhost', 'username', 'password', 'database');
$db->query("CREATE TABLE IF NOT EXISTS messages (id INT AUTO_INCREMENT PRIMARY KEY, sender VARCHAR(50), receiver VARCHAR(50), content TEXT, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP)");

登录后复制

新消息处理：通过POST请求将新消息保存到数据库。

if ($_SERVER['REQUEST_METHOD'] == 'POST') {
$sender = $_POST['sender'];
$receiver = $_POST['receiver'];
$content = $_POST['content'];

$db->query("INSERT INTO messages (sender, receiver, content) VALUES ('$sender', '$receiver', '$content')");
echo 'Success';
}

登录后复制

聊天记录查询：通过GET请求获取两个用户之间的聊天记录。

if ($_SERVER['REQUEST_METHOD'] == 'GET') {
$sender = $_GET['sender'];
$receiver = $_GET['receiver'];

$result = $db->query("SELECT * FROM messages WHERE (sender = '$sender' AND receiver = '$receiver') OR (sender = '$receiver' AND receiver = '$sender')");

$messages = [];
while ($row = $result->fetch_assoc()) {
$messages[] = $row;
}

echo json_encode($messages);
}

登录后复制

实时消息推送：使用长连接和异步任务，将新消息实时推送到所有在线用户。

$server = new swoole_websocket_server('0.0.0.0', 9501);
$server->on('open', function ($server, $request) {
echo "New connection: {$request->fd}
";
});
$server->on('message', function ($server, $frame) {
$message = json_decode($frame->data, true);

// 保存到数据库
$sender = $message['sender'];
$receiver = $message['receiver'];
$content = $message['content'];

$db->query("INSERT INTO messages (sender, receiver, content) VALUES ('$sender', '$receiver', '$content')");

// 推送给所有在线用户
$result = $db->query("SELECT fd FROM online_users");
while ($row = $result->fetch_assoc()) {
$server->push($row['fd'], $frame->data);
}
});
$server->on('close', function ($server, $fd) {
echo "Connection closed: {$fd}
";
});
$server->start();

登录后复制