从“快递签收规则”到信号处理：sigaction 的妙用与进阶

最近在搞一个消息队列服务，有个业务场景和“快递签收规则”颇为相似：客户端发送消息到服务端，服务端处理完成后需要通知客户端。如果客户端网络不稳定，可能会丢失服务端发来的通知。为了保证最终一致性，我们需要服务端重试机制，而这个重试机制需要考虑各种异常情况，例如服务端崩溃、客户端断线等。这让我想到了 Linux 的信号处理机制，尤其是 sigaction 函数，它就像快递签收规则中的“代收”、“拒收”、“超时自动签收”一样，决定了程序如何处理各种突发事件。

sigaction 允许我们自定义信号处理函数，并且可以设置信号处理的各种行为，例如阻塞其他信号、在信号处理函数返回后自动重置信号处理方式等。理解 sigaction 对于构建健壮、可靠的后端服务至关重要。

深入理解 sigaction：信号处理的“总开关”

sigaction 函数是 POSIX 标准中用于设置信号处理方式的关键函数。它比传统的 signal 函数提供了更多的控制选项，能够更精细地控制信号处理的行为。

函数原型如下：

int sigaction(int signum, const struct sigaction *act, struct sigaction *oldact);

• signum: 要设置处理方式的信号编号，例如 SIGINT (中断信号，通常由 Ctrl+C 产生), SIGTERM (终止信号), SIGCHLD (子进程状态改变信号) 等。
• act: 指向新的 sigaction 结构体的指针，包含了新的信号处理方式。
• oldact: 如果非空，则指向一个 sigaction 结构体，用于保存之前的信号处理方式。可以将它设置为 NULL，如果你不关心之前的信号处理方式。

sigaction 结构体定义如下：

struct sigaction {
 void (*sa_handler)(int); // 信号处理函数指针 (早期用法, 现在推荐使用 sa_sigaction)
 void (*sa_sigaction)(int, siginfo_t *, void *); // 信号处理函数指针 (带扩展信息)
 sigset_t sa_mask; // 信号处理期间要阻塞的信号集合
 int sa_flags; // 信号处理标志 (例如 SA_RESTART, SA_NOCLDSTOP)
 void (*sa_restorer)(void); // 已废弃，不要使用
};

其中最关键的成员是 sa_handler 或 sa_sigaction 以及 sa_flags。

• sa_handler: 接收一个 int 类型的参数，表示信号编号。这是最基本的信号处理函数指针。
• sa_sigaction: 接收三个参数：信号编号、指向 siginfo_t 结构体的指针（包含更详细的信号信息）以及一个 void * 指针。使用 sa_sigaction 可以获取更多关于信号的信息，例如发送信号的进程 ID、用户 ID 等。推荐使用这种方式。
• sa_mask: 在信号处理函数执行期间，希望阻塞的其他信号集合。例如，如果你的信号处理函数需要访问一些共享资源，你可能希望在信号处理期间阻塞其他可能访问相同资源的信号，以避免竞争条件。
• sa_flags: 一组标志，用于控制信号处理的各种行为。常用的标志包括：
  • SA_RESTART: 如果被信号中断的系统调用是可以重启的（例如 read，write），则在信号处理函数返回后自动重启系统调用。
  • SA_NOCLDSTOP: 仅在子进程终止时才发送 SIGCHLD 信号，忽略子进程的停止信号 (例如 Ctrl+Z)。
  • SA_NOCLDWAIT: 当子进程终止时，不产生僵尸进程。系统会自动回收子进程的资源。
  • SA_SIGINFO: 必须设置此标志才能使用 sa_sigaction 字段指定的信号处理函数。

代码示例：使用 sigaction 处理 SIGINT 信号

下面的代码演示了如何使用 sigaction 函数来处理 SIGINT 信号（通常由 Ctrl+C 产生）。

