引入背景：假如我们每天有10000个订单生成，需要同步到仓储系统中去，以前做法是开启一个crontab去跑这些任务，但是发现总有感觉同步效率低，间隔时间都是分钟级别的。

解决方案测试：我们将同步订单的任务表添加一个hash作为key，作为分发条件，因为mysql中select如果做mod函数是用不到索引的，所以我们自己做随机hash，但是务必不需要范围太大，以免服务器资源不够，方法是根据hashkey投放到不同的进程中进行同步，测试代码如下

<?php
/**
 * Created by PhpStorm.
 * User: xujun
 * Date: 2017/8/26
 * Time: 9:37
 */
//假定需要处理的数据如下
class Process{
  public $mpid=0;
  public $max_precess=5;
  //代替从数据库中读取的内容
  public $task = [
    ['uid'=>1,'uname'=>'bot','hash'=>1,'handle'=>'test'],
    ['uid'=>2,'uname'=>'bot1','hash'=>2,'handle'=>'test'],
    ['uid'=>3,'uname'=>'bot2','hash'=>3,'handle'=>'test'],
    ['uid'=>4,'uname'=>'bot3','hash'=>4,'handle'=>'test'],
    ['uid'=>2,'uname'=>'bot4','hash'=>2,'handle'=>'test'],
    ['uid'=>3,'uname'=>'bot5','hash'=>3,'handle'=>'test'],
    ['uid'=>4,'uname'=>'bot6','hash'=>1,'handle'=>'test'],
  ];
  public $works = [];
  public $swoole_table = NULL;
  //public $new_index=0;
  function test($index,$task){
    print_r("[".date('Y-m-d H:i:s')."]".'work-index:'.$index.'处理'.$task['uname'].'完成'.PHP_EOL);
  }

  public function __construct(){
    try {
      $this->swoole_table = new swoole_table(1024);
      $this->swoole_table->column('index', swoole_table::TYPE_INT);//用于父子进程间数据交换
      $this->swoole_table->create();

      swoole_set_process_name(sprintf('php-ps:%s', 'master'));
      $this->mpid = posix_getpid();
      $this->run();
      $this->processWait();
    }catch (\Exception $e){
      die('ALL ERROR: '.$e->getMessage());
    }
  }

  public function run(){
    for ($i=0; $i < $this->max_precess; $i++) {
      $this->CreateProcess();
    }
  }

  private function getTask($index){
    $_return = [];
    foreach ($this->task as $v){
      if($v['hash']==$index){
        $_return[] = $v;
      }
    }
    return $_return;
  }

  public function CreateProcess($index=null){
    if(is_null($index)){//如果没有指定了索引，新建的子进程，开启计数
      $index=$this->swoole_table->get('index');
      if($index === false){
        $index = 0;
      }else{
        $index = $index['index']+1;
      }
      print_r($index);
    }
    $this->swoole_table->set('index',array('index'=>$index));
    $process = new swoole_process(function(swoole_process $worker)use($index){

      swoole_set_process_name(sprintf('php-ps:%s',$index));
      $task = $this->getTask($index);
      foreach ($task as $v){
        call_user_func_array(array($this,$v['handle']),array($index,$v));
      }
      sleep(20);
    }, false, false);
    $pid=$process->start();

    $this->works[$index]=$pid;
    return $pid;
  }

  public function rebootProcess($ret){
    $pid=$ret['pid'];
    $index=array_search($pid, $this->works);
    if($index!==false){
      $index=intval($index);
      $new_pid=$this->CreateProcess($index);
      echo "rebootProcess: {$index}={$new_pid} Done\n";
      return;
    }
    throw new \Exception('rebootProcess Error: no pid');
  }

  public function processWait(){
    while(1) {
      if(count($this->works)){
        $ret = swoole_process::wait();
        if ($ret) {
          $this->rebootProcess($ret);
        }
      }else{
        break;
      }
    }
  }

}
$process = new Process();

这里代码中，使用了swoole_table作为进程间共享的内存，为了分配index。以及当进程退出后，父进程通过wait重新拉起该进程任务。

测试截图

进程ps

结果 休眠20s后退出后会被自动拉起

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

