Swoole의 프로세스와 스레드에 대해 얼마나 알고 계시나요?

스울레 튜토리얼 칼럼에서는 스울레의 과정과 실마리를 소개합니다.

권장(무료): swoole tutorial

Processes

1. 프로세스 간에 상태가 공유되지 않습니다
2. 프로세스 스케줄링은 운영 체제에 의해 완료됩니다
3. 각 프로세스에는 자체 독립 메모리 공간이 있습니다
4. 프로세스 간 통신은 주로 신호 ​​전송을 통해 이루어집니다. 세마포어, 파이프, 이벤트 등 다양한 구현 방법이 있습니다. 모든 방법의 통신 효율성에는 커널이 필요하므로 상대적으로 통신 효율성이 낮습니다
5. 왜냐하면 은 독립적인 메모리 공간으로 컨텍스트 전환 시 첫 번째 호출 스택의 정보, 각 CPU 레지스터의 정보, 가상 메모리 및 관련 열린 핸들 등을 저장해야 하므로 컨텍스트 프로세스 간 전환 비용이 매우 많이 들고 의사소통이 귀찮다.

Threads

1. 스레드 간 변수를 공유하면 번거로운 통신 문제가 해결됩니다. 변수에 액세스하려면 잠금이 필요합니다.
2. 프로세스는 여러 스레드를 가질 수 있지만 각 스레드는 상위 프로세스를 공유하고 운영 체제에서 리소스를 적용합니다. , 여기에는 가상 메모리, 파일 등이 포함됩니다. 공유 리소스이므로 스레드를 생성하는 데 필요한 시스템 리소스는 프로세스에 비해 훨씬 적고 해당 생성할 수 있는 스레드 수도 상대적으로 훨씬 늘어납니다.
3. 또한, 스케줄링 측면에서 메모리를 공유하기 때문에 컨텍스트 전환 시 저장해야 하는 것이 적어서 컨텍스트 전환이 효율적이 됩니다.

설명

• PHP를 통해 PHP 파일을 실행하는 것은 프로세스를 만드는 것과 같습니다. 이 프로세스는 시스템에 상주하며 자체 메모리 공간 시스템 리소스를 적용하고 해당 프로그램을 실행합니다.
  

swoole 프로세스

1. 마스터 프로세스: 메인 프로세스
2. 매니저 프로세스: 관리 프로세스
3. 워커 프로세스: 워커 프로세스
4. 태스크 프로세스: 비동기 태스크 워커 프로세스

• 첫 번째 레이어 , 마스터 프로세스, 이것이 스울의 주요 프로세스입니다. 이 프로세스는 스울 처리의 핵심 이벤트에 의해 구동됩니다. 이 프로세스에서는 MainReactor[스레드]와 여러 개의 Reactor[스레드]가 있음을 알 수 있습니다. swoole 클라이언트로부터의 연결, 신호 처리 등과 같은 이벤트 모니터링이 이러한 스레드에서 구현됩니다.

• 1.1, MainReactor(메인 스레드)
  메인 스레드는 서버 소켓을 모니터링하는 역할을 담당하며, 새로운 연결 승인이 있으면 메인 스레드는 각 Reactor 스레드의 연결 수를 평가합니다. 로드 밸런싱을 수행하려면 연결 수가 가장 적은 리액터 스레드에 이 연결을 할당하십시오.

• 1.2, Reactor 스레드 그룹
  Reactor 스레드는 클라이언트 시스템의 TCP 연결 유지, 네트워크 IO 처리, 완전 비동기 및 비차단 모드에서 데이터 송수신을 담당합니다.
  새 연결을 수락한 후 swoole의 메인 스레드는 고정된 Reactor 스레드에 연결을 할당하고, 소켓을 읽을 수 있을 때 데이터를 읽고, 프로토콜 분석을 수행하고, 요청을 작업자 프로세스에 전달합니다. 소켓에 쓰기가 가능해지면 TCP 클라이언트에 데이터를 보냅니다.

• 1.3. 하트비트 패킷 감지 스레드(HeartbeatCheck)
  Swoole이 하트비트 감지를 구성한 후 하트비트 패킷 스레드는 고정된 시간 내에 이전의 모든 온라인 연결에 감지 데이터 패킷을 보냅니다
  

• 1.4. 스레드(UdpRecv)
  클라이언트 UDP 데이터 패킷 수신 및 처리

