집 > 기사 > 백엔드 개발 > PHP를 사용하여 온라인 채팅 기능을 개발하는 방법

PHP를 사용하여 온라인 채팅 기능을 개발하는 방법

WBOY원래의: 2023-08-17 18:00:151534검색

오늘날의 인터넷 시대에 인스턴트 메시징은 사람들의 일상 생활에서 없어서는 안 될 부분이 되었습니다. 온라인 채팅 기능의 개발은 많은 웹사이트와 애플리케이션에서 중요한 요구 사항이 되었습니다. 이 기사에서는 PHP를 사용하여 간단한 온라인 채팅 기능을 개발하는 방법을 소개하고 참조용 코드 샘플을 제공합니다.

PHP를 사용하여 온라인 채팅 기능을 개발하는 데에는 주로 프런트엔드 페이지 구축과 실시간 커뮤니케이션 구현이라는 두 가지 기술 측면이 포함됩니다. 다음은 PHP를 사용하여 온라인 채팅 기능을 개발하는 방법을 보여주는 간단한 예입니다.

프런트엔드 페이지 구성

먼저 채팅 기록과 입력란을 표시할 프런트엔드 페이지를 만들어야 합니다.

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

위 코드는 채팅 기록을 표시하는 컨테이너, 메시지를 입력하기 위한 입력 상자, 메시지를 보내기 위한 보내기 버튼을 생성합니다. 받은 메시지는 JavaScript의 updateChat 기능을 통해 채팅 기록에 추가할 수 있습니다.

실시간 통신 구현

실시간 통신 기능을 구현하기 위해 PHP와 WebSocket 기술을 사용하겠습니다.

먼저 서버 측에서 WebSocket 서버용 PHP 스크립트를 만듭니다.

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

위 코드는 메시지를 수락하고 보낼 수 있는 간단한 WebSocket 서버를 구현합니다.

또한 서버와의 실시간 통신을 위해 프런트엔드 페이지에 WebSocket 클라이언트 JavaScript 코드를 추가해야 합니다.

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>';
}

위 코드에서는 WebSocket의 이벤트 리스너를 통해 수신된 메시지를 처리하고 채팅 기록에 추가합니다. sendMessage 함수는 서버에 메시지를 보내는 데 사용됩니다.

이제 PHP를 기반으로 간단한 온라인 채팅 기능을 구현해봤습니다. 위의 샘플 코드를 통해 독자들은 PHP를 사용하여 온라인 채팅 기능을 개발하는 방법을 미리 이해하고 필요에 따라 기능을 확장하고 최적화할 수 있다고 믿습니다.

위 내용은 PHP를 사용하여 온라인 채팅 기능을 개발하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

php JavaScript 事件 websocket

성명：

이전 기사：PHP를 사용하여 온라인 결제 기능을 개발하는 방법다음 기사：PHP를 사용하여 온라인 결제 기능을 개발하는 방법