swoole_process實現進程池的方法示例

 更新時間:2018年10月29日 09:52:56   作者:opso   我要評論

這篇文章主要介紹了swoole_process實現進程池的方法示例,小編覺得挺不錯的,現在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧

swoole —— 重新定義PHP

swoole 的進程之間有兩種通信方式,一種是消息隊列(queue),另一種是管道(pipe),對swoole_process 的研究在swoole中顯得尤為重要。

預備知識

IO多路復用

swoole 中的io多路復用表現為底層的 epoll進程模型,在C語言中表現為 epoll 函數。

  • epoll 模型下會持續監聽自己名下的素有socket 描述符 fd
  • 當觸發了 socket 監聽的事件時,epoll 函數才會響應,并返回所有監聽該時間的 socket 集合
  • epoll 的本質是阻塞IO,它的優點在于能同事處理大量socket連接

Event loop 事件循環

swoole 對 epoll 實現了一個Reactor線程模型封裝,設置了read事件和write事件的監聽回調函數。(詳見swoole_event_add)

  • Event loop 是一個Reactor線程,其中運行了一個epoll實例。
  • 通過swoole_event_add將socket描述符的一個事件添加到epoll監聽中,事件發生時將執行回調函數
  • 不可用于fpm環境下,因為fpm在任務結束時可能會關掉進程。

swoole_process

  • 基于C語言封裝的進程管理模塊,方便php來調用
  • 內置管道、消息隊列接口,方便實現進程間通信

我們在php-fpm.conf配置文件中發現,php-fpm中有兩種進程池管理設置。

  • 靜態模式 即初始化固定的進程數,當來了一個請求時,從中選取一個進程來處理。
  • 動態模式 指定最小、最大進程數,當請求量過大,進程數不超過最大限制時,新增線程去處理請求

接下來用swoole代碼來實現,這里只是為理解swoole_process、進程間通信、定時器等使用,實際情況使用封裝好的swoole_server來實現task任務隊列池會更方便。

假如有個定時投遞的任務隊列:

<?php

/**
 * 動態進程池,類似fpm
 * 動態新建進程
 * 有初始進程數,最小進程數,進程不夠處理時候新建進程,不超過最大進程數
 */

// 一個進程定時投遞任務

/**
 * 1. tick
 * 2. process及其管道通訊
 * 3. event loop 事件循環
 */
class processPool
{
  private $pool;

  /**
   * @var swoole_process[] 記錄所有worker的process對象
   */
  private $workers = [];

  /**
   * @var array 記錄worker工作狀態
   */
  private $used_workers = [];

  /**
   * @var int 最小進程數
   */
  private $min_woker_num = 5;

  /**
   * @var int 初始進程數
   */
  private $start_worker_num = 10;

  /**
   * @var int 最大進程數
   */
  private $max_woker_num = 20;

  /**
   * 進程閑置銷毀秒數
   * @var int
   */
  private $idle_seconds = 5;

  /**
   * @var int 當前進程數
   */
  private $curr_num;

  /**
   * 閑置進程時間戳
   * @var array
   */
  private $active_time = [];

  public function __construct()
  {
    $this->pool = new swoole_process(function () {
      // 循環建立worker進程
      for ($i = 0; $i < $this->start_worker_num; $i++) {
        $this->createWorker();
      }
      echo '初始化進程數:' . $this->curr_num . PHP_EOL;
      // 每秒定時往閑置的worker的管道中投遞任務
      swoole_timer_tick(1000, function ($timer_id) {
        static $count = 0;
        $count++;
        $need_create = true;
        foreach ($this->used_workers as $pid => $used) {
          if ($used == 0) {
            $need_create = false;
            $this->workers[$pid]->write($count . ' job');
            // 標記使用中
            $this->used_workers[$pid] = 1;
            $this->active_time[$pid] = time();
            break;
          }
        }
        foreach ($this->used_workers as $pid => $used)
          // 如果所有worker隊列都沒有閑置的,則新建一個worker來處理
          if ($need_create && $this->curr_num < $this->max_woker_num) {
            $new_pid = $this->createWorker();
            $this->workers[$new_pid]->write($count . ' job');
            $this->used_workers[$new_pid] = 1;
            $this->active_time[$new_pid] = time();
          }

        // 閑置超過一段時間則銷毀進程
        foreach ($this->active_time as $pid => $timestamp) {
          if ((time() - $timestamp) > $this->idle_seconds && $this->curr_num > $this->min_woker_num) {
            // 銷毀該進程
            if (isset($this->workers[$pid]) && $this->workers[$pid] instanceof swoole_process) {
              $this->workers[$pid]->write('exit');
              unset($this->workers[$pid]);
              $this->curr_num = count($this->workers);
              unset($this->used_workers[$pid]);
              unset($this->active_time[$pid]);
              echo "{$pid} destroyed\n";
              break;
            }
          }
        }

        echo "任務{$count}/{$this->curr_num}\n";

        if ($count == 20) {
          foreach ($this->workers as $pid => $worker) {
            $worker->write('exit');
          }
          // 關閉定時器
          swoole_timer_clear($timer_id);
          // 退出進程池
          $this->pool->exit(0);
          exit();
        }
      });

    });

    $master_pid = $this->pool->start();
    echo "Master $master_pid start\n";

    while ($ret = swoole_process::wait()) {
      $pid = $ret['pid'];
      echo "process {$pid} existed\n";
    }
  }