• swoole 최고의 성능을 얻으려면 작업 처리를 돕기 위해 여러 작업자 프로세스를 만들어야 하는데 작업자 프로세스는 작업을 포크해야 하지만 포크 작업은 안전하지 않은 경우 관리가 없으면 많은 좀비 프로세스가 나타나 서버 성능에 영향을 미치며 동시에 서비스 안정성을 보장하기 위해 작업자 프로세스가 실수로 종료되거나 비정상적으로 종료됩니다. , 작업자 프로세스를 다시 생성해야 합니다.

• Swoole은 운영 중에 별도의 관리 프로세스를 생성하며 모든 작업자 프로세스와 업무 프로세스는 관리 프로세스에서 분기됩니다. 관리 프로세스는 모든 하위 프로세스의 종료 이벤트를 모니터링합니다. 작업자 프로세스에 치명적인 오류가 발생하거나 실행 중인 라이프사이클이 종료되면 관리 프로세스는 해당 프로세스를 재활용하고 새 프로세스를 생성합니다. 즉, "nanny" Manager 프로세스는 작업자 생성 및 재활용과 작업 프로세스를 관리하는 모든 권한을 갖습니다

• 작업자 프로세스는 swoole의 주요 논리 프로세스에 속합니다. 사용자는 클라이언트의 일련의 요청을 처리하고 Reactor 스레드에서 전달한 요청 패킷을 수락하며 PHP 콜백 함수를 실행하여 데이터를 처리하여 응답 데이터를 생성합니다. TCP 클라이언트는 비동기 비차단 모드 또는 동기 차단 모드일 수 있습니다

• taskWorker 프로세스는 swoole에서 제공하는 비동기 작업자 프로세스입니다. 이러한 프로세스는 주로 처리에 사용됩니다. 일부 장기간 동기 작업은 작업자 프로세스에서 전달됩니다.

클라이언트와 서버 간의 상호 작용:

1. 클라이언트 요청이 Main Reactor에 도달합니다. 클라이언트는 실제로 마스터 프로세스의 Reactor 스레드에 연결됩니다.

2. Main Reactor는 Reactor의 상황에 따라 해당 Reactor에 요청을 등록합니다. (각 Reactor에는 epoll이 있습니다. 클라이언트의 변경 사항을 모니터링하는 데 사용됩니다.)

3.클라이언트에 변경 사항이 있으면 Reactor가 데이터를 전달합니다. 처리를 위해 작업자에게

4. 작업자가 처리를 완료한 후 프로세스 간 통신(예: 파이프, 공유 메모리, 메시지 큐)을 통해 해당 리액터로 전송됩니다.

5. Reactor는 처리가 완료된 후 해당 연결 요청에 응답 결과를 보냅니다.

마스터 프로세스의 콜백 함수

• onStart 서버가 시작되고 메인 프로세스의 메인 스레드에서 이 함수를 콜백합니다.
• onShutdown 이 이벤트 서버가 정상적으로 종료될 때

Manager 프로세스의 Callback 함수

• 관리 프로세스가 시작될 때 onManagerStart가 호출됨
• 관리 프로세스가 종료될 때 onManagerStop이 호출됨
• onWorkerError 작업자/task_worker 프로세스에서 예외가 발생하는 경우 이 함수는 Manager 프로세스에서 호출됩니다

Worker 프로세스의 콜백 함수

• onWorkerStart 작업자 프로세스/태스크 프로세스가 시작될 때 발생하는 이벤트입니다.
• onWorkerStop 작업자 프로세스가 종료될 때 발생하는 이벤트입니다.
• onConnect 이 함수는 새로운 연결이 들어올 때 작업자 프로세스에서 호출됩니다.
• onClose TCP 클라이언트 연결이 닫힌 후 작업자 프로세스에서 이 함수가 호출됩니다.
• onReceive 데이터가 수신될 때 이 함수가 호출됩니다.
• onPacket 작업자 프로세스에서 발생하는 UDP 패킷을 수신할 때 호출되는 함수입니다.
• onFinish 작업자 프로세스에서 전달한 작업이 task_worker에서 완료되면 작업 프로세스에서 메시지를 보냅니다. Finish() 메소드를 통해 작업 처리 결과를 작업자 프로세스에 전달합니다.
• onWorkerExit는 reload_async 기능이 활성화된 후에만 유효합니다. 비동기 재시작 기능
• onPipeMessage sendMessage가 보낸 파이프 메시지를 작업자 프로세스가 수신하면 이벤트가 발생합니다.

Task 프로세스의 콜백 함수

• onTask가 task_worker 프로세스에서 호출됩니다. 작업자 프로세스는 swoole_server_task 함수를 사용하여 task_worker 프로세스에 새 작업을 전달할 수 있습니다
• onWorkerStart 이 이벤트는 작업자 프로세스/작업 프로세스가 시작될 때 발생합니다
• onPipeMessage 작업자 프로세스가 sendMessage

