Rumah >pembangunan bahagian belakang >tutorial php >Cara menggunakan PHP untuk membangunkan fungsi sembang dalam talian

Cara menggunakan PHP untuk membangunkan fungsi sembang dalam talian

WBOYasal: 2023-08-17 18:00:151622semak imbas

Dalam era Internet hari ini, pemesejan segera telah menjadi bahagian yang sangat diperlukan dalam kehidupan seharian orang ramai. Pembangunan fungsi sembang dalam talian telah menjadi keperluan penting untuk banyak laman web dan aplikasi. Artikel ini akan memperkenalkan cara menggunakan PHP untuk membangunkan fungsi sembang dalam talian yang mudah dan menyediakan sampel kod untuk rujukan.

Menggunakan PHP untuk membangunkan fungsi sembang dalam talian terutamanya melibatkan dua aspek teknologi: pembinaan muka surat hadapan dan pelaksanaan komunikasi masa nyata. Berikut ialah contoh mudah untuk menunjukkan cara membangunkan fungsi sembang dalam talian menggunakan PHP.

Pembinaan halaman hadapan

Pertama, kita perlu mencipta halaman hadapan untuk memaparkan rekod sembang dan kotak input.

<!DOCTYPE html>
<html>
<head>
    <title>在线聊天</title>
    <style>
        .container {
            border: 1px solid #ccc;
            height: 400px;
            width: 500px;
            padding: 10px;
            overflow-y: scroll;
        }
    </style>
</head>
<body>
    <div class="container" id="chatContainer"></div>
    <input type="text" id="messageInput">
    <input type="button" value="发送" onclick="sendMessage()">
</body>
<script>
    function updateChat(data) {
        document.getElementById('chatContainer').innerHTML += '<p>' + data + '</p>';
    }

    function sendMessage() {
        var message = document.getElementById('messageInput').value;
        // 向服务器发送消息的代码
    }
</script>
</html>

Kod di atas mencipta bekas untuk memaparkan sejarah sembang, kotak input untuk memasukkan mesej dan butang hantar untuk menghantar mesej. Mesej yang diterima boleh ditambahkan pada sejarah sembang melalui fungsi updateChat JavaScript.

Pelaksanaan komunikasi masa nyata

Untuk merealisasikan fungsi komunikasi masa nyata, kami akan menggunakan teknologi PHP dan WebSocket.

Pertama, buat skrip PHP untuk pelayan WebSocket di bahagian pelayan.

<?php
$host = 'localhost';
$port = '8080';

$null = NULL;

$server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_set_option($server, SOL_SOCKET, SO_REUSEADDR, 1);
socket_bind($server, 0, $port);
socket_listen($server);

$clients = array($server);

while (true) {
    $changed = $clients;
    socket_select($changed, $null, $null, 0, 10);

    if (in_array($server, $changed)) {
        $socket_new = socket_accept($server);
        $clients[] = $socket_new;

        $header = socket_read($socket_new, 1024);
        performHandshaking($header, $socket_new, $host, $port);

        socket_getpeername($socket_new, $ip);
        $response = mask(json_encode(array('type' => 'system', 'message' => $ip . ' connected.')));
        sendMessage($response);

        $found_socket = array_search($server, $changed);
        unset($changed[$found_socket]);
    }

    foreach ($changed as $changed_socket) {
        while (socket_recv($changed_socket, $buf, 1024, 0) >= 1) {
            $received_text = unmask($buf);
            $tst_msg = json_decode($received_text);
            $user_name = $tst_msg->name;
            $user_message = $tst_msg->message;
            $response_text = mask(json_encode(array('type' => 'usermsg', 'name' => $user_name, 'message' => $user_message)));
            sendMessage($response_text);
            break 2;
        }

        $buf = @socket_read($changed_socket, 1024, PHP_NORMAL_READ);
        if ($buf === false) {
            $found_socket = array_search($changed_socket, $clients);
            socket_getpeername($changed_socket, $ip);
            unset($clients[$found_socket]);
            $response = mask(json_encode(array('type' => 'system', 'message' => $ip . ' disconnected.')));
            sendMessage($response);
        }
    }
}

