如何透過PHP和WebSocket實現即時線上問答系統

隨著網路的發展，即時線上互動問答系統逐漸成為了常見的網路應用。它不僅可以滿足用戶即時交流的需求，而且可以加強用戶的黏性和參與度。在本文中，我們將以PHP和WebSocket為基礎，介紹如何實現即時線上問答系統，同時提供具體的程式碼範例，以便讀者更好地理解和學習。

一、什麼是WebSocket

WebSocket是一種基於TCP協定實現的雙向通訊標準。它可以在網頁瀏覽器和網路伺服器之間建立即時連接，實現即時資料傳輸。透過WebSocket，我們可以將Web應用程式中的資料即時推送到客戶端，或接收客戶端的即時請求和回應。

二、為什麼要使用WebSocket實現即時線上問答系統

傳統的Ajax輪詢方式在效能和穩定性方面存在一些問題，例如會增加伺服器的壓力和網路的延遲。而使用WebSocket可以有效地優化這些問題，讓問答系統更流暢、更穩定。

三、如何使用PHP和WebSocket實現即時線上問答系統

1. #安裝WebSocket

我們可以使用PHP WebSocket類別庫來實作WebSocket。在本文中，我們使用PHP WAMP伺服器（https://wampserver.com/）來建立開發環境，並安裝PHP WebSocket類別庫（https://github.com/Textalk/websocket-php）。

2. 建立WebSocket伺服器

接下來，我們需要建立一個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();

這段程式碼建立了一個WebSocket伺服器實例，監聽127.0.0.1:8080連接埠。當有客戶端連線成功後，伺服器會透過回呼函數輸出連接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數據，以便客戶端能夠正確處理新的回答。

四、總結

本文介紹如何使用PHP和WebSocket實現即時線上問答系統，並提供了具體的程式碼範例。透過WebSocket，我們可以有效地優化問答系統的效能和穩定性，使用戶更愉悅地使用這個系統。同時，讀者也可以根據這些範例程式碼來優化自己的Web應用程序，並提供更好的使用者體驗。

以上是如何透過PHP和WebSocket實現即時線上問答系統的詳細內容。更多資訊請關注PHP中文網其他相關文章！