#include <stdio.h>
#include <signal.h>
#include <unistd.h>
#include <stdlib.h>

void sigint_handler(int signo, siginfo_t *info, void *context) { // 信号处理函数，使用 sa_sigaction
 printf("Received SIGINT signal (Ctrl+C)\n");
 printf("Signal number: %d\n", signo);
 printf("Sending process ID: %d\n", info->si_pid); // 打印发送信号进程的ID
 printf("User ID: %d\n", info->si_uid);       // 打印用户ID

 // 执行一些清理工作，例如释放资源、关闭文件等
 exit(0); // 正常退出程序
}

int main() {
 struct sigaction sa;

 sa.sa_sigaction = sigint_handler; // 设置信号处理函数
 sa.sa_flags = SA_SIGINFO; // 必须设置 SA_SIGINFO 才能使用 sa_sigaction
 sigemptyset(&sa.sa_mask); // 初始化信号掩码为空集

 if (sigaction(SIGINT, &sa, NULL) == -1) { // 注册信号处理函数
 perror("sigaction");
 return 1;
 }

 printf("Waiting for SIGINT signal...\n");
 while (1) {
 sleep(1); // 模拟程序运行
 }

 return 0;
}

这段代码首先定义了一个 sigint_handler 函数，用于处理 SIGINT 信号。然后，在 main 函数中，我们创建了一个 sigaction 结构体，设置 sa_sigaction 字段为 sigint_handler，sa_flags 字段为 SA_SIGINFO，并将 sa_mask 初始化为空集。最后，我们调用 sigaction 函数将 SIGINT 信号与我们自定义的信号处理函数关联起来。当程序接收到 SIGINT 信号时，sigint_handler 函数会被调用，打印相关信息并退出程序。

实战避坑：sigaction 使用的注意事项

1. SA_RESTART 的使用: SA_RESTART 标志非常有用，但也要小心使用。如果你的信号处理函数可能会修改全局状态，并且系统调用重启后依赖这些状态，那么可能会导致不可预测的结果。在这种情况下，最好不要使用 SA_RESTART，而是手动处理被中断的系统调用。
2. 异步信号安全函数: 信号处理函数中只能调用异步信号安全的函数。这意味着这些函数必须是可重入的，并且不能使用全局变量或锁。常见的异步信号安全函数包括 write、_exit、signal 等。调用非异步信号安全函数可能会导致死锁或程序崩溃。
3. 信号掩码的设置: 合理设置信号掩码可以避免信号处理函数被重复调用，或者避免某些信号干扰信号处理函数的执行。例如，如果你在处理 SIGCHLD 信号时，可能希望阻塞其他的 SIGCHLD 信号，以避免并发处理多个子进程状态改变事件。
4. 多线程环境下的信号处理: 在多线程程序中，信号处理的行为更加复杂。默认情况下，信号会被传递给进程中的任意一个线程。你可以使用 pthread_sigmask 函数来控制每个线程的信号掩码，从而决定哪些线程可以接收哪些信号。确保信号处理函数是线程安全的。
5. 与 Nginx 等服务器的结合: 在构建高性能的 Nginx 模块或者其他服务器扩展时，sigaction 经常被用于处理一些特殊信号，例如重新加载配置的信号 (SIGHUP)。需要特别注意信号处理函数的执行时间，避免阻塞主进程。可以使用 ngx_post_thread_task 将一些耗时的操作放入线程池中执行，保证主进程的响应速度。同时要考虑高并发场景下的信号处理问题，比如防止惊群效应，合理设置锁机制。

总结

sigaction 是一个强大的信号处理工具，但同时也需要谨慎使用。理解其工作原理和各种选项，可以帮助我们编写更健壮、可靠的程序。从快递签收规则中，我们也能体会到，任何复杂系统的背后，都离不开对各种异常情况的周全考虑。就像处理信号一样，我们需要提前定义好各种“签收”策略，才能保证系统的稳定运行。