에서 보낸 파이프 메시지를 받으면 이벤트가 트리거됩니다.

간단한 설명 :

• 1. 서버 종료 프로그램이 종료되는 마지막 이벤트는 onShutdown입니다.
• 2. 서버가 성공적으로 시작된 후 onStart/onManagerStart/onWorkerStart는 순차적이 아닌 여러 프로세스에서 동시에 실행됩니다.
• 3. 모든 이벤트 콜백은 $server->start 이후에 발생합니다. 시작 이후에 작성된 코드는 유효하지 않습니다.
• 4. onStart/onManagerStart/onWorkerStart 3 이벤트의 실행 순서는 불확실합니다

swoole 실행 흐름도

<?php //tcp协议$server=new Swoole\Server("0.0.0.0",9800);   //创建server对象$server->set([
    'worker_num'=>3, //设置进程
    //'heartbeat_idle_time'=>10,//连接最大的空闲时间
    //'heartbeat_check_interval'=>3 //服务器定时检查
    'open_length_check'=>1,
    'package_length_type'=>'N',//设置包头的长度
    'package_length_offset'=>0, //包长度从哪里开始计算
    'package_body_offset'=>4,  //包体从第几个字节开始计算
    'package_max_length'=>1024 * 1024 * 2,]);$server->on("Start",function (){

    var_dump(1);
     //设置主进程的名称
     swoole_set_process_name("server-process:master");});//服务关闭时候触发(信号)$server->on("shutdown",function (){});//当管理进程启动时调用它$server->on('ManagerStart',function (){
    var_dump(2);
    //swoole_set_process_name("server-process:manger");});$server->on('WorkerStart',function ($server,$workerId){
   // swoole_set_process_name("server-process:worker");
    var_dump(3);});//监听事件,连接事件(woker进程当中)$server->on('connect',function ($server,$fd){
    echo "新的连接进入:{$fd}".PHP_EOL;});//消息发送过来(woker进程当中)$server->on('receive',function (swoole_server $server, int $fd, int $reactor_id, string $data){
    //var_dump("消息发送过来:".$data);
    //服务端});//消息关闭$server->on('close',function (){
    echo "消息关闭".PHP_EOL;});//服务器开启$server->start();echo '123456';

process

1. 프로세스 스케줄링은 운영체제에 의해 완료됩니다
3. 각 프로세스는 자신만의 독립적인 메모리 공간을 가집니다
4. 프로세스 간 통신은 주로 신호 ​​전송을 통해 이루어지며, 이벤트 등 여러 가지 구현 방법이 있습니다. 어떤 방식이든 통신 효율성은 커널을 거쳐야 하기 때문에 상대적으로 통신 효율성이 낮다. 5. 독립된 메모리 공간이므로 첫 번째 콜 스택의 정보와 각 CPU 레지스터의 정보, 가상 메모리가 필요하다. 컨텍스트 전환 시 메모리, 공개 관련 핸들 및 기타 정보가 저장되므로 컨텍스트 프로세스 간 전환에는 비용이 많이 들고 통신이 번거롭습니다.

Threads

1. 스레드 간 변수를 공유하면 통신 문제가 해결됩니다. 변수에 액세스하려면 잠금이 필요합니다
2. 프로세스는 여러 스레드를 가질 수 있지만 각 스레드는 상위 프로세스를 공유하고 운영 체제와 같은 리소스를 적용합니다. 가상 메모리, 파일 등이 포함됩니다. 공유 리소스이기 때문에 스레드를 생성하는 데 필요한 시스템 리소스는 프로세스에 비해 훨씬 적고, 해당 생성할 수 있는 스레드 수도 상대적으로 많아졌습니다.
3. 또한, 스케줄링 측면에서 메모리를 공유하기 때문에 컨텍스트 전환 시 저장해야 하는 것이 적어서 컨텍스트 전환이 효율적이 됩니다.

설명

• PHP를 통해 PHP 파일을 실행하는 것은 프로세스를 만드는 것과 같습니다. 이 프로세스는 시스템에 상주하며 자체 메모리 공간 시스템 리소스를 적용하고 해당 프로그램을 실행합니다.
  

swoole 프로세스

1. 마스터 프로세스: 메인 프로세스
2. 매니저 프로세스: 관리 프로세스
3. 워커 프로세스: 워커 프로세스
4. 태스크 프로세스: 비동기 태스크 워커 프로세스

