## swoole_event_add
swoole_event_add函數用于將一個socket加入到swoole的reactor事件監聽中。此函數可以用在Server或Client模式下。
~~~
bool swoole_event_add(int $sock, mixed $read_callback, mixed $write_callback = null, int $flags = null);
~~~
參數1可以為以下三種類型:
* int,就是文件描述符,包括swoole_client的socket,以及第三方擴展的socket(比如mysql)
* stream資源,就是stream_socket_client/fsockopen 創建的資源
* sockets資源,就是sockets擴展中 socket_create創建的資源,需要在編譯時加入 ./configure --enable-sockets
參數2為可讀回調函數,參數3為可寫事件回調,可以是字符串函數名、對象+方法、類靜態方法或匿名函數,當此socket可讀時回調指定的函數。
參數4為事件類型的掩碼,可選擇關閉/開啟可讀可寫事件,如SWOOLE_EVENT_READ,SWOOLE_EVENT_WRITE,或者SWOOLE_EVENT_READ | SWOOLE_EVENT_WRITE
> swoole_event_add在swoole1.6.2+之后可用
> 第3,4個參數在1.7.1版本后可用,用于監聽可寫事件回調,以及設置讀寫事件的監聽
在Server程序中使用,可以理解為在worker/taskworker進程中將此socket注冊到epoll事件中。
在Client程序中使用,可以理解為在客戶端進程中將此socket注冊到epoll事件中。
~~~
$fp = stream_socket_client("tcp://www.qq.com:80", $errno, $errstr, 30);
fwrite($fp,"GET / HTTP/1.1\r\nHost: www.qq.com\r\n\r\n");
swoole_event_add($fp, function($fp) {
$resp = fread($fp, 8192);
//socket處理完成后,從epoll事件中移除socket
swoole_event_del($fp);
fclose($fp);
});
echo "Finish\n"; //swoole_event_add不會阻塞進程,這行代碼會順序執行
~~~
### 回調函數
* 在可讀事件回調函數中必須使用fread、recv等函數讀取Socket緩存區中的數據,否則事件會持續觸發,如果不希望繼續讀取必須使用Swoole\Event::del移除事件監聽
* 在可寫事件回調函數中,寫入socket之后必須調用Swoole\Event::del移除事件監聽,否則可寫事件會持續觸發
* 執行fread、socekt_recv、socket_read、Swoole\Client::recv返回false,并且錯誤碼為EAGAIN時表示當前Socket接收緩存區內沒有任何數據,這時需要加入可讀監聽等待EventLoop通知
* 執行fwrite、socket_write、socket_send、Swoole\Client::send操作返回false,并且錯誤碼為EAGAIN時表示當前Socket發送緩存區已滿,暫時不能發送數據。需要監聽可寫事件等待EventLoop通知
- swoole簡介
- swoole功能概述
- 序章
- 開發必讀
- 1 環境搭建
- 1.1 環境搭建
- 1.2 搭建Echo服務器
- 2 初識Swoole
- 2.1 Worker進程
- 2.2 TaskWorker進程
- 2.3 Timer定時器
- 2.4 Process進程
- 2.5 Table內存表
- 2.6 多端口監聽
- 2.7 sendfile文件支持
- 2.8 SSL支持
- 2.9 熱重啟
- 2.10 http_server
- 附錄*server配置
- 附錄*server函數
- 附錄*server屬性
- 附錄*server回調函數
- 附錄*server高級特性
- 心跳檢測
- 3 Swoole協議
- 3.1 EOF協議
- 3.2 固定包頭協議
- 3.3 Http協議
- 3.4 WebSocket協議
- 3.5 MTQQ協議
- 內置http_server
- 內置websocket_server
- Swoole\Redis\Server
- 4 Swoole異步IO
- 4.1 AsyncIO
- 異步文件系統IO
- swoole_async_readfile
- swoole_async_writefile
- swoole_async_read
- swoole_async_write
- 5 swoole異步客戶端
- ws_client
- http_client
- mysql_client
- redis_client
- tcp_client
- http2_client
- 6 swoole協程
- Swoole\Coroutine\Http\Client
- Swoole\Coroutine\MySQL
- Swoole\Coroutine\Redis
- Coroutine\PostgreSQL
- Swoole\Coroutine\Client
- Swoole\Coroutine\Socket
- Swoole\Coroutine\Channel
- Coroutine
- Swoole\Coroutine::create
- Swoole\Coroutine::resume
- Swoole\Coroutine::suspend
- Swoole\Coroutine::sleep
- Coroutine::getaddrinfo
- Coroutine::gethostbyname
- swoole_async_dns_lookup_coro
- Swoole\Coroutine::getuid
- getDefer
- setDefer
- recv
- Coroutine::stats
- Coroutine::fread
- Coroutine::fget
- Coroutine::fwrite
- Coroutine::readFIle
- Coroutine::writeFIle
- Coroutine::exec
- 7 swoole_process
- process::construct
- process::start
- process::name
- process::signal
- process::setaffinity
- process::exit
- process::kill
- process::daemon
- process->exec
- process::wait
- process::alarm
- 8 swoole定時器
- swoole_timer_tick
- swoole_timer_after
- swoole_timer_clear
- 9 swoole_event
- swoole_event_add
- swoole_event_set
- swoole_event_del
- swoole_event_wait
- swoole_event_defer
- swoole_event_write
- swoole_event_exit
- swoole提供的function
- 常見問題
- 客戶端鏈接失敗原因
- 如何設置進程數
- 如何實現異步任務
- 如何選擇swoole三種模式
- php中哪些函數是阻塞的
- 是否可以共用1個redis或mysql連接
- 如何在回調函數中訪問外部的變量
- 為什么不要send完后立即close
- 不同的Server程序實例間如何通信
- MySQL的連接池、異步、斷線重連
- 在php-fpm或apache中使用swoole
- 學習Swoole需要掌握哪些基礎知識
- 在phpinfo中有在php-m中沒有
- 同步阻塞與異步非阻塞選擇
- CURL發送POST請求服務器端超時
- 附錄
- 預定義常量
- 內核參數調優
- php四種回調寫法
- 守護進程程序常用數據結構
- swoole生命周期
- swoole_server中內存管理機制
- 使用jemalloc優化swoole內存分配性能
- Reactor、Worker、Task的關系
- Manager進程
- Swoole的實現
- Reactor線程
- 安裝擴展
- swoole-worker手冊
- swoole相關開源項目
- 寫在后面的話
- 版本更新記錄
- 4.0