PHP異步編程，異步的本質

實現異步的方式有哪些? 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複用技術.