Bagaimana untuk menggunakan PHP dan swoole untuk membina platform perundingan dalam talian yang sangat tersedia?-tutorial php-php.cn

Bagaimana untuk menggunakan PHP dan swoole untuk membina platform perundingan dalam talian yang sangat tersedia?

PHPz

Lepaskan： 2023-07-21 10:34:01

asal

1472 orang telah melayarinya

Bagaimana untuk menggunakan PHP dan swoole untuk membina platform perundingan dalam talian yang sangat tersedia?

Dalam era Internet hari ini, platform perundingan dalam talian menjadi pilihan pertama untuk lebih banyak syarikat dan individu. Untuk menyediakan perkhidmatan perundingan dalam talian yang cekap dan stabil, kami boleh menggunakan PHP dan swoole untuk membina platform perundingan dalam talian yang sangat tersedia.

1. Persediaan

Sebelum bermula, pastikan anda telah memasang PHP dan sambungan swoole. Anda boleh memasang sambungan swoole melalui arahan berikut:

pecl install swoole

Salin selepas log masuk

2. Buat pangkalan data

Pertama, kita perlu mencipta pangkalan data untuk menyimpan maklumat pengguna, rekod sembang dan data lain. Anda boleh menggunakan pernyataan SQL berikut untuk mencipta pangkalan data dan jadual:

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
);

Salin selepas log masuk

3 Bina pelayan

Buat fail bernama server.php sebagai kod pelayan kami. Berikut ialah contoh mudah:

<?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();

Salin selepas log masuk

4 Memproses logik log masuk

Dalam pelayan, kita perlu memproses logik log masuk pengguna. Apabila pengguna menghantar permintaan log masuk, kami perlu mengesahkan nama pengguna dan kata laluan dan mengembalikan respons yang sepadan berdasarkan hasil pengesahan. Berikut ialah contoh mudah:

// 登录逻辑
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));
}

Salin selepas log masuk

5 Memproses logik mesej

Apabila pengguna menghantar mesej, kita perlu menyimpan mesej ke pangkalan data dan menghantarnya kepada penerima yang sepadan. Berikut ialah contoh mudah:

// 消息逻辑
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));
    }
}

Salin selepas log masuk

6. Interaksi pelanggan

Akhir sekali, kita perlu menggunakan JavaScript untuk menulis halaman pelanggan untuk berinteraksi dengan pelayan. Berikut ialah contoh mudah:

<!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>

Salin selepas log masuk

Melalui langkah di atas, kami telah melengkapkan contoh kod utama yang diperlukan untuk membina platform perundingan dalam talian yang sangat tersedia menggunakan PHP dan swoole. Anda boleh menambah baik lagi fungsi mengikut keperluan sebenar dan menambah beberapa langkah pengesahan keselamatan yang diperlukan untuk memastikan kestabilan dan keselamatan platform.

Atas ialah kandungan terperinci Bagaimana untuk menggunakan PHP dan swoole untuk membina platform perundingan dalam talian yang sangat tersedia?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!