고급 Workerman 네트워크 프로그래밍: 높은 동시성 인스턴트 메시징 시스템 구현
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 중국어 웹사이트의 기타 관련 기사를 참조하세요!
핫 AI 도구
Undresser.AI Undress
사실적인 누드 사진을 만들기 위한 AI 기반 앱
AI Clothes Remover
사진에서 옷을 제거하는 온라인 AI 도구입니다.
Undress AI Tool
무료로 이미지를 벗다
Clothoff.io
AI 옷 제거제
AI Hentai Generator
AI Hentai를 무료로 생성하십시오.
인기 기사
뜨거운 도구
메모장++7.3.1
사용하기 쉬운 무료 코드 편집기
SublimeText3 중국어 버전
중국어 버전, 사용하기 매우 쉽습니다.
스튜디오 13.0.1 보내기
강력한 PHP 통합 개발 환경
드림위버 CS6
시각적 웹 개발 도구
SublimeText3 Mac 버전
신 수준의 코드 편집 소프트웨어(SublimeText3)
뜨거운 주제
7529
15
1378
52
82
11
54
19
21
76
C++ 오픈 소스 라이브러리란 무엇입니까?
Apr 22, 2024 pm 05:48 PM
C++는 다음 기능을 다루는 풍부한 오픈 소스 라이브러리 세트를 제공합니다. 데이터 구조 및 알고리즘(표준 템플릿 라이브러리) 멀티스레딩, 정규식(Boost) 선형 대수(Eigen) 그래픽 사용자 인터페이스(Qt) 컴퓨터 비전(OpenCV) 기계 학습 (TensorFlow) 암호화 (OpenSSL) 데이터 압축 (zlib) 네트워크 프로그래밍 (libcurl) 데이터베이스 관리 (sqlite3)
C++ 함수는 네트워크 프로그래밍에서 DNS 쿼리를 어떻게 처리합니까?
Apr 27, 2024 pm 06:39 PM
C++ 표준 라이브러리는 네트워크 프로그래밍에서 DNS 쿼리를 처리하는 함수를 제공합니다. gethostbyname(): 호스트 이름을 기반으로 호스트 정보를 찾습니다. gethostbyaddr(): IP 주소를 기반으로 호스트 정보를 찾습니다. dns_lookup(): DNS를 비동기적으로 확인합니다.
Java 네트워크 프로그래밍의 일반적인 프로토콜은 무엇입니까?
Apr 15, 2024 am 11:33 AM
Java 네트워크 프로그래밍에서 일반적으로 사용되는 프로토콜은 다음과 같습니다. TCP/IP: 안정적인 데이터 전송 및 연결 관리에 사용됩니다. HTTP: 웹 데이터 전송에 사용됩니다. HTTPS: 암호화를 사용하여 데이터를 전송하는 보안 버전의 HTTP입니다. UDP: 빠르지만 불안정한 데이터 전송용입니다. JDBC: 관계형 데이터베이스와 상호 작용하는 데 사용됩니다.
C++ 함수는 네트워크 프로그래밍에서 네트워크 보안을 어떻게 구현합니까?
Apr 28, 2024 am 09:06 AM
C++ 기능은 네트워크 프로그래밍에서 네트워크 보안을 달성할 수 있습니다. 1. 암호화 알고리즘(openssl)을 사용하여 통신을 암호화합니다. 2. 디지털 서명(cryptopp)을 사용하여 데이터 무결성 및 발신자 신원을 확인합니다. (htmlcxx)는 사용자 입력을 필터링하고 삭제합니다.
Java 네트워크 프로그래밍은 비연결 통신에 UDP를 어떻게 사용합니까?
Apr 15, 2024 pm 12:51 PM
UDP(사용자 데이터그램 프로토콜)는 시간에 민감한 애플리케이션에 일반적으로 사용되는 경량의 비연결 네트워크 프로토콜입니다. 이를 통해 애플리케이션은 TCP 연결을 설정하지 않고도 데이터를 보내고 받을 수 있습니다. 샘플 Java 코드를 사용하여 UDP 서버 및 클라이언트를 생성할 수 있습니다. 서버는 들어오는 데이터그램을 수신하고 응답하며, 클라이언트는 메시지를 보내고 응답을 받습니다. 이 코드는 채팅 애플리케이션이나 데이터 수집 시스템과 같은 실제 사용 사례를 구축하는 데 사용될 수 있습니다.
동시성 높은 시스템의 Golang 프레임워크 아키텍처
Jun 03, 2024 pm 05:14 PM
동시성이 높은 시스템의 경우 Go 프레임워크는 파이프라인 모드, Goroutine 풀 모드 및 메시지 대기열 모드와 같은 아키텍처 모드를 제공합니다. 실제 사례에서 동시성이 높은 웹사이트는 Nginx 프록시, Golang 게이트웨이, Goroutine 풀 및 데이터베이스를 사용하여 많은 수의 동시 요청을 처리합니다. 코드 예제는 들어오는 요청을 처리하기 위한 Goroutine 풀의 구현을 보여줍니다. 적절한 아키텍처 패턴과 구현을 선택함으로써 Go 프레임워크는 확장 가능하고 동시에 높은 동시성 시스템을 구축할 수 있습니다.
Java 기본부터 실제 애플리케이션까지: 빠르게 시작하는 방법은 무엇입니까?
May 08, 2024 am 08:30 AM
Java 입문 가이드: 기본 구문 소개(변수, 연산자, 제어 흐름, 객체, 클래스, 메서드, 상속, 다형성, 캡슐화), 핵심 Java 클래스 라이브러리(예외 처리, 컬렉션, 제네릭, 입력/출력 스트림, 네트워크 프로그래밍, 날짜 및 시간 API), 실제 사례(코드 예제를 포함한 계산기 애플리케이션).
높은 동시성 시나리오에서 PHP 프레임워크의 성능
Jun 06, 2024 am 10:25 AM
벤치마크 테스트에 따르면 높은 동시성 시나리오에서 PHP 프레임워크의 성능은 Phalcon(RPS2200), Laravel(RPS1800), CodeIgniter(RPS2000) 및 Symfony(RPS1500)입니다. 실제 사례에서는 전자상거래 웹사이트의 Double Eleven 이벤트 기간 동안 Phalcon 프레임워크가 초당 3,000건의 주문을 달성한 것으로 나타났습니다.
