Ubuntu 22.04 Apache + PHP + Swoole 기반 WebSocket 환경 구축

sudo apt update && sudo apt install -y \ apache2 \ php \ php-cli \ php-fpm \ php-dev \ php-pear \ libcurl4-openssl-dev \ php-curl \ php-mbstring \ php-xml \ php-mysql \ php-pgsql \ php-sqlite3 \ php-gd \ php-zip \ php-json \ php-bcmath \ php-intl \ php-readline \ php-memcached \ php-redis \ php-imagick \ php-xdebug \ composer \ unzip \ git \ curl

git clone https://github.com/swoole/swoole-src.git cd swoole-src git fetch --tags git checkout v6.1.5 phpize ./configure make sudo make install

echo "extension=swoole.so" | sudo tee /etc/php/8.1/cli/conf.d/20-swoole.ini

php -m | grep swoole

cd .. rm -rf swoole-src/

<VirtualHost *:80> ServerAdmin example@domain.com ServerName example-domain.com RewriteEngine on ProxyRequests Off ProxyPreserveHost On ProxyPass /ws ws://localhost:9502/ ProxyPassReverse /ws ws://localhost:9502/ RewriteCond %{HTTP:Upgrade} =websocket [NC] RewriteRule /ws/(.*) ws://localhost:9501/$1 [P,L] ErrorLog "/var/log/apache2/example-domain.com-error.log" CustomLog "/var/log/apache2/example-domain.com-access.log" common </VirtualHost> <VirtualHost *:443> ServerAdmin example@domain.com ServerName example-domain.com SSLEngine on SSLProtocol all -SSLv2 -SSLv3 SSLCertificateKeyFile /home/example/ssl/current/example-domain_com_SHA256WITHRSA.key SSLCertificateFile /home/example/ssl/current/example-domain_com.crt SSLCACertificateFile /home/example/ssl/current/ChainCA/SectigoRSADomainValidationSecureServerCA.crt SSLCertificateChainFile /home/example/ssl/current/ChainCA/rsa-dv.chain-bundle.pem ErrorLog "/var/log/apache2/example-domain.com-ssl_error.log" CustomLog "/var/log/apache2/example-domain.com-ssl_access.log" common ProxyRequests Off ProxyPreserveHost On RequestHeader set X-Forwarded-Proto "https" RequestHeader set X-Forwarded-Ssl "on" RequestHeader set X-Forwarded-Port "443" <Location "/ws"> ProxyPass ws://localhost:9502/ timeout=300 connectiontimeout=300 keepalive=On ProxyPassReverse ws://localhost:9502/ </Location> RewriteEngine On RewriteCond %{HTTP:Upgrade} =websocket [NC] RewriteCond %{HTTP:Connection} =Upgrade [NC] RewriteRule /ws(.*) ws://localhost:9501$1 [P,L] </VirtualHost>

php websocket.php

const ws = new WebSocket("ws://localhost:9502"); ws.onopen = () => { ws.send("Hello from browser!"); }; ws.onmessage = e => { console.log("From server:", e.data); };

php 복사편집 <?php $server = new Swoole\WebSocket\Server("0.0.0.0", 9502); // Task 워커 수 지정 $server->set([ 'task_worker_num' => 4 // 병렬 처리 가능 ]); // 클라이언트 연결 시 $server->on("open", function ($server, $req) { echo "Connection opened: {$req->fd}\n"; }); // 메시지 수신 시 $server->on("message", function ($server, $frame) { echo "Received message: {$frame->data}\n"; // Task 워커에 비동기 작업 요청 (예: DB 저장) $server->task([ 'fd' => $frame->fd, 'message' => $frame->data ]); // 바로 응답 $server->push($frame->fd, "메시지를 받았습니다."); }); // Task 워커에서 처리 $server->on("task", function ($server, $task_id, $src_worker_id, $data) { echo "Task received: #{$task_id} from Worker #{$src_worker_id}\n"; // 여기서 무거운 작업 수행 (예: DB 저장, 외부 API 호출) file_put_contents("chat.log", "[{$data['fd']}] {$data['message']}\n", FILE_APPEND); // 결과 반환 return "저장 완료"; }); // Task 완료 후 메인 워커에 결과 전달 $server->on("finish", function ($server, $task_id, $data) { echo "Task #{$task_id} finished with result: {$data}\n"; }); $server->on("close", function ($server, $fd) { echo "Connection closed: {$fd}\n"; }); $server->start();