PHP와 WebSocket을 통해 실시간 온라인 질의응답 시스템을 구현하는 방법

인터넷의 발전과 함께 실시간 온라인 대화형 질문 및 답변 시스템이 점차 일반적인 네트워크 애플리케이션이 되었습니다. 실시간 커뮤니케이션에 대한 사용자의 요구를 충족할 수 있을 뿐만 아니라 사용자의 끈기와 참여도를 높일 수 있습니다. 본 글에서는 PHP와 WebSocket을 기반으로 실시간 온라인 질의응답 시스템을 구현하는 방법을 소개하고, 독자들이 더 잘 이해하고 학습할 수 있도록 구체적인 코드 예제를 제공하겠습니다.

1. WebSocket이란

WebSocket은 TCP 프로토콜을 기반으로 한 양방향 통신 표준입니다. 실시간 데이터 전송을 실현하기 위해 웹 브라우저와 웹 서버 사이에 실시간 연결을 설정할 수 있습니다. WebSocket을 통해 웹 애플리케이션에서 클라이언트로 실시간으로 데이터를 푸시하거나 클라이언트로부터 실시간 요청 및 응답을 받을 수 있습니다.

2. 실시간 온라인 질문과 답변 시스템을 구현하기 위해 WebSocket을 사용하는 이유는 무엇입니까?

기존 Ajax 폴링 방식은 서버 부담 증가, 네트워크 지연 등 성능 및 안정성 측면에서 몇 가지 문제가 있습니다. WebSocket을 사용하면 이러한 질문을 효과적으로 최적화하고 질문 및 답변 시스템을 보다 원활하고 안정적으로 만들 수 있습니다.

3. PHP와 WebSocket을 사용하여 실시간 온라인 질문 및 답변 시스템을 구현하는 방법

1. WebSocket 설치

