PHP와 Swoole을 사용하여 가용성이 높은 온라인 상담 플랫폼을 구축하는 방법은 무엇입니까?-PHP 튜토리얼-php.cn

PHP와 Swoole을 사용하여 가용성이 높은 온라인 상담 플랫폼을 구축하는 방법은 무엇입니까?

오늘날의 인터넷 시대에 온라인 상담 플랫폼은 점점 더 많은 기업과 개인에게 첫 번째 선택이 되고 있습니다. 효율적이고 안정적인 온라인 상담 서비스를 제공하기 위해 PHP와 Swoole을 활용하여 가용성이 높은 온라인 상담 플랫폼을 구축할 수 있습니다.

1. 준비

시작하기 전에 PHP와 Swoole Extension이 설치되어 있는지 확인하세요. 다음 명령을 통해 swoole 확장 프로그램을 설치할 수 있습니다:

1	`pecl install swoole`

로그인 후 복사

2. 데이터베이스 생성

먼저 사용자 정보, 채팅 기록 및 기타 데이터를 저장할 데이터베이스를 생성해야 합니다. 다음 SQL 문을 사용하여 데이터베이스와 테이블을 만들 수 있습니다.

CREATE DATABASE online_consulting;
USE online_consulting;
 
CREATE TABLE users (
    id INT PRIMARY KEY AUTO_INCREMENT,
    username VARCHAR(255) NOT NULL,
    password VARCHAR(255) NOT NULL
);
 
CREATE TABLE messages (
    id INT PRIMARY KEY AUTO_INCREMENT,
    sender_id INT NOT NULL,
    receiver_id INT NOT NULL,
    message VARCHAR(255) NOT NULL,
    timestamp INT NOT NULL
);

로그인 후 복사

3. 서버 구축

서버 코드로 server.php라는 파일을 만듭니다. 다음은 간단한 예입니다.

<?php
 
$server = new SwooleWebSocketServer('0.0.0.0', 9501);
 
$server->on('open', function ($server, $request) {
    echo "New client connected: {$request->fd}
";
});
 
$server->on('message', function ($server, $frame) {
    $data = json_decode($frame->data, true);
 
    switch ($data['type']) {
        case 'login':
            // 处理登录逻辑
            break;
 
        case 'message':
            // 处理消息逻辑
            break;
    }
});
 
$server->on('close', function ($server, $fd) {
    echo "Client disconnected: {$fd}
";
});
 
$server->start();

로그인 후 복사

4. 로그인 로직 처리

서버에서는 사용자의 로그인 로직을 처리해야 합니다. 사용자가 로그인 요청을 보내면 사용자 이름과 비밀번호를 확인하고 확인 결과에 따라 해당 응답을 반환해야 합니다. 다음은 간단한 예입니다.

// 登录逻辑
function handleLogin($server, $frame, $data) {
    $username = $data['username'];
    $password = $data['password'];
 
    // 从数据库中查询用户信息
    $user = queryUserByUsername($username);
 
    if (!$user || $user['password'] !== $password) {
        // 登录失败
        $response = [
            'type' => 'login',
            'success' => false,
            'message' => 'Invalid username or password'
        ];
    } else {
        // 登录成功
        $response = [
            'type' => 'login',
            'success' => true,
            'message' => 'Login successful'
        ];
    }
 
    $server->push($frame->fd, json_encode($response));
}

로그인 후 복사

5. 메시지 처리 논리

사용자가 메시지를 보낼 때 메시지를 데이터베이스에 저장하고 해당 수신자에게 보내야 합니다. 다음은 간단한 예입니다.

// 消息逻辑
function handleMessage($server, $frame, $data) {
    $senderId = $data['sender_id'];
    $receiverId = $data['receiver_id'];
    $message = $data['message'];
    $timestamp = time();
 
    // 将消息保存到数据库
    saveMessage($senderId, $receiverId, $message, $timestamp);
 
    // 发送消息给接收者
    $receiverFd = getUserFdById($receiverId);
 
    if ($receiverFd !== null) {
        $response = [
            'type' => 'message',
            'sender_id' => $senderId,
            'receiver_id' => $receiverId,
            'message' => $message,
            'timestamp' => $timestamp
        ];
 
        $server->push($receiverFd, json_encode($response));
    }
}

로그인 후 복사

6. 클라이언트 상호 작용

마지막으로 JavaScript를 사용하여 서버와 상호 작용하는 클라이언트 페이지를 작성해야 합니다. 다음은 간단한 예시입니다.

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Online Consulting Platform</title>
</head>
<body>
    <input type="text" id="username" placeholder="Username">
    <input type="password" id="password" placeholder="Password">
    <button onclick="login()">Login</button>
 
    <input type="text" id="message" placeholder="Message">
    <button onclick="sendMessage()">Send</button>
 
    <ul id="messages"></ul>
 
    <script>
        const socket = new WebSocket('ws://localhost:9501');
 
        socket.onopen = function() {
            console.log('Connected to server');
        };
 
        socket.onmessage = function(event) {
            const data = JSON.parse(event.data);
 
            switch (data.type) {
                case 'login':
                    if (data.success) {
                        console.log('Login successful');
                    } else {
                        console.log('Login failed: ' + data.message);
                    }
                    break;
 
                case 'message':
                    const li = document.createElement('li');
                    li.innerHTML = data.sender_id + ': ' + data.message;
                    document.getElementById('messages').appendChild(li);
                    break;
            }
        };
 
        function login() {
            const username = document.getElementById('username').value;
            const password = document.getElementById('password').value;
 
            const data = {
                type: 'login',
                username: username,
                password: password
            };
 
            socket.send(JSON.stringify(data));
        }
 
        function sendMessage() {
            const senderId = 1; // 从数据库中获取当前用户ID
            const receiverId = 2; // 从数据库中获取接收者ID
            const message = document.getElementById('message').value;
 
            const data = {
                type: 'message',
                sender_id: senderId,
                receiver_id: receiverId,
                message: message
            };
 
            socket.send(JSON.stringify(data));
        }
    </script>
</body>
</html>