  /**
   * 創建一個新進程
   * @return int 新進程的pid
   */
  public function createWorker()
  {
    $worker_process = new swoole_process(function (swoole_process $worker) {
      // 給子進程管道綁定事件
      swoole_event_add($worker->pipe, function ($pipe) use ($worker) {
        $data = trim($worker->read());
        if ($data == 'exit') {
          $worker->exit(0);
          exit();
        }
        echo "{$worker->pid} 正在處理 {$data}\n";
        sleep(5);
        // 返回結果,表示空閑
        $worker->write("complete");
      });
    });

    $worker_pid = $worker_process->start();

    // 給父進程管道綁定事件
    swoole_event_add($worker_process->pipe, function ($pipe) use ($worker_process) {
      $data = trim($worker_process->read());
      if ($data == 'complete') {
        // 標記為空閑
//        echo "{$worker_process->pid} 空閑了\n";
        $this->used_workers[$worker_process->pid] = 0;
      }
    });

    // 保存process對象
    $this->workers[$worker_pid] = $worker_process;
    // 標記為空閑
    $this->used_workers[$worker_pid] = 0;
    $this->active_time[$worker_pid] = time();
    $this->curr_num = count($this->workers);
    return $worker_pid;
  }

}

new processPool();

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。

您可能感興趣的文章:

相關文章

  • 老生常談php中傳統驗證與thinkphp框架(必看篇)

    老生常談php中傳統驗證與thinkphp框架(必看篇)

    下面小編就為大家帶來一篇老生常談php中傳統驗證與thinkphp框架(必看篇)。小編覺得挺不錯的,現在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-06-06
  • PHP實現鏈式操作的核心思想

    PHP實現鏈式操作的核心思想

    這篇文章主要介紹了PHP實現鏈式操作的核心思想,本文著重講解它的核心思想,比較直觀明子,需要的朋友可以參考下
    2015-06-06
  • symfony2.4的twig中date用法分析

    symfony2.4的twig中date用法分析

    這篇文章主要介紹了symfony2.4的twig中date用法,結合實例形式分析了twig中針對日期與時間操作的常見方法,需要的朋友可以參考下
    2016-03-03
  • php 無限分類 樹形數據格式化代碼

    php 無限分類 樹形數據格式化代碼

    這篇文章主要介紹了php 無限分類 樹形數據格式化代碼,需要的朋友可以參考下
    2016-10-10
  • PHP獲取當前URL路徑的處理方法(適用于多條件篩選列表)

    PHP獲取當前URL路徑的處理方法(適用于多條件篩選列表)

    下面小編就為大家帶來一篇PHP獲取當前URL路徑的處理方法(適用于多條件篩選列表)。小編覺得挺不錯的,現在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-02-02
  • 詳解PHP歸并排序的實現

    詳解PHP歸并排序的實現

    本文主要介紹了php歸并排序的實現算法,即把待排序序列分為若干個有序的子序列,再把有序的子序列合并為整體有序序列。有興趣的朋友可以來了解一下。
    2016-10-10
  • PHP網頁游戲學習之Xnova(ogame)源碼解讀(十四)

    PHP網頁游戲學習之Xnova(ogame)源碼解讀(十四)

    這篇文章主要介紹了PHP網頁游戲Xnova(ogame)源碼解讀的資源更新頁面部分,需要的朋友可以參考下
    2014-06-06
  • 利用Laravel生成Gravatar頭像地址的優雅方法

    利用Laravel生成Gravatar頭像地址的優雅方法

    Gravatar是一圖像跟隨著您到訪過的網站,當您在博客中留言或發表文章,它將會出現在您的名稱旁。下面這篇文章主要給大家介紹了關于利用Laravel如何生成 Gravatar 頭像地址的優雅方法,需要的朋友可以參考下。
    2017-12-12
  • php操縱mysqli數據庫的實現方法

    php操縱mysqli數據庫的實現方法

    下面小編就為大家帶來一篇php操縱mysqli數據庫的實現方法。小編覺得挺不錯的,現在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2016-09-09
  • PHP微信紅包生成代碼分享

    PHP微信紅包生成代碼分享

    這篇文章主要介紹了PHP微信紅包API接口,針對PHP微信公眾號自動發送紅包API,PHP微信紅包API接口的主要代碼進行分析,感興趣的小伙伴們可以參考一下
    2016-10-10

最新評論

时时彩包赢公式0369