고급 Workerman 네트워크 프로그래밍: 높은 동시성 인스턴트 메시징 시스템 구현
- WBOY원래의
- 2023-08-05 16:09:071055검색
Advanced Workerman 네트워크 프로그래밍: 높은 동시성 인스턴트 메시징 시스템 구현
모바일 인터넷의 인기로 인해 인스턴트 메시징 시스템은 우리 삶에서 점점 더 중요한 역할을 하고 있습니다. 동시성 인스턴트 메시징 시스템을 구현하는 것은 네트워크 프로그래밍을 배우는 데 중요한 이정표입니다. 본 글에서는 Workerman 프레임워크를 사용하여 동시성이 높은 인스턴트 메시징 시스템을 구현하고 코드 예제를 통해 구현 프로세스를 자세히 소개합니다.
먼저 Workerman 프레임워크를 설치해야 합니다. Workerman은 경량 PHP 비동기 네트워크 프로그래밍 프레임워크로, 풍부한 네트워크 프로그래밍 기능을 제공하며 동시성 인스턴트 메시징 시스템 구현에 대한 요구 사항을 충족할 수 있습니다. Workerman은 작곡가를 통해 설치하고 다음 명령을 실행할 수 있습니다:
composer require workerman/workerman
설치가 완료된 후, 동시성이 높은 인스턴트 메시징 시스템을 구현하기 위한 코드 작성을 시작할 수 있습니다.
- 서버 클래스 만들기
먼저 클라이언트 연결과 메시지 전송을 처리하는 서버 클래스를 만듭니다. 코드 예시는 다음과 같습니다.
use WorkermanWorker;
class ChatServer
{
protected $clients;
public function __construct()
{
$this->clients = new SplObjectStorage;
$ws_worker = new Worker('websocket://0.0.0.0:8000');
$ws_worker->onConnect = function($connection) {
$this->clients->attach($connection);
echo "New client connected
";
};
$ws_worker->onMessage = function($connection, $data) {
// 处理接收到的消息
foreach ($this->clients as $client) {
$client->send($data);
}
};
$ws_worker->onClose = function($connection) {
$this->clients->detach($connection);
echo "Client disconnected
";
};
Worker::runAll();
}
}
new ChatServer();위 코드에서는 먼저 Workerman Worker 객체를 생성하고 청취 주소와 포트를 websocket://0.0.0.0:8000으로 설정합니다. 그런 다음 클라이언트의 연결, 수신된 메시지 및 연결 해제를 각각 처리하기 위해 세 개의 콜백 함수가 정의됩니다. onConnect 콜백 함수에서는 SplObjectStorage를 사용하여 모든 클라이언트 연결 개체를 저장합니다. onMessage 콜백 함수에서는 모든 클라이언트 연결 개체를 반복하고 수신된 메시지를 각 클라이언트에 보냅니다. onClose 콜백 함수에서는 SplObjectStorage에서 연결이 끊긴 클라이언트 개체를 삭제합니다.
- 클라이언트 페이지 만들기
다음으로 서버에 연결하고 메시지를 주고받을 클라이언트 페이지를 만듭니다. 코드 예시는 다음과 같습니다.
<!DOCTYPE html>
<html>
<head>
<title>Chat App</title>
<style>
#messages {
height: 300px;
overflow-y: scroll;
}
</style>
</head>
<body>
<div id="messages"></div>
<form id="form">
<input type="text" id="message" autocomplete="off">
<button>Send</button>
</form>
<script>
const messages = document.getElementById('messages');
const form = document.getElementById('form');
const input = document.getElementById('message');
const ws = new WebSocket('ws://localhost:8000');
ws.onopen = function() {
console.log('Connected to the server');
};
ws.onmessage = function(event) {
const message = document.createElement('div');
message.textContent = event.data;
messages.appendChild(message);
};
form.addEventListener('submit', function(event) {
event.preventDefault();
const message = input.value;
input.value = '';
ws.send(message);
});
</script>
</body>
</html>위 코드에서는 websocket 연결 개체를 생성하고 서버 주소 ws://localhost:8000에 연결합니다. 그런 다음 onopen, onmessage 및 submit 이벤트에 대한 핸들러 함수가 정의됩니다. onmessage 콜백 함수에서는 div 요소를 만들고 받은 메시지를 div 요소에 추가한 다음 페이지의 message 요소에 div 요소를 추가합니다. 제출 이벤트의 핸들러 함수에서 입력 상자의 텍스트를 가져와 서버로 보냅니다.
- 코드 실행
위의 두 코드를 각각 server.php 및 client.html 파일로 저장하세요. 명령줄에서 다음 명령을 실행하세요.
php server.php start
그런 다음 브라우저에서 client.html 파일을 엽니다. WebSocket을 통해 구현된 인스턴트 메시징 시스템 페이지에 액세스할 수 있습니다. 여러 클라이언트가 서버에 연결되면 메시지가 실시간으로 전송되어 메시지 목록에 표시될 수 있습니다.
요약:
위의 코드 예제를 통해 서버 클래스 생성부터 클라이언트 페이지 생성까지 Workerman 프레임워크 기반의 높은 동시성 인스턴트 메시징 시스템을 구현했습니다. 이 예제를 연구함으로써 우리는 네트워크 프로그래밍의 높은 동시성 처리에 대해 더 깊이 이해하게 되었습니다. 동시에 우리는 강력한 네트워크 애플리케이션을 더 빠르게 개발할 수 있게 해주는 Workerman 프레임워크의 강력함과 단순성에 대해서도 배웠습니다. 이 글이 여러분이 네트워크 프로그래밍을 배우고 Workerman 프레임워크를 사용하는 데 도움이 되기를 바랍니다.
위 내용은 고급 Workerman 네트워크 프로그래밍: 높은 동시성 인스턴트 메시징 시스템 구현의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!