• 첫 번째 레이어 , 마스터 프로세스, 이것이 스울의 주요 프로세스입니다. 이 프로세스는 스울 처리의 핵심 이벤트에 의해 구동됩니다. 이 프로세스에서는 MainReactor[스레드]와 여러 개의 Reactor[스레드]가 있음을 알 수 있습니다. swoole 클라이언트로부터의 연결, 신호 처리 등과 같은 이벤트 모니터링이 이러한 스레드에서 구현됩니다.

• 1.1, MainReactor(메인 스레드)
  메인 스레드는 서버 소켓을 모니터링하는 역할을 담당하며, 새로운 연결 승인이 있으면 메인 스레드는 각 Reactor 스레드의 연결 수를 평가합니다. 로드 밸런싱을 수행하려면 연결 수가 가장 적은 리액터 스레드에 이 연결을 할당하십시오.

• 1.2, Reactor 스레드 그룹
  Reactor 스레드는 클라이언트 시스템의 TCP 연결 유지, 네트워크 IO 처리, 완전 비동기 및 비차단 모드에서 데이터 송수신을 담당합니다.
  새 연결을 수락한 후 swoole의 메인 스레드는 고정된 Reactor 스레드에 연결을 할당하고, 소켓을 읽을 수 있을 때 데이터를 읽고, 프로토콜 분석을 수행하고, 요청을 작업자 프로세스에 전달합니다. 소켓에 쓰기가 가능해지면 TCP 클라이언트에 데이터를 보냅니다.

• 1.3. 하트비트 패킷 감지 스레드(HeartbeatCheck)
  Swoole이 하트비트 감지를 구성한 후 하트비트 패킷 스레드는 고정된 시간 내에 이전의 모든 온라인 연결에 감지 데이터 패킷을 보냅니다
  

• 1.4. 스레드(UdpRecv)
  클라이언트 UDP 데이터 패킷 수신 및 처리

• swoole 최고의 성능을 얻으려면 작업 처리를 돕기 위해 여러 작업자 프로세스를 만들어야 하는데 작업자 프로세스는 작업을 포크해야 하지만 포크 작업은 안전하지 않은 경우 관리가 없으면 많은 좀비 프로세스가 나타나 서버 성능에 영향을 미치며 동시에 서비스 안정성을 보장하기 위해 작업자 프로세스가 실수로 종료되거나 비정상적으로 종료됩니다. , 작업자 프로세스를 다시 생성해야 합니다.

• Swoole은 운영 중에 별도의 관리 프로세스를 생성하며 모든 작업자 프로세스와 업무 프로세스는 관리 프로세스에서 분기됩니다. 관리 프로세스는 모든 하위 프로세스의 종료 이벤트를 모니터링합니다. 작업자 프로세스에 치명적인 오류가 발생하거나 실행 중인 라이프사이클이 종료되면 관리 프로세스는 해당 프로세스를 재활용하고 새 프로세스를 생성합니다. 즉, "nanny" Manager 프로세스는 작업자 및 작업 프로세스의 생성 및 재활용을 관리하는 모든 권한을 가집니다. 작업자 프로세스는 Swoole의 주요 논리 프로세스에 속하며 사용자는 클라이언트의 일련의 요청을 처리합니다. Reactor 스레드는 요청 패킷을 전달하고 PHP 콜백 함수를 실행하여 데이터를 처리하여 응답 데이터를 생성한 다음 이를 Reactor 스레드로 보냅니다. 이를 비동기 비차단 모드로 보냅니다. 또는 동기 차단 모드

• taskWorker 프로세스 이 항목은 swoole에서 제공하는 비동기 작업 프로세스로 주로 일부 장기 동기화 작업을 처리하고 작업자 프로세스에서 전달하는 데 사용됩니다.

• 클라이언트와 서버 간의 상호 작용:

1. 클라이언트 요청이 Main Reactor에 도달합니다. 클라이언트는 실제로 마스터 프로세스의 Reactor 스레드에 연결됩니다.

2. Main Reactor는 Reactor의 상황에 따라 해당 Reactor에 요청을 등록합니다. (각 Reactor에는 epoll이 있습니다. 클라이언트의 변경 사항을 모니터링하는 데 사용됩니다.)

3.클라이언트에 변경 사항이 있으면 Reactor가 데이터를 전달합니다. 처리를 위해 작업자에게

4. 작업자가 처리를 완료한 후 프로세스 간 통신(예: 파이프, 공유 메모리, 메시지 큐)을 통해 해당 리액터로 전송됩니다.

5. Reactor는 해당 연결 요청에 대한 응답 결과를 전송하고 처리가 완료됩니다