# PHP  # swoole  # process  # PHP swoole中使用task进程异步的处理耗时任务应用案例分析  # php swoole多进程/多线程用法示例【基于php7nts版】  # PHP基于swoole多进程操作示例  # PHP swoole中http_server的配置与使用方法实例分析  # PHP使用swoole编写简单的echo服务器示例  # php安装swoole扩展的方法  # php异步多线程swoole用法实例  # PHP的swoole扩展安装方法详细教程  # 使用swoole扩展php websocket示例  # PHP框架Swoole定时器Timer特性分析  # PHP+swoole实现简单多人在线聊天群发  # PHP swoole的process模块创建和使用子进程操作示例  # 拉起  # 都是  # 不需要  # 太大  # 如果没有  # 中去  # 后会  # 数据库中  # 大家多多  # 数据交换  # 使用了  # uid  # function  # bot  # uname  # gt  # public 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： 公司门户网站制作公司有哪些,怎样使用wordpress制作一个企业网站？  nginx修改上传文件大小限制的方法  香港代理服务器配置指南：高匿IP选择、跨境加速与SEO优化技巧  如何获取上海专业网站定制建站电话？  使用豆包 AI 辅助进行简单网页 HTML 结构设计  Laravel如何清理系统缓存命令_Laravel清除路由配置及视图缓存的方法【总结】  Laravel如何使用Telescope进行调试？（安装和使用教程）  Laravel用户认证怎么做_Laravel Breeze脚手架快速实现登录注册功能  安克发布新款氮化镓充电宝：体积缩小 30%，支持 200W 输出  手机怎么制作网站教程步骤,手机怎么做自己的网页链接？  Laravel Telescope怎么调试_使用Laravel Telescope进行应用监控与调试  Microsoft Edge如何解决网页加载问题 Edge浏览器加载问题修复  如何自定义safari浏览器工具栏？个性化设置safari浏览器界面教程【技巧】  网站制作怎么样才能赚钱,用自己的电脑做服务器架设网站有什么利弊，能赚钱吗？  Laravel任务队列怎么用_Laravel Queues异步处理任务提升应用性能  HTML透明颜色代码怎么让下拉菜单透明_下拉菜单透明背景指南【技巧】  如何快速生成橙子建站落地页链接？  googleplay官方入口在哪里_Google Play官方商店快速入口指南  Win11任务栏卡死怎么办 Windows11任务栏无反应解决方法【教程】  EditPlus中的正则表达式 实战(4)  Laravel如何实现API版本控制_Laravel API版本化路由设计策略  海南网站制作公司有哪些,海口网是哪家的？  Laravel如何使用Livewire构建动态组件？（入门代码）  php json中文编码为null的解决办法  详解Android中Activity的四大启动模式实验简述  如何用ChatGPT准备面试 模拟面试问答与职场话术练习教程  专业商城网站制作公司有哪些,pi商城官网是哪个？  如何快速配置高效服务器建站软件？  个人摄影网站制作流程,摄影爱好者都去什么网站？  高防服务器租用指南：配置选择与快速部署攻略  Laravel模型事件有哪些_Laravel Model Event生命周期详解  Linux系统运维自动化项目教程_Ansible批量管理实战  Android滚轮选择时间控件使用详解  如何用虚拟主机快速搭建网站？详细步骤解析  Laravel路由Route怎么设置_Laravel基础路由定义与参数传递规则【详解】  如何在香港服务器上快速搭建免备案网站？  如何用JavaScript实现文本编辑器_光标和选区怎么处理  php读取心率传感器数据怎么弄_php获取max30100的心率值【指南】  Swift开发中switch语句值绑定模式  如何在腾讯云服务器上快速搭建个人网站？  如何快速搭建支持数据库操作的智能建站平台？  深圳网站制作平台,深圳市做网站好的公司有哪些？  Laravel如何使用Collections进行数据处理？（实用方法示例）  网站视频制作书签怎么做,ie浏览器怎么将网站固定在书签工具栏？  Laravel用户密码怎么加密_Laravel Hash门面使用教程  Laravel怎么自定义错误页面_Laravel修改404和500页面模板  javascript中的try catch异常捕获机制用法分析  油猴 教程,油猴搜脚本为什么会网页无法显示？  如何用wdcp快速搭建高效网站？  laravel怎么配置和使用PHP-FPM来优化性能_laravel PHP-FPM配置与性能优化方法