PHP를 사용하여 온라인 채팅 기능을 개발하는 방법
오늘날의 인터넷 시대에 인스턴트 메시징은 사람들의 일상 생활에서 없어서는 안 될 부분이 되었습니다. 온라인 채팅 기능의 개발은 많은 웹사이트와 애플리케이션에서 중요한 요구 사항이 되었습니다. 이 기사에서는 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 중국어 웹사이트의 기타 관련 기사를 참조하세요!