# 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 $event_flag = null); ~~~ 参数1可以为以下三种类型： - int，就是文件描述符,包括swoole_client的socket,以及第三方扩展的socket（比如mysql） - stream资源，就是stream_socket_client/fsockopen 创建的资源 - sockets资源，就是sockets扩展中 socket_create创建的资源需要在编译时加入 ./configure --enable-sockets 参数2为可读回调函数，参数3为可写事件回调，可以是字符串函数名、对象+方法、类静态方法或匿名函数，当此socket可读时回调指定的函数。 > swoole_event_add在swoole1.6.2+之后可用 第3，4个参数在1.7.1版本后可用，用于监听可写事件回调，以及设置读写事件的监听 参数4为事件类型的掩码，可选择关闭/开启可读可写事件，如SWOOLE_EVENT_READ，SWOOLE_EVENT_WRITE，或者SWOOLE_EVENT_READ | SWOOLE_EVENT_WRITE 在Server程序中使用，可以理解为在worker/taskworker进程中将此socket注册到epoll事件中。 在Client程序中使用，可以理解为在客户端进程中将此socket注册到epoll事件中。 ~~~ <?php $db = new mysqli; $db->connect('127.0.0.1', 'root', 'root', 'test'); $db->query("show tables", MYSQLI_ASYNC); swoole_event_add(swoole_get_mysqli_sock($db), function($db_sock) { global $db; $res = $db->reap_async_query(); var_dump($res->fetch_all(MYSQLI_ASSOC)); swoole_event_del(swoole_get_mysqli_sock($db)); // socket处理完成后，从epoll事件中移除socket }); $db2 = new mysqli; $db2->connect('127.0.0.1', 'root', 'root', 'test'); $db2->query("show tables", MYSQLI_ASYNC); swoole_event_add(swoole_get_mysqli_sock($db2), function($db_sock) { global $db2; $res = $db2->reap_async_query(); var_dump($res->fetch_all(MYSQLI_ASSOC)); swoole_event_del(swoole_get_mysqli_sock($db2)); // socket处理完成后，从epoll事件中移除socket }); echo "Finish\n"; //swoole_event_add不会阻塞进程，这行代码会顺序执行 ~~~ |  Swoole流程 | |-----|