实现异步的方式有哪些? swoole提供了一些异步方法, 那它们底层是用哪种方式实现的呢?

实现异步的方式有:

• 线程方式

• 进程方式

• IO复用

线程方式和进程方式类似, 有异步请求时, 开一个线程或者进程, 获取到数据后, 线程间可以直接共享数据. 进程间可以通过进程通信机制，如共享内存,管道等方式进行数据传送. 思路很简单, 可以参考这篇利用swoole_process和eventloop实现php异步编程, 但是缺点非常明显, 开销太大, 一个异步请求，就要开一个线程或者进程.

IO复用方式, 通常有select,poll, epoll这几种方式, 当下最流行的当然是epoll, 性能好, 理论上来说没有连接限制, 单个进程内可以维持数十万的连接. 使用这种方式，当有异步请求时，可以在当前进程内，再开一个连接做异步请求，开销很少, 性能很好, 主流的异步实现都是这种方式.

swoole提供了一些异步http client, mysql client, 可以让你异步地访问http server和mysql server, 通过回调的方式对返回的数据进行处理, 它们使用的方式就是IO复用.

来看一段swoole的源代码:

异步tcp请求

static int swClient_tcp_connect_async(swClient *cli, char *host, int port, double timeout, int nonblock){    int ret;    cli->timeout = timeout;    //alloc input memory buffer    cli->buffer = swString_new(cli->buffer_input_size);    if (!cli->buffer)    {        return SW_ERR;    }    if (!(cli->onConnect && cli->onError && cli->onClose))    {        swWarn("onConnect/onError/onClose callback have not set.");        return SW_ERR;    }    if (swClient_inet_addr(cli, host, port) < 0)    {        return SW_ERR;    }    while (1)    {        ret = connect(cli->socket->fd, (struct sockaddr *) &cli->server_addr.addr, cli->server_addr.len);        if (ret < 0)        {            if (errno == EINTR)            {                continue;            }            SwooleG.error = errno;        }        break;    }    if ((ret < 0 && errno == EINPROGRESS) || ret == 0)    {        if (SwooleG.main_reactor->add(SwooleG.main_reactor, cli->socket->fd, cli->reactor_fdtype | SW_EVENT_WRITE) < 0)        {            return SW_ERR;        }        return SW_OK;    }    return ret;}

关键看这一段:

if (SwooleG.main_reactor->add(SwooleG.main_reactor, cli->socket->fd, cli->reactor_fdtype | SW_EVENT_WRITE) < 0){    return SW_ERR;}return SW_OK;

就是把socket fd放到reactor中监听, 本质上就是epoll, 也就是IO复用技术.