# PHP的幾種回調寫法
# PHP幾種回調寫法
PHP里通過匿名函數寫回調是最方便的,但是除了匿名函數方式的回調,PHP還有其它的回調寫法。以下是PHP幾種回調寫法的示例。
## 1、匿名函數回調
```php
<?php
use Workerman\Worker;
require_once __DIR__ . '/Workerman/Autoloader.php';
$http_worker = new Worker("http://0.0.0.0:2345");
// 匿名函數回調
$http_worker->onMessage = function($connection, $data)
{
// 向瀏覽器發送hello world
$connection->send('hello world');
};
Worker::runAll();
```
## 2、普通函數回調
```php
<?php
use Workerman\Worker;
require_once __DIR__ . '/Workerman/Autoloader.php';
$http_worker = new Worker("http://0.0.0.0:2345");
// 匿名函數回調
$http_worker->onMessage = 'on_message';
// 普通函數
function on_mesage($connection, $data)
{
// 向瀏覽器發送hello world
$connection->send('hello world');
}
Worker::runAll();
```
## 3、類方法作為回調
MyClass.php
```php
class MyClass{
public function __construct(){}
public function onWorkerStart($worker){}
public function onConnect($connection){}
public function onMessage($connection, $message) {}
public function onClose($connection){}
public function onWorkerStop($connection){}
}
```
啟動腳本 start.php
```php
<?php
use Workerman\Worker;
require_once __DIR__ . '/Workerman/Autoloader.php';
// 載入MyClass
require_once __DIR__.'/MyClass.php';
$worker = new Worker("websocket://0.0.0.0:2346");
// 創建一個對象
$my_object = new MyClass();
// 調用類的方法
$worker->onWorkerStart = array($my_object, 'onWorkerStart');
$worker->onConnect = array($my_object, 'onConnect');
$worker->onMessage = array($my_object, 'onMessage');
$worker->onClose = array($my_object, 'onClose');
$worker->onWorkerStop = array($my_object, 'onWorkerStop');
Worker::runAll();
```
注意:
以上的代碼結構不允許在構造函數里初始化資源(MySQL連接、Redis連接、Memcache連接等),因為```$my\_object = new MyClass();```運行在主進程。以MySQL為例,在主進程初始化的MySQL連接等資源會被子進程繼承,每個子進程都可以操作這個數據庫連接,但是這些連接在MySQL服務端對應的是同一個連接,會發生不可預期的錯誤,例如```mysql gone away``` 錯誤。
以上代碼結構如果需要在類的構造函數里初始化資源,可以采用以下寫法。
MyClass.php
```php
class MyClass{
protected $db = null;
public function __construct(){
// 假設數據庫連接類是MyDbClass
$db = new MyDbClass();
}
public function onWorkerStart($worker){}
public function onConnect($connection){}
public function onMessage($connection, $message) {}
public function onClose($connection){}
public function onWorkerStop($connection){}
}
```
啟動腳本 start.php
```php
<?php
use Workerman\Worker;
require_once __DIR__ . '/Workerman/Autoloader.php';
$worker = new Worker("websocket://0.0.0.0:2346");
// 在onWorkerStart里初始化類
$worker->onWorkerStart = function($worker) {
// 載入MyClass
require_once __DIR__.'/MyClass.php';
// 創建一個對象
$my_object = new MyClass();
// 調用類的方法
$worker->onConnect = array($my_object, 'onConnect');
$worker->onMessage = array($my_object, 'onMessage');
$worker->onClose = array($my_object, 'onClose');
$worker->onWorkerStop = array($my_object, 'onWorkerStop');
};
Worker::runAll();
```
上面代碼結構中onWorkerStart運行時已經是屬于子進程,等于每個子進程各自建立自己的MySQL連接,所以不會有共享連接的問題。
這樣還有一個好處就是支持業務代碼reload。由于MyClass.php是在子進程載入的,根據reload規則業務更改MyClass.php后直接reload即可生效。
## 4、類的靜態方法作為回調
靜態類MyClass.php
```php
class MyClass{
public static function onWorkerStart($worker){}
public static function onConnect($connection){}
public static function onMessage($connection, $message) {}
public static function onClose($connection){}
public static function onWorkerStop($connection){}
}
```
啟動腳本 start.php
```php
<?php
use Workerman\Worker;
require_once __DIR__ . '/Workerman/Autoloader.php';
// 載入MyClass
require_once __DIR__.'/MyClass.php';
$worker = new Worker("websocket://0.0.0.0:2346");
// 調用類的靜態方法。
$worker->onWorkerStart = array('MyClass', 'onWorkerStart');
$worker->onConnect = array('MyClass', 'onConnect');
$worker->onMessage = array('MyClass', 'onMessage');
$worker->onClose = array('MyClass', 'onClose');
$worker->onWorkerStop = array('MyClass', 'onWorkerStop');
// 如果類帶命名空間,則是類似這樣的寫法
// $worker->onWorkerStart = array('your\namesapce\MyClass', 'onWorkerStart');
// $worker->onConnect = array('your\namesapce\MyClass', 'onConnect');
// $worker->onMessage = array('your\namesapce\MyClass', 'onMessage');
// $worker->onClose = array('your\namesapce\MyClass', 'onClose');
// $worker->onWorkerStop = array('your\namesapce\MyClass', 'onWorkerStop');
Worker::runAll();
```
注意:根據PHP的運行機制,如果沒用調用new 則不會調用構造函數,另外靜態類的方法里面不允許使用```$this```。
- 序言
- 原理
- 開發必讀
- 入門指引
- 特性
- 簡單的開發示例
- 安裝
- 環境要求
- 下載安裝
- 啟動停止
- 開發流程
- 開發前必讀
- 目錄結構
- 開發規范
- 基本流程
- 通訊協議
- 通訊協議作用
- 定制通訊協議
- 一些例子
- Worker類
- 構造函數
- 屬性
- id
- count
- name
- protocol
- transport
- reusePort
- connections
- stdoutFile
- pidFile
- logFile
- user
- reloadable
- daemonize
- globalEvent
- 回調屬性
- onWorkerStart
- onWorkerReload
- onConnect
- onMessage
- onClose
- onBufferFull
- onBufferDrain
- onError
- 接口
- runAll
- stopAll
- listen
- TcpConnection類
- 屬性
- id
- protocol
- worker
- maxSendBufferSize
- defaultMaxSendBufferSize
- maxPackageSize
- 回調屬性
- onMessage
- onClose
- onBufferFull
- onBufferDrain
- onError
- 接口
- send
- getRemoteIp
- getRemotePort
- close
- destroy
- pauseRecv
- resumeRecv
- pipe
- AsyncTcpConnection類
- 構造函數
- connect
- reconnect
- transport
- Timer定時器類
- add
- del
- 定時器注意事項
- WebServer
- 調試
- 基本調試
- 查看運行狀態
- 網絡抓包
- 跟蹤系統調用
- 常用組件
- GlobalData數據共享組件
- GlobalDataServer
- GlobalDataClient
- Channel分布式通訊組件
- ChannelServer
- channelClient
- 例子-集群推送
- 例子-分組發送
- FileMonitor文件監控組件
- MySQL組件
- workerman/mysql
- swoole/mysql(異步)
- redis組件
- swoole/redis
- 異步http組件
- swoole/http-client
- 異步消息隊列組件
- react/zmq
- react/stomp
- 異步dns組件
- swoole/dns
- 常見問題
- 心跳
- 客戶端鏈接失敗原因
- 是否支持多線程
- 與其它框架整合
- 運行多個workerman
- 支持哪些協議
- 如何設置進程數
- 查看客戶端連接數
- 對象和資源的持久化
- 例子無法工作
- 啟動失敗
- 停止失敗
- 支持多少并發
- 更改代碼不生效
- 向指定客戶端發送數據
- 如何主動推送消息
- 在其它項目中推送
- 如何實現異步任務
- status里send_fail的原因
- Windows下開發Linux下部署
- 是否支持socket.io
- 終端關閉導致workerman關閉
- 與nginx apache的關系
- 禁用函數檢查
- 平滑重啟原理
- 為Flash開843端口
- 如何廣播數據
- 如何建立udp服務
- 監聽ipv6
- 關閉未認證的鏈接
- 傳輸加密-ssl/tsl
- 創建wss服務
- 創建https服務
- workerman作為客戶端
- 作為ws/wss客戶端
- PHP的幾種回調寫法
- 附錄
- Linux內核調優
- 壓力測試
- 安裝擴展
- websocket協議
- ws協議
- text協議
- frame協議
- 不支持的函數/特性
- 版權信息