PHP WebSocket 클래스 라이브러리를 사용하여 WebSocket을 구현할 수 있습니다. 이 기사에서는 PHP WAMP 서버(https://wampserver.com/)를 사용하여 개발 환경을 설정하고 PHP WebSocket 클래스 라이브러리(https://github.com/Textalk/websocket-php)를 설치합니다.

2. Create WebSocket Server

다음으로 클라이언트 요청을 처리할 WebSocket 서버를 생성해야 합니다. WebSocket 서버는 지정된 포트를 수신하고 클라이언트가 연결될 때까지 기다려야 합니다. 클라이언트가 성공적으로 연결되면 서버는 WebSocket 개체를 생성하고 클라이언트와 상호 작용합니다.

다음은 간단한 WebSocket 서버 예입니다.

use WebSocketServer;

$server = new Server('127.0.0.1', 8080);

$server->on('open', function($conn) {
    echo "New connection added: {$conn->getId()}
";
});

$server->on('message', function($conn, $msg) use ($server) {
    $server->broadcast($msg);
});

$server->run();

이 코드는 포트 127.0.0.1:8080에서 수신 대기하는 WebSocket 서버 인스턴스를 생성합니다. 클라이언트가 성공적으로 연결되면 서버는 콜백 함수를 통해 연결 ID를 출력하고 클라이언트 메시지를 수신할 때 연결된 모든 클라이언트에 이를 브로드캐스트합니다.

3. 질문 및 답변 시스템 만들기

다음으로 사용자의 질문과 답변을 처리하기 위한 질문 및 답변 시스템을 만들어야 합니다. 우리는 PHP와 MySQL을 사용하여 이 시스템을 구현할 수 있습니다.

먼저, 사용자들이 묻는 질문과 답변을 저장할 데이터베이스를 만들어야 합니다. 다음은 데이터 테이블을 생성하는 샘플 SQL 문입니다.

CREATE TABLE `questions_info` (
  `id` int(11) NOT NULL PRIMARY KEY AUTO_INCREMENT,
  `title` varchar(255) NOT NULL,
  `content` text NOT NULL,
  `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP
);

CREATE TABLE `answers_info` (
  `id` int(11) NOT NULL PRIMARY KEY AUTO_INCREMENT,
  `question_id` int(11) NOT NULL,
  `content` text NOT NULL,
  `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP
);

이 코드는 질문과 답변의 세부 정보를 저장하기 위해 두 개의 데이터 테이블을 생성합니다. 그 중 Question_id는 해당 질문에 대한 답변의 ID입니다.

다음으로, 사용자가 웹 브라우저에서 질문하고 기존 질문과 답변을 볼 수 있는 질문 처리 페이지를 구현합니다. 사용자가 질문을 제출하면 WebSocket을 통해 연결된 모든 클라이언트에 질문 정보가 푸시됩니다. 클라이언트가 새로운 질문을 받으면 해당 질문이 페이지에 표시됩니다.

다음은 간단한 샘플 코드입니다.

use WebSocketClient;

// 引入数据库连接信息
require_once 'config.php';

// 创建MySQL连接对象
$mysqli = new mysqli(DB_HOST, DB_USERNAME, DB_PASSWORD, DB_NAME);

// 处理用户提交问题
if (isset($_POST['submit'])) {
    $title = $mysqli->real_escape_string($_POST['title']);
    $content = $mysqli->real_escape_string($_POST['content']);
    $query = "INSERT INTO questions_info (title, content) VALUES ('$title', '$content')";
    $mysqli->query($query);
    $id = $mysqli->insert_id;

    // 推送新问题到客户端
    $client = new Client('ws://127.0.0.1:8080');
    $client->send('{"type":"new_question","id":'.$id.',"title":"'.$title.'","content":"'.$content.'"}');
}

// 查询已有问题
$query = "SELECT * FROM questions_info ORDER BY create_time DESC";
$result = $mysqli->query($query);

// 输出问题列表
while ($row = $result->fetch_assoc()) {
    $question_id = $row['id'];
    $question_title = $row['title'];
    $question_content = $row['content'];

    // 查询问题回答数
    $query = "SELECT COUNT(*) FROM answers_info WHERE question_id=$question_id";
    $answer_count = $mysqli->query($query)->fetch_row()[0];
?>

<div class="question-item">
    <h3 class="question-title">
        <a href="question.php?id=<?php echo $question_id; ?>"><?php echo $question_title; ?></a>
    </h3>
    <div class="question-content"><?php echo $question_content; ?></div>
    <div class="question-meta">
        <span class="answer-count"><?php echo $answer_count; ?>回答</span>
    </div>
</div>

<?php } ?>

이 코드는 사용자가 시작한 질문의 처리를 구현하고, 클라이언트에 새 질문을 푸시할 때 클라이언트가 새 질문을 올바르게 처리할 수 있도록 WebSocket을 통해 JSON 데이터를 전달합니다.

다음으로, 사용자가 답변을 제출하면 답변이 MySQL 데이터베이스에 저장되고 답변 정보가 WebSocket을 통해 연결된 모든 클라이언트에 푸시됩니다. 클라이언트가 새로운 답변을 받으면 페이지에 표시됩니다.

다음은 간단한 샘플 코드입니다.

// 处理用户提交回答
if (isset($_POST['submit'])) {
    $question_id = $_POST['question_id'];
    $content = $mysqli->real_escape_string($_POST['content']);
    $query = "INSERT INTO answers_info (question_id, content) VALUES ('$question_id', '$content')";
    $mysqli->query($query);
    $id = $mysqli->insert_id;

    // 推送新回答到客户端
    $client = new Client('ws://127.0.0.1:8080');
    $client->send('{"type":"new_answer","id":'.$id.',"question_id":'.$question_id.',"content":"'.$content.'"}');
}

// 查询问题和回答列表
$question_id = $_GET['id'];
$query = "SELECT * FROM questions_info WHERE id=$question_id";
$question = $mysqli->query($query)->fetch_assoc();
$query = "SELECT * FROM answers_info WHERE question_id=$question_id ORDER BY create_time DESC";
$result = $mysqli->query($query);
?>

<h2 class="question-title"><?php echo $question['title']; ?></h2>
<div class="question-content"><?php echo $question['content']; ?></div>

<!-- 输出回答列表 -->
<?php while ($row = $result->fetch_assoc()) { ?>
<div class="answer-item">
    <div class="answer-content"><?php echo $row['content']; ?></div>
</div>
<?php } ?>

<!-- 输出回答表单 -->
<form method="post">
    <input type="hidden" name="question_id" value="<?php echo $question_id; ?>">
    <div class="form-item">
        <textarea name="content"></textarea>
    </div>
    <div class="form-item">
        <input type="submit" name="submit" value="提交回答">
    </div>
</form>

이 코드는 질문에 대한 사용자 답변 처리를 구현하며, 클라이언트에 새 답변을 푸시할 때 클라이언트가 새 답변을 올바르게 처리할 수 있도록 WebSocket을 통해 JSON 데이터를 전달합니다.

4. 요약

이 글에서는 PHP와 WebSocket을 사용하여 실시간 온라인 질문 및 답변 시스템을 구현하는 방법을 소개하고 구체적인 코드 예제를 제공합니다. WebSocket을 통해 Q&A 시스템의 성능과 안정성을 효과적으로 최적화할 수 있어 사용자가 시스템을 더욱 즐겁게 사용할 수 있습니다. 동시에 독자는 이러한 샘플 코드를 기반으로 자신의 웹 애플리케이션을 최적화하고 더 나은 사용자 경험을 제공할 수도 있습니다.

위 내용은 PHP와 WebSocket을 통해 실시간 온라인 질의응답 시스템을 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!