마스터 프로세스의 콜백 함수

• onStart 서버가 시작되면 메인 프로세스의 메인 스레드에서 이 함수가 콜백됩니다.
• onShutdown 서버가 정상적으로 종료될 때 발생하는 이벤트

매니저 프로세스의 콜백 함수

• onManagerStart 관리 프로세스가 시작될 때 호출됩니다. 관리 프로세스가 종료될 때
• onManagerStop이 호출될 때 호출됩니다.
• onWorkerError 작업자/task_worker 프로세스에서 예외가 발생하면 Manager 프로세스에서 이 함수가 호출됩니다.

Callback Worker 프로세스의 함수

• onWorkerStart 이 이벤트는 Worker 프로세스에서 호출됩니다. /Task 프로세스가 시작될 때 발생합니다.
• onWorkerStop 이 이벤트는 작업자 프로세스가 종료될 때 발생합니다.
• onConnect 이 함수는 새로운 연결이 들어올 때 작업자 프로세스에서 호출됩니다.
• onClose TCP 클라이언트 연결이 닫힌 후 작업자 프로세스에서 이 함수가 호출됩니다.
• onReceive 데이터가 수신될 때 이 함수가 호출됩니다.
• onPacket 작업자 프로세스에서 발생하는 UDP 패킷을 수신할 때 호출되는 함수입니다.
• onFinish 작업자 프로세스에서 전달한 작업이 task_worker에서 완료되면 작업 프로세스에서 메시지를 보냅니다. Finish() 메소드를 통해 작업 처리 결과를 작업자 프로세스에 전달합니다.
• onWorkerExit는 reload_async 기능이 활성화된 후에만 유효합니다. 비동기 재시작 기능
• onPipeMessage sendMessage가 보낸 파이프 메시지를 작업자 프로세스가 수신하면 이벤트가 발생합니다.

Task 프로세스의 콜백 함수

• onTask가 task_worker 프로세스에서 호출됩니다. 작업자 프로세스는 swoole_server_task 함수를 사용하여 task_worker 프로세스에 새 작업을 전달할 수 있습니다
• onWorkerStart 이 이벤트는 작업자 프로세스/작업 프로세스가 시작될 때 발생합니다
• onPipeMessage 작업자 프로세스가 sendMessage

에서 보낸 파이프 메시지를 받으면 이벤트가 트리거됩니다.

간단한 설명 :

• 1. 서버 종료 프로그램이 종료되는 마지막 이벤트는 onShutdown입니다.
• 2. 서버가 성공적으로 시작된 후 onStart/onManagerStart/onWorkerStart는 순차적이 아닌 여러 프로세스에서 동시에 실행됩니다.
• 3. 모든 이벤트 콜백은 $server->start 이후에 발생합니다. 시작 이후에 작성된 코드는 유효하지 않습니다.
• 4. onStart/onManagerStart/onWorkerStart 3 이벤트의 실행 순서는 불확실합니다

swoole 작업 흐름도

<?php //tcp协议$server=new Swoole\Server("0.0.0.0",9800);   //创建server对象$server->set([
    'worker_num'=>3, //设置进程
    //'heartbeat_idle_time'=>10,//连接最大的空闲时间
    //'heartbeat_check_interval'=>3 //服务器定时检查
    'open_length_check'=>1,
    'package_length_type'=>'N',//设置包头的长度
    'package_length_offset'=>0, //包长度从哪里开始计算
    'package_body_offset'=>4,  //包体从第几个字节开始计算
    'package_max_length'=>1024 * 1024 * 2,]);$server->on("Start",function (){

    var_dump(1);
     //设置主进程的名称
     swoole_set_process_name("server-process:master");});//服务关闭时候触发(信号)$server->on("shutdown",function (){});//当管理进程启动时调用它$server->on('ManagerStart',function (){
    var_dump(2);
    //swoole_set_process_name("server-process:manger");});$server->on('WorkerStart',function ($server,$workerId){
   // swoole_set_process_name("server-process:worker");
    var_dump(3);});//监听事件,连接事件(woker进程当中)$server->on('connect',function ($server,$fd){
    echo "新的连接进入:{$fd}".PHP_EOL;});//消息发送过来(woker进程当中)$server->on('receive',function (swoole_server $server, int $fd, int $reactor_id, string $data){
    //var_dump("消息发送过来:".$data);
    //服务端});//消息关闭$server->on('close',function (){
    echo "消息关闭".PHP_EOL;});//服务器开启$server->start();echo '123456';

위 내용은 Swoole의 프로세스와 스레드에 대해 얼마나 알고 계시나요?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!