swoole_task_redis可控制任务进程数，单个任务执行时间: redis\rabbbit可控制task多任务进程数，每个进程执行时间，任务都是redis缓存，子进程最长执行时间，

# 基于swoole的多进程任务消耗框架

#### 介绍
1、可控制task每个任务进程数，根据自己的硬件配置合理选择适当的任务进程数，有效的消耗任务。

2、每个进程执行时间可设置警告，可记录日志

3、任务都是redis,rabbitmq缓存，完全异步，生产者和消费者分开，

4、可设置子进程最长执行时间，防止内存泄漏，

5、支持thinkphp5.1 ORM 数据操作，提高效率，快速开发

6、支持api方式推送任务进入队列，

7、服务器错误日志统计，

8、可控制定时检查队列长度，如果队列超过预设值将会报警功能，

9、一个进程对应一个数据库连接，避免数据连接数过多，可以在一个进程里面设置，断线重连接。

#### 安装教程

1、安装php环境和swoole2.0以下扩展，

2、php swoole_job.php start|stop|restart

3、兼容高版本swoole有效方式
`    修改php.ini 增加 swoole.enable_coroutine = 'Off'`

####使用教程

1、  多个数据库配置

```
 Db::setConfig(['type'            => 'mysql',
                // 服务器地址
                'hostname'        => '127.0.0.1',
                // 数据库名
                'database'        => 'code',
                // 用户名
                'username'        => 'root',
                // 密码
                'password'        => '****',
                // 端口
                'hostport'        => '3306',
                // 连接dsn
                'dsn'             => '',
                // 数据库连接参数
                'params'          => [],
                 // 数据库调试模式
              //  'debug'           => true,

// 数据库编码默认采用utf8
                'charset'         => 'utf8',
                 // 是否需要断线重连
                'break_reconnect' => true,
                // 数据库表前缀
                'prefix'          => 'xyh_',
                 'db1'            =>  [
                    // 数据库类型
                    'type'        => 'mysql',
                    // 服务器地址
                    'hostname'    => 'xxx.xxx.xxx.xxx',
                    // 数据库名
                    'database'    => 'xxxx',
                    // 数据库用户名
                    'username'    => '***',
                    // 数据库密码
                    'password'    => '****',
                    // 端口
                    'hostport'        => '3306',
                    // 数据库编码默认采用utf8
                    'charset'     => 'utf8',
                     // 是否需要断线重连
                    'break_reconnect' => true,
                    // 数据库表前缀
                    'prefix'      => 'dsc_',
                ]
        ]）;
```

2、数据库操作

多个数据库切换：

```
    Db::name('code')->find();

Db::connect('db1')->name('seller_commission_bill')->select();
```

使用操作跟thinkphp5.1 ORM一样，

3、任务添加

```
<?php
define('SWOOLE_XYH_PATH', __DIR__ );

date_default_timezone_set('Asia/Shanghai');

require SWOOLE_XYH_PATH . '/Xphp/Kcloze/Loader.php';

use Kcloze\Jobs\JobObject;
use Kcloze\Jobs\Logs;
use Kcloze\Jobs\Queue\BaseTopicQueue;
use Kcloze\Jobs\Queue\Queue;

$config        = require_once SWOOLE_XYH_PATH . '/config.php';
$logger        = Logs::getLogger($config['logPath'] ?? '', $config['logSaveFileApp'] ?? '');
$queue         =Queue::getQueue($config['job']['queue'], $logger);

$queue->setTopics($config['job']['topics']);

if (!$queue) {
    die("queue object is null\n");
}

//jobs的topic需要在配置文件里面定义，并且一次性注册进去
$topics = $queue->getTopics();
//var_dump($topics); exit;
$delay                 = 0;
$priority              = BaseTopicQueue::HIGH_LEVEL_1;
$jobExtras['delay']    = $delay;
$jobExtras['priority'] = $priority;
$job                   = new JobObject('MyJob', '\Controller\JobAction', 'test1', ['测试1', time()], $jobExtras);
$result                = $queue->push('MyJob', $job, 1, 'json');
var_dump($result);
```

4、报警方式

微信模板和客服推送消息

```
    /**
     *功能：微信推送
     */
    function httpPost($url, $data){        
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_HEADER, 0);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
        return curl_exec($ch);
    }

$openid =  'oWtej08afx7tTyq1xYlGW2VUbcWk';

$content = '你的内容';

//客服
    $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=wx0b9a7f1edd2b3&secret=f68efaaf9864ff1bb837ea3f90b";
    $access_token = json_decode(file_get_contents($url))->access_token;
    $apiUrl='https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token=';
    $apiUrl = $apiUrl.$access_token;
    $data = '{
            "touser":"'.$openid.'",
            "msgtype":"text",
            "text":
            {
                "content":"'.$content.'"
            }
         }';

//推送模板
    $apiUrl = 'https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=';   
    $apiUrl = $apiUrl.$access_token;

$title = "推送测试";
    $data = array('1245', '7845', '4564');
    $foot = "准备";

$data = '{
                "touser":"oWtej08afx7tTyq1xYlGW2VUbcWk",//微信openID
                "template_id":"ZaAAEGSzT4SUy-jQ4bNNmwI58aasbf7X_kTKd1axawg",//模板id
                "url":"http://www.baidu.com",//点击跳转地址
                "data":{//模板数据
                    "first":{"value":"'.$title.'","color":"#173177"},
                    "keyword1":{"value":"'.$data[0].'","color":"#173177"},
                    "keyword2":{"value":"'.$data[1].'","color":"#173177"},
                    "keyword3":{"value":"'.$data[2].'","color":"#173177"},
                    "remark":{"value":"'.$foot.'","color":"#173177"}
                }
             }';

$data  = httpPost($apiUrl, $data);
    $data  = json_decode($data);  
```

#### 注意

1、数据库性能，数据库CPU跑100%，表结构，索引，等导致数据查询更改操作耗时，

2、swoole任务进程数，不宜过多，过多会导致CPU资源不够，无法正常切换，内存也会增加，

3、合理配置进程数，和数据库，防止CPU，内存爆满，

4、数据库最好不是本地的，不然CPU很容易跑满，

不多话，先生/swoole_task_redis可控制任务进程数，单个任务执行时间

简介

发行版

贡献者

近期动态

不多话，先生/swoole_task_redis可控制任务进程数，单个任务执行时间 .gitee-modal { width: 500px !important; }

简介

发行版

贡献者

近期动态

搜索帮助

不多话，先生/swoole_task_redis可控制任务进程数，单个任务执行时间