socket_close($server);

function sendMessage($message) {
    global $clients;
    foreach ($clients as $changed_socket) {
        @socket_write($changed_socket, $message, strlen($message));
    }
    return true;
}

function unmask($text) {
    $length = ord($text[1]) & 127;

    if ($length == 126) {
        $masks = substr($text, 4, 4);
        $data = substr($text, 8);
    } elseif ($length == 127) {
        $masks = substr($text, 10, 4);
        $data = substr($text, 14);
    } else {
        $masks = substr($text, 2, 4);
        $data = substr($text, 6);
    }

    $text = "";

    for ($i = 0; $i < strlen($data); ++$i) {
        $text .= $data[$i] ^ $masks[$i % 4];
    }

    return $text;
}

function mask($text) {
    $b1 = 0x80 | (0x1 & 0x0f);
    $length = strlen($text);

    if ($length <= 125) {
        $header = pack('CC', $b1, $length);
    } elseif ($length > 125 && $length < 65536) {
        $header = pack('CCn', $b1, 126, $length);
    } elseif ($length >= 65536) {
        $header = pack('CCNN', $b1, 127, $length);
    }

    return $header . $text;
}

function performHandshaking($receved_header, $client_conn, $host, $port) {
    $headers = array();
    $lines = preg_split("/
/", $receved_header);

    foreach ($lines as $line) {
        $line = rtrim($line);
        if (preg_match('/A(S+): (.*)z/', $line, $matches)) {
            $headers[$matches[1]] = $matches[2];
        }
    }

    $sec_key = $headers['Sec-WebSocket-Key'];
    $sec_accept = base64_encode(sha1($sec_key . "258EAFA5-E914-47DA-95CA-C5AB0DC85B11", true));

    $upgrade = "HTTP/1.1 101 Web Socket Protocol Handshake
" .
        "Upgrade: websocket
" .
        "Connection: Upgrade
" .
        "WebSocket-Origin: $host
" .
        "WebSocket-Location: ws://$host:$port/demo/shout.php
" .
        "Sec-WebSocket-Accept:$sec_accept

";

    socket_write($client_conn, $upgrade, strlen($upgrade));
}
?>

Kod di atas melaksanakan pelayan WebSocket mudah yang boleh menerima dan menghantar mesej.

Selain itu, kami juga perlu menambah kod JavaScript klien WebSocket ke halaman hadapan untuk komunikasi masa nyata dengan pelayan.

var socket = new WebSocket('ws://localhost:8080');

socket.onopen = function() {
    updateChat("连接已建立");
};

socket.onmessage = function(e) {
    updateChat(e.data);
};

socket.onclose = function() {
    updateChat("连接已关闭");
};

function sendMessage() {
    var message = document.getElementById('messageInput').value;
    socket.send(message);
    document.getElementById('messageInput').value = '';
}

function updateChat(data) {
    document.getElementById('chatContainer').innerHTML += '<p>' + data + '</p>';
}

Dalam kod di atas, kami memproses mesej yang diterima melalui pendengar acara WebSocket dan menambahkannya pada sejarah sembang. Fungsi sendMessage digunakan untuk menghantar mesej ke pelayan.

Pada ketika ini, kami telah melaksanakan fungsi sembang dalam talian yang mudah berdasarkan PHP. Melalui contoh kod di atas, saya percaya pembaca boleh mempunyai pemahaman awal tentang cara menggunakan PHP untuk membangunkan fungsi sembang dalam talian, dan boleh mengembangkan dan mengoptimumkan fungsi mengikut keperluan mereka sendiri.

Atas ialah kandungan terperinci Cara menggunakan PHP untuk membangunkan fungsi sembang dalam talian. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

php JavaScript 事件 websocket

Kenyataan：

Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn

Artikel sebelumnya：Cara menggunakan PHP untuk membangunkan fungsi pembayaran dalam talianArtikel seterusnya：Cara menggunakan PHP untuk membangunkan fungsi pembayaran dalam talian

Artikel berkaitan

Lihat lagi