PHP로 온라인 커뮤니케이션 기능을 구현하는 방법-PHP 문제-php.cn

집

PHP 문제

PHP로 온라인 커뮤니케이션 기능을 구현하는 방법

Apr 19, 2023 am 09:18 AM

현재 인터넷 시대에 온라인 커뮤니케이션은 우리 일상생활에서 없어서는 안 될 부분이 되었습니다. 직장에서든 생활에서든 우리 모두는 온라인을 통해 다른 사람들과 소통하고 소통해야 합니다. 따라서 오늘날의 웹사이트 개발에 있어 온라인 커뮤니케이션 기능의 구현은 점점 더 중요해지고 있습니다. 이 기사에서는 PHP를 사용하여 기본적인 온라인 통신 기능을 구현하는 방법을 소개하고 완전한 코드 예제를 제공합니다.

1. MySQL 테이블 디자인

PHP 코드 작성을 시작하기 전에 필요에 따라 데이터베이스 테이블 구조를 디자인하세요. 예를 들어, 테이블은 다음 데이터를 저장해야 합니다. 발신자 ID

발신 시간
위 요구 사항을 기반으로 다음과 같은 테이블 구조를 설계해야 합니다.

CREATE TABLE `chat_message` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `from_user_id` int(11) unsigned NOT NULL,
  `to_user_id` int(11) unsigned NOT NULL,
  `message` varchar(255) DEFAULT '',
  `send_time` datetime DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

로그인 후 복사

2. MySQL 데이터베이스에 연결

PHP에서 MySQL 데이터베이스에 연결하는 것은 매우 간단합니다. MySQL에 연결하려면 mysqli_connect() 함수를 사용하면 됩니다.

다음은 MySQL 데이터베이스에 연결하는 예입니다.

$servername = "localhost";
$username = "username";
$password = "password";
$dbname = "chat_db";

// 创建连接
$conn = mysqli_connect($servername, $username, $password, $dbname);

// 检查连接是否成功
if (!$conn) {
    die("Connection failed: " . mysqli_connect_error());
}

로그인 후 복사

3. 채팅 메시지 삽입

사용자가 웹사이트에서 채팅 메시지를 보낼 때 해당 메시지를 데이터베이스에 삽입해야 합니다.

다음은 채팅 메시지를 삽입하는 코드 예제입니다.

// 获取发送人ID和接收人ID
$from_user_id = $_SESSION['user_id'];
$to_user_id = $_POST['to_user_id'];
$message = $_POST['message'];

// 获取当前时间
$send_time = date('Y-m-d H:i:s');

// 将数据插入到 chat_message 表中
$sql = "INSERT INTO chat_message (from_user_id, to_user_id, message, send_time)
VALUES ('$from_user_id', '$to_user_id', '$message', '$send_time')";

if (mysqli_query($conn, $sql)) {
    echo "New record created successfully";
} else {
    echo "Error: " . $sql . "&lt;br&gt;" . mysqli_error($conn);
}

로그인 후 복사

4. 채팅 기록 가져오기

사용자가 웹사이트에서 채팅 기록을 볼 때 데이터베이스에서 기록 메시지를 가져와야 합니다.

다음은 채팅 내역을 가져오는 코드 예시입니다.

// 获取对话双方的ID
$user1_id = $_GET['user1_id'];
$user2_id = $_GET['user2_id'];

// 查询消息记录
$sql = "SELECT * FROM chat_message WHERE
        (from_user_id = '$user1_id' AND to_user_id = '$user2_id') OR
        (from_user_id = '$user2_id' AND to_user_id = '$user1_id')
        ORDER BY send_time ASC";
$result = mysqli_query($conn, $sql);

// 输出消息记录
while($row = mysqli_fetch_assoc($result)) {
    echo $row['send_time'] . " - " . $row['message'] . "&lt;br&gt;";
}

로그인 후 복사

위 코드는 chat_message 테이블에서 현재 사용자와 관련된 채팅 기록을 조회하여 보낸 시간 순서대로 메시지 기록을 출력하는 코드입니다.

5. 웹 UI 구현

마지막으로 사용자가 브라우저에서 채팅 메시지를 보내고 받을 수 있도록 웹 UI를 작성해야 합니다.

다음은 웹 UI를 구현하는 코드 예제입니다.

&lt;!DOCTYPE html&gt;
&lt;html&gt;
&lt;head&gt;
    &lt;meta charset=&quot;UTF-8&quot;&gt;
    &lt;title&gt;网上交流功能&lt;/title&gt;
