사용자 정의 프로세스

webman에서는 workerman과 마찬가지로 사용자 정의 리스너 또는 프로세스를 만들 수 있습니다.

주의
Windows 사용자는 사용자 정의 프로세스를 시작하려면 php windows.php를 사용하여 webman을 시작해야 합니다.

사용자 정의 HTTP 서비스

때로는 webman HTTP 서비스의 코어 코드를 변경해야 할 특별한 요구사항이 있을 수 있습니다. 이 경우, 사용자 정의 프로세스를 통해 구현할 수 있습니다.

예를 들어, app\Server.php를 생성합니다.

<?php

namespace app;

use Webman\App;

class Server extends App
{
    // 여기에서 Webman\App의 메소드를 덮어쓰기합니다.
}

config/process.php에 다음 구성을 추가합니다.

use Workerman\Worker;

return [
    // ... 다른 구성들은 생략...

    'my-http' => [
        'handler' => app\Server::class,
        'listen' => 'http://0.0.0.0:8686',
        'count' => 8, // 프로세스 수
        'user' => '',
        'group' => '',
        'reusePort' => true,
        'constructor' => [
            'request_class' => \support\Request::class, // 요청 클래스 설정
            'logger' => \support\Log::channel('default'), // 로그 인스턴스
            'app_path' => app_path(), // 앱 디렉토리 위치
            'public_path' => public_path() // 퍼블릭 디렉토리 위치
        ]
    ]
];

팁
webman에서 기본 제공하는 HTTP 프로세스를 종료하려면 config/server.php에서 listen=>''로 설정하면 됩니다.

사용자 정의 웹소켓 리스너 예제

app/Pusher.php를 생성합니다.

<?php
namespace app;

use Workerman\Connection\TcpConnection;

class Pusher
{
    public function onConnect(TcpConnection $connection)
    {
        echo "onConnect\n";
    }

    public function onWebSocketConnect(TcpConnection $connection, $http_buffer)
    {
        echo "onWebSocketConnect\n";
    }

    public function onMessage(TcpConnection $connection, $data)
    {
        $connection->send($data);
    }

    public function onClose(TcpConnection $connection)
    {
        echo "onClose\n";
    }
}

참고: 모든 onXXX 속성은 public입니다.

config/process.php에 다음 구성을 추가합니다.

return [
    // ... 다른 프로세스 구성은 생략 ...

    'websocket_test' => [
        'handler' => app\Pusher::class,
        'listen'  => 'websocket://0.0.0.0:8888',
        'count'   => 1,
    ],
];

사용자 정의 리스너가 아닌 프로세스 예제

app/TaskTest.php를 생성합니다.

<?php
namespace app;

use Workerman\Timer;
use support\Db;

class TaskTest
{
    public function onWorkerStart()
    {
        // 10초마다 새로 등록된 사용자가 있는지 데이터베이스를 확인합니다.
        Timer::add(10, function(){
            Db::table('users')->where('regist_timestamp', '>', time()-10)->get();
        });
    }
}

config/process.php에 다음 구성을 추가합니다.

return [
    // ... 다른 프로세스 구성은 생략...

    'task' => [
        'handler'  => app\TaskTest::class
    ],
];

주의: listen을 생략하면 어떤 포트도 리스닝하지 않으며, count를 생략하면 프로세스 수가 기본적으로 1로 설정됩니다.

구성 파일 설명

프로세스의 완전한 구성은 다음과 같습니다.

return [
    // ... 

    // websocket_test는 프로세스 이름입니다.
    'websocket_test' => [
        // 여기에서 프로세스 클래스가 지정됩니다.
        'handler' => app\Pusher::class,
        // 리스닝 프로토콜, IP 및 포트 (선택 사항)
        'listen'  => 'websocket://0.0.0.0:8888',
        // 프로세스 수 (선택 사항, 기본값 1)
        'count'   => 2,
        // 프로세스 실행 사용자 (선택 사항, 기본값 현재 사용자)
        'user'    => '',
        // 프로세스 실행 사용자 그룹 (선택 사항, 기본값 현재 사용자 그룹)
        'group'   => '',
        // 현재 프로세스가 reload를 지원하는지 여부 (선택 사항, 기본값 true)
        'reloadable' => true,
        // reusePort 활성화 여부 (선택 사항, PHP>=7.0에서 기본값은 true)
        'reusePort'  => true,
        // transport (선택 사항, ssl을 사용해야 할 경우 ssl로 설정, 기본값은 tcp)
        'transport'  => 'tcp',
        // context (선택 사항, transport가 ssl인 경우 인증서 경로를 전달해야 함)
        'context'    => [], 
        // 프로세스 클래스 생성자 매개변수, 여기서는 process\Pusher::class 클래스의 생성자 매개변수 (선택 사항)
        'constructor' => [],
    ],
];

요약

webman의 사용자 정의 프로세스는 사실상 workerman의 간단한 래핑으로, 구성과 비즈니스를 분리하고 workerman의 onXXX 콜백을 클래스 메소드로 구현했을 뿐입니다. 다른 용도로의 사용은 완전히 workerman과 동일합니다.