深入理解 PHP-FPM 多进程模型与源码执行流程

int main(int argc, char *argv[])
{
    zend_signal_startup();
    // 将全局变量 sapi_module 设置为 cgi_sapi_module
    sapi_startup(&cgi_sapi_module);
    fcgi_init();
    // 获取命令行参数，其中 php-fpm -D、-i 等参数都是在这里被解析出来的
    // ...
    cgi_sapi_module.startup(&cgi_sapi_module);
    
    // 【第1步】环境初始化与配置加载
    fpm_init(argc, argv, fpm_config ? fpm_config : CGIG(fpm_config), fpm_prefix, fpm_pid, test_conf, php_allow_to_run_as_root, force_daemon, force_stderr);
    
    /* master 进程会在这一步死循环,后面的流程都是子进程在执行。
       【第2步】进入 Master 进程的永久事件循环 */
    fcgi_fd = fpm_run(&max_requests);
    
    request = fpm_init_request(fcgi_fd);
    // 【第3步】子进程开始阻塞在 accept 等待请求
    // ....
}

// fpm 中的事件结构体
struct fpm_event_s {
    int fd;                           // 事件的句柄
    struct timeval timeout;           // 下一次触发的事件
    struct timeval frequency;         // 频率:多久执行一次
    void (*callback)(struct fpm_event_s *, short, void *); // 事件触发时调用的函数
    void *arg;                        // 调用 callback 时的参数
    int flags;                        // 标志位如 FPM_EV_READ 等
    int index;                        // 在 fd 句柄数组中的索引
    short which;                      // 事件类型
};
typedef struct fpm_event_queue_s {
    struct fpm_event_queue_s *prev;
    struct fpm_event_queue_s *next;
    struct fpm_event_s *ev;
} fpm_event_queue;

void fpm_event_loop(int err) {
    static struct fpm_event_s signal_fd_event;
    // 创建一个事件:管道 sp[0] 可读时触发
    fpm_event_set(&signal_fd_event, fpm_signals_get_fd(), FPM_EV_READ, &fpm_got_signal, NULL);
    fpm_event_add(&signal_fd_event, 0);
    // 以阻塞的方式获取事件，module->wait() 根据平台不同分别调用 epoll_wait 或 kevent
    ret = module->wait(fpm_event_queue_fd, timeout);
}
// kqueue 中添加事件的实现
static int fpm_event_kqueue_add(struct fpm_event_s *ev) {
    struct kevent k;
    EV_SET(&k, ev->fd, EVFILT_READ, EV_ADD, 0, 0, (void *)ev);
    if (kevent(kfd, &k, 1, NULL, 0, NULL) < 0) {
        zlog(ZLOG_ERROR, "kevent: unable to add event");
        return -1;
    }
    ev->index = ev->fd;
    return 0;
}

int fpm_signals_init_main() {
    struct sigaction act;
    // 创建全双工套接字作为进程间通讯管道
    if (0 > socketpair(AF_UNIX, SOCK_STREAM, 0, sp)) {
        return -1;
    }
    memset(&act, 0, sizeof(act));
    act.sa_handler = sig_handler;
    // 注册常用信号的处理函数
    sigfillset(&act.sa_mask);
    sigaction(SIGTERM, &act, 0);
    sigaction(SIGINT,  &act, 0);
    // ... 其他信号注册
    return 0;
}
static void sig_handler(int signo) {
    const char sig_chars[NSIG + 1] = {
        [SIGTERM] = 'T', [SIGINT] = 'I', [SIGUSR1] = '1' /*...*/
    };
    // 仅在主进程中写入管道通知事件循环
    if (fpm_globals.parent_pid == getpid()) {
        zend_quiet_write(sp[1], &sigs, 1);
    }
}

int fpm_run(int *max_requests) {
    struct fpm_worker_pool_s *wp;
    for (wp = fpm_worker_all_pools; wp; wp = wp->next) {
        is_parent = fpm_children_create_initial(wp);
        if (!is_parent) {
            goto run_child; // 只有新创建的子进程才会跳到这里继续执行
        }
    }
    /* 进入事件处理死循环，持续监控子进程状态、定时器及信号 */
    fpm_event_loop(0);
run_child:
    // 子进程清理并返回监听 socket，准备进入接收请求流程
    return fpm_globals.listening_socket;
}

request = fpm_init_request(fcgi_fd);
zend_first_try {
    while (EXPECTED(fcgi_accept_request(request) >= 0)) {
        // 解析 Request Header
        fpm_request_info();
        // 开启 SAPI 模块，重置全局变量
        php_request_startup();
        // 打开指定 DOCUMENT_ROOT 下的 PHP 脚本
        php_fopen_primary_script(&file_handle);
        // 【核心动作】执行脚本内容，产生输出
        php_execute_script(&file_handle);
        // 结束本次 FastCGI 事务，清空请求上下文
        fastcgi_request_done:;
    }
} zend_end_try();