한국어
한국어
CREATE TABLE messages (
id INT AUTO_INCREMENT PRIMARY KEY,
sender_id INT,
receiver_id INT,
message TEXT,
sent_at DATETIME
);
<?php
$conn = new mysqli('localhost', 'username', 'password', 'database');
if ($conn->connect_error) {
die("데이터베이스에 연결하지 못했습니다：" . $conn->connect_error);
}
?>
<?php
// 메시지와 수신자를 보내도록하십시오ID
$message = $_POST['message'];
$receiverId = $_POST['receiver_id'];
// 발신자를 얻으십시오ID（세션 또는 로그인 확인을 통해 얻을 수 있습니다）
$senderId = $_SESSION['user_id'];
// 준비 문을 만듭니다
$stmt = $conn->prepare("INSERT INTO messages (sender_id, receiver_id, message, sent_at) VALUES (?, ?, ?, NOW())");
$stmt->bind_param("iis", $senderId, $receiverId, $message);
$stmt->execute();
// 데이터가 성공적으로 삽입되어 있는지 확인하십시오
if ($stmt->affected_rows > 0) {
echo "메시지는 성공적으로 전송되었습니다！";
} else {
echo "메시지 보내는 메시지가 실패했습니다！";
}
$stmt->close();
?>
<?php
// 수신자를 얻으십시오ID（세션 또는 로그인 확인을 통해 얻을 수 있습니다）
$receiverId = $_SESSION['user_id'];
// 준비 문을 만듭니다
$stmt = $conn->prepare("SELECT * FROM messages WHERE receiver_id = ? ORDER BY sent_at DESC");
$stmt->bind_param("i", $receiverId);
$stmt->execute();
// 결과 세트를 가져옵니다
$result = $stmt->get_result();
// 결과 설정을 연관 배열로 변환합니다
$messages = $result->fetch_all(MYSQLI_ASSOC);
// 반품JSON형식의 메시지 배열
echo json_encode($messages);
$stmt->close();
?>
<?php
// 사용AJAX백엔드에서 메시지 배열 가져 오기
var xhr = new XMLHttpRequest();
xhr.open("GET", "get_messages.php", true);
xhr.onreadystatechange = function() {
if (xhr.readyState == 4 && xhr.status == 200) {
var messages = JSON.parse(xhr.responseText);
// 메시지 배열을 통해 루프，채팅 창에 표시됩니다
for (var i = 0; i < messages.length; i++) {
var message = messages[i];
// 메시지 내용 및 발신자 정보 등을 표시합니다.
// ...
}
}
};
xhr.send();
?>
