4.5 同步任务
最后更新于：2022-03-31 23:47:26
# 4.5 同步任务
同步任务即Task,用来做一些异步的慢速任务,比如发邮件、批量任何、任何不支持异步Client的服务调用等等。MSF框架是纯异步Server架构,也就是说任何耗时的任务的代码不能放到Worker进程中执行,所以我们利用Swoole的Task模块来完成耗时任务。
## Task进程
同步任务代码是在Task进程中执行的,Task进程具有以下的特性:
- 同步阻塞
- 支持定时器
目前MSF框架封装了异步的Http Client、Redis Client、MySQL Client,除了这几种原生支持异步外,任何其他的非异步Client的网络IO均要封装成Task,比如MongoDB Task。
## Task示例
框架内封装了Task基类`\PG\MSF\Tasks\Task`,自定义的Task都应该继承此类。另外,框架内置一个MongoDbTask类,是操作MongoDB的任务类,封装了查询和修改MongoDB数据库的一些基本方法,如:
### composer安装依赖
编辑项目的composer.json，加入依赖`alcaeus/mongo-php-adapter`
```json
{
"require": {
"alcaeus/mongo-php-adapter": "^1.0"
}
}
```
或者
```bash
$composer require alcaeus/mongo-php-adapter
```
### MongoDB配置
```php
<?php
/**
* MongoDb配置文件
*
* @author camera360_server@camera360.com
* @copyright Chengdu pinguo Technology Co.,Ltd.
*/
$config['mongodb']['test']['server'] = 'mongodb://192.168.1.106:27017';
$config['mongodb']['test']['options'] = ['connect' => true];
$config['mongodb']['test']['driverOptions'] = [];
return $config;
```
示例代码:
[./php-msf-demo/config/docker/mongodb.php](https://github.com/pinguo/php-msf/pinguo/config/docker/mongodb.php)
### Task业务逻辑类
```php
<?php
namespace App\Tasks;
use \PG\MSF\Tasks\MongoDbTask;
class Idallloc extends MongoDbTask
{
/**
* 当前要用的配置 配置名，db名，collection名
* @var array
*/
protected $mongoConf = ['test', 'demo', 'idalloc'];
public function getNextId($key)
{
$condition = [
'_id' => $key,
];
$update = [
'$inc' => [
'last' => 1,
],
];
$options = [
'new' => true,
'upsert' => true,
];
$doc = $this->mongoCollection->findAndModify($condition, $update, [], $options);
return isset($doc['last']) ? $doc['last'] : false;
}
}
```
示例代码:
[https://github.com/pinguo/php-msf-demo/app/Tasks/Idallloc.php](https://github.com/pinguo/php-msf-demo/blob/master/app/Tasks/Idallloc.php)
### 调用Task
```php
<?php
/**
* MongoDB操作示例
*
* @author camera360_server@camera360.com
* @copyright Chengdu pinguo Technology Co.,Ltd.
*/
namespace App\Controllers;
use PG\MSF\Controllers\Controller;
use App\Tasks\Idallloc;
class MongoDBTest extends Controller
{
public function actionGetNewId()
{
/**
* @var Idallloc $idAlloc
*/
$idAlloc = $this->getObject(Idallloc::class);
$newId = yield $idAlloc->getNextId('test');
$this->output($newId);
}
}
```
示例代码:
[https://github.com/pinguo/php-msf-demo/app/Controllers/MongoDBTest.php](https://github.com/pinguo/php-msf-demo/blob/master/app/Controllers/MongoDBTest.php)
我们需要认识到：
1. Worker进程只是将任务投递给Tasker进程后立即返回，即是非阻塞的投递；
2. Tasker进程执行相应的业务逻辑，在这里就是从MongoDB获取新的一个ID；
3. Worker进程是通过协程获取到Tasker执行结果，即调用需要加yield关键字；
### 访问接口
```bash
[worker@newdev ~]$ curl http://127.0.0.1:8000/MongoDBTest/GetNewId
1
```