基於PHP的即時聊天系統的訊息撤回和撤銷功能-php教程-PHP中文網

基於PHP的即時聊天系統的訊息撤回和撤銷功能

王林

發布： 2023-08-26 09:18:01

原創

1199 人瀏覽過

基於PHP的即時聊天系統的訊息撤回和撤銷功能

#引言：
隨著互聯網的快速發展和普及，即時聊天系統成為人們日常溝通的重要方式。在開發聊天系統時，實現訊息撤回和撤銷功能是一個常見的需求。本文將介紹如何使用PHP編寫一個基於WebSocket的即時聊天系統，並實現訊息撤回和撤銷功能。

建置環境
首先，我們需要建置PHP環境和WebSocket服務。可以選擇使用PHP框架，如Laravel或Symfony，或直接使用PHP原生的WebSocket函式庫。在框架中，可以使用Composer來管理相依性。
建立資料庫
我們需要一個儲存聊天訊息的資料庫。可以使用MySQL或其他關係型資料庫。建立一個名為chat_messages的表，包含以下欄位：
id: 訊息的唯一識別碼
sender_id: 發送者的用戶ID
receiver_id: 接收者的用戶ID
message: 訊息內容
timestamp: 訊息傳送時間
實作即時聊天功能
使用WebSocket協定實作即時通訊。在PHP中，可以使用Ratchet或Swoole等函式庫來實作WebSocket伺服器。透過監聽客戶端的訊息和連線事件，將訊息儲存到資料庫中，並即時將訊息傳送給接收者。

以下是一個使用Ratchet庫的簡單範例：

require 'vendor/autoload.php';

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

class Chat implements MessageComponentInterface {
    protected $clients;

    public function __construct() {
        $this->clients = new SplObjectStorage;
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        // 解析接收到的消息
        $data = json_decode($msg, true);

        // 将消息保存到数据库
        $message = new ChatMessage();
        $message->sender_id = $data['sender_id'];
        $message->receiver_id = $data['receiver_id'];
        $message->message = $data['message'];
        $message->timestamp = time();
        $message->save();

        // 将消息发送给接收者
        foreach ($this->clients as $client) {
            if ($client !== $from && $client->resourceId == $data['receiver_id']) {
                $client->send($data['message']);
                break;
            }
        }
    }

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
    }

    public function onError(ConnectionInterface $conn, Exception $e) {
        $conn->close();
    }
}

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new Chat()
        )
    ),
    8080
);

$server->run();

登入後複製

#實作訊息撤回和撤銷功能
為了實現訊息撤回和撤銷功能，我們需要在資料庫表中新增一列，用於標識訊息的狀態。可以新增一個名為status的字段，用於表示訊息的狀態：
1: 正常
#2: 撤回
3: 撤銷

修改onMessage函數，在儲存訊息到資料庫之前，新增狀態欄位的設定：

$message = new ChatMessage();
$message->sender_id = $data['sender_id'];
$message->receiver_id = $data['receiver_id'];
$message->message = $data['message'];
$message->timestamp = time();
$message->status = 1; // 设置消息状态为正常
$message->save();

登入後複製

實作撤回功能，可以在客戶端發送撤回指令到伺服器，並將對應的訊息狀態設為撤回：

public function onMessage(ConnectionInterface $from, $msg) {
    // 解析接收到的消息
    $data = json_decode($msg, true);

    // 根据消息ID更新状态为撤回
    ChatMessage::where('id', $data['message_id'])
        ->update(['status' => 2]);

    // 广播撤回消息给接收者
    $this->broadcastMessage($data['message_id'], $from, $data['receiver_id']);
}

public function broadcastMessage($messageId, ConnectionInterface $from, $receiverId) {
    foreach ($this->clients as $client) {
        if ($client !== $from && $client->resourceId == $receiverId) {
            $client->send(json_encode(['action' => 'revoke', 'message_id' => $messageId]));
            break;
        }
    }
}

登入後複製

實現撤銷功能，可以在客戶端發送撤銷指令到伺服器，並將對應的訊息狀態設為撤銷：

public function onMessage(ConnectionInterface $from, $msg) {
    // 解析接收到的消息
    $data = json_decode($msg, true);

    // 根据消息ID更新状态为撤销
    ChatMessage::where('id', $data['message_id'])
        ->update(['status' => 3]);

    // 广播撤销消息给接收者
    $this->broadcastMessage($data['message_id'], $from, $data['receiver_id']);
}

public function broadcastMessage($messageId, ConnectionInterface $from, $receiverId) {
    foreach ($this->clients as $client) {
        if ($client !== $from && $client->resourceId == $receiverId) {
            $client->send(json_encode(['action' => 'revoke', 'message_id' => $messageId]));
            break;
        }
    }
}

登入後複製