PHP 기반 실시간 채팅 시스템의 메시지 철회 및 철회 기능

PHP 기반 실시간 채팅 시스템의 메시지 철회 및 취소 기능

소개:
인터넷의 급속한 발전과 대중화로 인해 실시간 채팅 시스템은 일상생활에서 사람들이 소통하는 중요한 수단이 되었습니다. . 채팅 시스템을 개발할 때 메시지 회수 및 취소 기능을 구현하는 것은 일반적인 요구 사항입니다. 이 기사에서는 PHP를 사용하여 WebSocket 기반 실시간 채팅 시스템을 작성하고 메시지 철회 및 취소 기능을 구현하는 방법을 소개합니다.

1. 환경 구축
   먼저 PHP 환경과 WebSocket 서비스를 설정해야 합니다. Laravel 또는 Symfony와 같은 PHP 프레임워크를 사용하거나 PHP의 기본 WebSocket 라이브러리를 직접 사용하도록 선택할 수 있습니다. 프레임워크에서는 Composer를 사용하여 종속성을 관리할 수 있습니다.
2. Create Database
   채팅 메시지를 저장하려면 데이터베이스가 필요합니다. MySQL 또는 기타 관계형 데이터베이스를 사용할 수 있습니다. 다음 필드를 포함하는 chat_messages라는 테이블을 생성합니다.
3. id: 메시지의 고유 식별자
4. sender_id: 보낸 사람의 사용자 ID
5. receiver_id: 받는 사람의 사용자 ID
6. message: 메시지 내용
7. timestamp: 메시지 보내기 time
8. 실시간 채팅 기능
   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();

4. 메시지 철회 및 철회 기능 구현
   메시지 철회 및 철회 기능을 구현하려면 데이터베이스 테이블에 열을 추가하여 상태를 식별해야 합니다. 메시지. 메시지 상태를 나타내기 위해 status라는 필드를 추가할 수 있습니다.
5. 1: 정상
6. 2: 철회
7. 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;
        }
    }
}

5. 클라이언트측 처리
   클라이언트측에서는 반환된 메시지 상태에 따라 메시지가 철회되었는지 취소되었는지를 적절하게 표시합니다.

요약:
이 기사에서는 PHP를 사용하여 WebSocket 기반 실시간 채팅 시스템을 구축하고 메시지 철회 및 취소 기능을 구현하는 방법을 소개합니다. 이러한 기능은 Ratchet 라이브러리와 데이터베이스를 사용하여 메시지를 저장하고 처리함으로써 쉽게 구현할 수 있습니다. 실제 프로젝트에서는 필요에 따라 해당 확장 및 최적화를 수행할 수 있습니다.

위 내용은 PHP 기반 실시간 채팅 시스템의 메시지 철회 및 철회 기능의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!