#task
通過加載器加載并返回一個task的代理。
函數原型
```php
/**
* 獲取一個task
* @param $task
* @return mixed|null|TaskProxy
* @throws SwooleException
*/
public function task($task)
```
其中$task是Task的類名,根據SD的傳統該類優先在app/Tasks中尋找,如果不存在則在Server/Tasks中尋找。
例子:
```php
public function test_task()
{
$testTask = $this->loader->task('TestTask');
$testTask->test();
$testTask->startTask(null);
}
```
需要注意$this->loader->task('TestTask')返回的并不是TestTask的實例,其實返回的是一個TaskProxy,這個TaskProxy是個單例模式,所以調用task的時候不要對TaskProxy緩存,隨時用隨時獲取。
TestTask有個test方法,雖然說$testTask是個TaskProxy,但你可以把他當做是TestTask調用方法。
TaskProxy和Task的更加深入的用法見具體章節。
# Task
Task是異步任務模塊服務于controller和model。
1.7以后的版本,Task中可以使用協程,所以寫法和Model基本一致。
Task類在task進程中是單例,每種類只會實例化一次。
## TaskProxy
> controller和model中獲取的Task其實是TaskProxy
* startTask
```php
/**
* 開始異步任務
*/
function startTask($callback,$id = -1)
```
* startTaskWait
```php
/**
* 開始同步任務
*/
function startTaskWait($timeOurt = 0.5, $id = -1)
```
## Controller和Model中的用法
AppTask.php
```php
class AppTask extends Task
{
public function testTask()
{
return "test task\n";
}
}
```
AppController.php
```php
class AppController extends Controller
{
public function http_test_task()
{
$AppTask = $this->loader->task('AppTask');
$AppTask->testTask();
$AppTask->startTask(function ($serv, $task_id, $data) {
$this->http_output->end($data);
});
}
}
```
## TimerTask的用法
添加到配置文件timerTask.php中
```php
$config['timerTask'][] = [
'task_name'=>'AppTask',
'method_name'=>'testTask',
'start_time'=>'Y-m-d 00:00:00',
'end_time'=>'Y-m-d 23:59:59',
'interval_time'=>'2',
];
```
## 協程模式
示例:
```php
$task = $this->loader->task('TestTask');
$task->test();
$result = yield $task->coroutineSend();
```
使用協程會大大簡化代碼的書寫,提高代碼的可讀性。
上面的代碼通過yield關鍵字返回了異步回調的值。
_
**如果你的task是沒有結果返回的,請不要用協程,這樣會超時。**_
##Task層級
1.7.4版本支持深層級的Task。
```php
$this->testTask = $this->loader->task('Test/TestTask');
```
如上會調用Test目錄下TestTask,請注意命名空間的規范。
在1.7.4版本之前需要這樣
```php
$this->testTask = $this->loader->task('Test\\TestTask');
- Introduction
- SD 3.X文檔連接
- 導言
- 用戶案例
- 基于Swoole擴展分布式全棧開發框架
- 選擇SD框架助力企業開發
- 捐贈SwooleDistributed項目
- 框架性能報告
- 更新日志
- VIP服務福利
- 安裝與配置
- 【推薦】全自動安裝部署
- 環境要求
- 使用Composer安裝/更新SD框架
- 通過Docker安裝
- 代碼結構
- 啟動命令
- 服務器配置
- 服務器基礎配置server.php
- 客戶端協議配置client.php
- business.php
- log.php
- 微服務及集群配置consul.php
- fileHeader.php
- mysql.php
- redis.php
- 定時任務配置timerTask.php
- 服務器端口配置ports.php
- catCache.php
- 驗證服務啟動成功
- 微服務-Consul
- 日志工具-GrayLog
- 集群-Cluster
- 內核優化
- 入門教學
- 開發流程
- 開發前必讀
- 開發規范
- 基本流程
- 框架入口
- Model數據模型
- Controller控制器
- 協程
- 協程基礎
- 迭代器
- 調度器
- 使用協程的優勢
- 通過協程的方法屏蔽異步同步的區別
- Select多路選擇器
- 協程Sleep
- 通用協程方法
- 設置超時
- 設置無異常
- 設置降級函數
- initAsynPools
- dump
- 封裝器與路由器
- 封裝器
- sendToUid
- 路由器
- sendToUids
- 對象池
- 擴展組件
- 中間件
- Redis使用介紹
- RedisAsynPool
- Redis具體使用
- sendToAll
- RedisRoute
- Redis+Lua
- Mysql使用介紹
- MysqlAsynPool
- Mysql返回值
- 如何獲取構建的mysql語句
- 如何執行一個SQL
- 如何執行事務
- stopTask
- Mysql具體使用
- 異步客戶端
- Loader
- MqttClient
- model
- SdTcpRpcPool
- task
- HttpClientPool
- view
- TcpClientPool
- AMQP
- initialization
- Memory
- destory
- Cache
- Lock
- Pool
- EventDispatcher
- Process
- Cluster
- TimerTask
- Reload
- Consul
- Context
- 自定義進程
- 進程間RPC
- $http_input
- CatCache
- $http_output
- TimerCallBack
- 專題
- HTTP專欄
- TCP專欄
- 基礎知識
- WebSocket專欄
- 微服務
- Consul配置
- RPC
- REST
- AMQP異步任務系統
- MQTT簡易服務器
- Docker化以及資源編排
- 快速搭建公司內部統一的開發環境
- 使用HTTPS/WSS
- 訂閱/發布
- 游戲專題
- 類介紹
- AppServer
- clearState
- onOpenServiceInitialization
- SwooleDistributedServer
- get_instance
- kickUid
- bindUid
- unBindUid
- coroutineUidIsOnline
- coroutineCountOnline
- setTemplateEngine
- isWebSocket
- isTaskWorker
- getSocketName
- initAsynPools
- addAsynPool
- getAsynPool
- getServerAllTaskMessage
- Controller
- onExceptionHandle
- send
- sendToUid
- sendToUids
- sendToAll
- sendToGroup
- close
- getContext
- defaultMethod
- $redis_pool
- $mysql_pool
- $request_type
- $fd
- $uid
- $client_data
- $request
- $response
- $loader
- $logger
- $server
- $config
- Model
- initialization
- destory
- View
- Task
- stopTask
- HttpInput
- postGet
- post
- get
- getPost
- getAllPostGet
- getAllHeader
- getRawContent
- cookie
- getRequestHeader
- server信息
- getRequestMethod
- getRequestUri
- getPathInfo
- HttpOutput
- setStatusHeader
- setContentType
- setHeader
- end
- setCookie
- endFile
- 單元測試