&lt;/head&gt;
&lt;body&gt;
    &lt;h1&gt;网上交流功能&lt;/h1&gt;
    &lt;div id=&quot;chat_box&quot; style=&quot;border: 1px solid black; height: 500px; overflow: auto;&quot;&gt;&lt;/div&gt;
    &lt;br&gt;
    &lt;form id=&quot;message_form&quot; action=&quot;&quot; method=&quot;POST&quot;&gt;
        接收人ID：&lt;input type=&quot;text&quot; name=&quot;to_user_id&quot;&gt;&lt;br&gt;&lt;br&gt;
        消息内容：&lt;input type=&quot;text&quot; name=&quot;message&quot;&gt;&lt;br&gt;&lt;br&gt;
        &lt;input type=&quot;submit&quot; value=&quot;发送&quot;&gt;
    &lt;/form&gt;

    &lt;script&gt;
        // 获取聊天记录
        setInterval(function() {
            var xmlhttp = new XMLHttpRequest();
            xmlhttp.onreadystatechange = function() {
                if (this.readyState == 4 &amp;&amp; this.status == 200) {
                    document.getElementById("chat_box").innerHTML = this.responseText;
                }
            };
            xmlhttp.open("GET", "get_chat_history.php?user1_id="+user1_id+"&amp;user2_id="+user2_id, true);
            xmlhttp.send();
        }, 1000);

        // 发送消息
        document.getElementById("message_form").addEventListener("submit", function(event) {
            event.preventDefault();
            var xmlhttp = new XMLHttpRequest();
            xmlhttp.onreadystatechange = function() {
                if (this.readyState == 4 &amp;&amp; this.status == 200) {
                    console.log(this.responseText);
                }
            };
            var data = new FormData(document.getElementById("message_form"));
            xmlhttp.open("POST", "insert_chat_message.php", true);
            xmlhttp.send(data);
            document.getElementById("message_form").reset();
        });
    &lt;/script&gt;
&lt;/body&gt;
&lt;/html&gt;

로그인 후 복사

위 코드는 웹 UI를 생성하고 사용자가 양식을 작성하여 메시지를 보내고 받을 수 있도록 합니다. setInterval() 함수를 사용하여 채팅 기록을 주기적으로 조회하고, XMLHttpRequest 객체를 사용하여 서버에 데이터를 전송함으로써 실시간으로 새로운 채팅 기록을 확인할 수 있습니다. 동시에 addEventListener() 함수를 사용하여 양식에 이벤트 리스너를 추가하면 사용자가 제출한 메시지를 캡처하여 데이터베이스에 삽입할 수 있습니다.

6. 전체 코드

다음은 MySQL 데이터베이스에 연결하고 채팅 메시지를 삽입하고 채팅 기록을 가져오는 PHP 코드 예제입니다.

connect_db.php

&lt;?php
$servername = &quot;localhost&quot;;
$username = &quot;username&quot;;
$password = &quot;password&quot;;
$dbname = &quot;chat_db&quot;;

// 创建连接
$conn = mysqli_connect($servername, $username, $password, $dbname);

// 检查连接是否成功
if (!$conn) {
    die(&quot;Connection failed: &quot; . mysqli_connect_error());
}
?&gt;

로그인 후 복사

insert_chat_message.php

<?php
require_once('connect_db.php');

// 获取发送人ID和接收人ID
$from_user_id = $_SESSION['user_id'];
$to_user_id = $_POST['to_user_id'];
$message = $_POST['message'];

// 获取当前时间
$send_time = date('Y-m-d H:i:s');

// 将数据插入到 chat_message 表中
$sql = "INSERT INTO chat_message (from_user_id, to_user_id, message, send_time)
VALUES ('$from_user_id', '$to_user_id', '$message', '$send_time')";

if (mysqli_query($conn, $sql)) {
    echo "New record created successfully";
} else {
    echo "Error: " . $sql . "&lt;br&gt;" . mysqli_error($conn);
}
?>

로그인 후 복사

get_chat_history.php

<?php
require_once('connect_db.php');

// 获取对话双方的ID
$user1_id = $_GET['user1_id'];
$user2_id = $_GET['user2_id'];

// 查询消息记录
$sql = "SELECT * FROM chat_message WHERE
        (from_user_id = '$user1_id' AND to_user_id = '$user2_id') OR
        (from_user_id = '$user2_id' AND to_user_id = '$user1_id')
        ORDER BY send_time ASC";
$result = mysqli_query($conn, $sql);

// 输出消息记录
while($row = mysqli_fetch_assoc($result)) {
    echo $row['send_time'] . " - " . $row['message'] . "&lt;br&gt;";
}
?>

로그인 후 복사

위는 PHP를 사용하여 온라인 커뮤니케이션 기능을 구현한 완전한 코드 예제입니다. 본 코드 예시에서는 보안 등 다른 측면을 고려하지 않았으므로, 사용 시 개선 및 최적화에 주의하시기 바랍니다.

위 내용은 PHP로 온라인 커뮤니케이션 기능을 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

본 웹사이트의 성명

본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.