|

o2yzhutncmb6404873137.gif
+ y0 U7 Q' X# L! V0 l2 m$ x点击上方蓝色字体,关注我们
" c" }& y- o9 Y6 q. C2 {6 R" L2 q/ b b w4 s- b
与I/O多路复用机制(如select和poll)相比,异步I/O通过信号通知机制,使得进程不需要反复查询I/O状态,而是由内核主动向进程发送信号(如SIGIO)来通知I/O状态的变化。% K( m/ m, {$ W6 z
1
& s; q8 Z V. S8 D# A! u6 q! XI/O多路复用与异步I/O的区别
* C% z5 O% t) i6 o: UI/O多路复用(select/poll/epoll)
+ J8 R# _: y5 Y7 |" y ^在多路复用机制中,进程使用select、poll或epoll等系统调用来主动查询文件描述符的状态,即等待某个文件描述符变得可读或可写。. G: `! C4 y" x% w+ `. o
$ i5 q% G5 J/ z" K9 X, l
这些方法虽然能有效处理多个文件描述符的事件,但本质上仍属于同步I/O,因为进程在发起查询时会被阻塞。- p" A) |% n) [$ T6 {, `
$ ?7 Y0 i7 J* [) Y* Q
异步I/O(Asynchronous I/O)2 Y6 X. o) d; V' v6 k) l& H, p
在异步I/O中,进程通过注册信号处理函数和设置文件描述符的异步标志,当I/O操作就绪时,内核会自动向进程发送信号(通常是SIGIO信号),不再需要主动轮询状态。
3 z; j3 l$ {8 A+ R6 S j5 M* A8 `0 v( H8 B( l3 Y: K$ z
进程在等待I/O时可以继续执行其他任务,收到信号后再执行相应的I/O操作。
. S7 x3 ]9 k0 z) x6 k27 j* a& `+ [9 H2 e
实现异步I/O的步骤. y N( z$ z9 N3 H0 h$ A- V7 f
在Linux中,使用异步I/O通常需要配合信号机制。# w' Y7 c8 v8 I* |, _
" \2 L1 S6 D, Z' K# S* U: F具体步骤如下:& \6 z7 F7 p) ~
设置文件描述符为非阻塞模式设置文件描述符的异步标志指定异步I/O事件的接收进程( K+ `( |( |% r4 x. s0 s
为SIGIO信号注册信号处理函数, d- N) c C3 e% j6 x3 H
' R6 q3 _. t# ^7 F' ?6 \$ h
2.1、设置非阻塞模式+ U7 t% E8 f$ z! f; R3 G
首先,需要将文件描述符设置为非阻塞模式(O_NONBLOCK标志),以便在执行I/O操作时不会阻塞当前进程。9 K9 b) \% W$ |- }$ O
% m" r7 {3 x: q: K4 K6 u9 |0 x3 V: T! k
可以通过fcntl系统调用来实现:- C) }7 _4 k, ^4 F
- [3 f; m! {, x6 E! q
int fd = open("example.txt", O_RDWR | O_NONBLOCK);if (fd 0) { perror("open"); return -1;}2.2、设置异步I/O标志(O_ASYNC)
% S4 Q8 j" L$ l! T7 D' O6 a接下来,需要为文件描述符设置异步I/O标志(O_ASYNC)。该标志用于通知内核,当文件描述符上的I/O操作就绪时向接收进程发送SIGIO信号。. z% c B! A. z
) H& e" Y t# c3 g; o5 ^
需要使用fcntl系统调用来完成此操作:
- i: Y: l% F- a0 Z' O! h; Z. _
+ U4 y8 r% K0 L7 H9 Fint flags = fcntl(fd, F_GETFL); // 获取当前标志flags |= O_ASYNC; // 增加O_ASYNC标志fcntl(fd, F_SETFL, flags); // 设置新的标志注意:open函数无法直接通过指定O_ASYNC标志来使能异步I/O,因此必须通过fcntl来设置。
6 i' l/ X% Y1 E( p0 m4 _0 n0 q) F) |7 ?! P0 A- z5 O$ L: ]3 y
2.3、设置异步I/O事件的接收进程
+ G3 x0 d% c1 H% y默认情况下,异步I/O事件的接收进程是创建文件描述符的进程。
6 `. u' u% c/ ]3 Q [8 n4 |
) t# t( K, U& f但如果需要将I/O事件转交给其他进程,可以使用fcntl函数设置文件描述符的“所有者”,也就是指定哪个进程应当接收I/O事件的通知信号:. E! e# A) {+ Q: F$ K5 G3 l
$ t9 ~0 Z2 E a3 W% J, ? ufcntl(fd, F_SETOWN, getpid()); // 设置当前进程为异步I/O事件的接收进程2.4、注册SIGIO信号处理函数
! C, ?4 Y4 B7 Q7 m1 c最后,为SIGIO信号注册信号处理函数。可以使用signal或sigaction函数为SIGIO信号注册一个处理函数。
% V* u! `% @$ Z; P; m# U, _* r# o8 [4 B: e
当文件描述符上有I/O操作就绪时,内核会向接收进程发送SIGIO信号,触发信号处理函数的执行。4 |, n+ `. s5 K# x4 {$ t* a4 E9 O2 I2 X
+ M; c2 _$ L7 z+ A
以下是信号处理函数的注册示例:' R) A: M: F+ e* ~) c ?
- x* v; H& _# j; ~* `# {
void sigio_handler(int signum) { // 执行I/O操作 char buffer[1024]; ssize_t bytes_read = read(fd, buffer, sizeof(buffer)); if (bytes_read > 0) { buffer[bytes_read] = '\0'; printf("异步读取的数据:%s
8 h; ]# R- M+ V L0 ]( a. T", buffer); }}5 ^1 H; \- E# z' f$ Q3 [) r: m
int main() { // 注册SIGIO信号处理函数 signal(SIGIO, sigio_handler); // 设置文件描述符的非阻塞模式和异步模式 int fd = open("example.txt", O_RDWR | O_NONBLOCK); if (fd 0) { perror("open"); return 1; } // 使能异步I/O int flags = fcntl(fd, F_GETFL); flags |= O_ASYNC; fcntl(fd, F_SETFL, flags); // 设置异步I/O事件的接收进程 fcntl(fd, F_SETOWN, getpid()); // 主程序可以执行其他任务 while (1) { printf("主进程在执行其他任务...
) B7 N- g0 Y! ]"); sleep(1); } close(fd); return 0;}说明:
1 Z" m! T0 g- D) X: U: T在sigio_handler函数中,read函数用于读取文件描述符上的数据。主程序中,进程可以继续执行其他任务而不会被阻塞,当I/O操作就绪时,会自动触发SIGIO信号并调用信号处理函数。
$ O: q w, @+ X/ P- m' B5 @+ |; u' ~
; ^. S+ l" A3 n t& u' `3
) X% Q6 V2 \8 N- pO_ASYNC标志的作用和注意事项! ? c# E$ U8 b4 |) C+ f
O_ASYNC标志用于使能文件描述符的异步I/O事件,使文件描述符在可执行I/O操作时向指定进程发送SIGIO信号。
9 U6 b, _3 I) r9 a$ j7 w O' b: j3 B9 s# [; K; c
需要注意以下几点:& u$ v2 {5 [- f5 y* {# s7 c' a
无法通过open直接设置O_ASYNC。必须使用fcntl设置文件描述符的异步标志。异步I/O事件的接收进程必须是文件描述符的所有者,如果需要其他进程接收SIGIO信号,必须通过F_SETOWN指定进程ID。信号处理函数的安全性:信号处理函数需要快速、简洁,不应调用阻塞的I/O操作或复杂的逻辑,否则可能影响主程序的实时性。
( } }, B/ R+ U" T! q48 z% F6 _# n, S! u
异步I/O的应用场景网络编程:在服务器端需要处理大量连接时,异步I/O可以避免进程阻塞,适合高并发应用场景。串口通信:在嵌入式系统中,串口通信是一种常见的通信方式。通过异步I/O,进程可以同时执行其他任务,不会因为串口I/O而阻塞。传感器数据采集:在实时数据采集系统中,异步I/O可以确保数据采集的实时性,进程在等待数据就绪时可以继续执行其他任务,提升CPU利用率。[/ol]9 h( w7 B1 Q O3 M: v) ?6 }6 T# m# \
57 c6 E1 `7 J0 P
异步I/O的缺陷与优化) E7 B" ^1 X' Y/ D' R
默认异步I/O信号SIGIO的局限
* ^( I' k [, m1 ?: J默认情况下,异步I/O使用非实时信号SIGIO作为通知信号。由于SIGIO是非实时信号,不支持信号排队机制,可能导致多个通知丢失。* f5 Z: |/ H k
) s1 z0 Y8 c: u5 {$ Q) R4 P例如:
3 C- e( z/ Z. A& _" ?当信号处理函数正在处理一个SIGIO信号时,后续的SIGIO信号可能被阻塞或忽略。SIGIO信号只能在信号处理函数执行完毕后再次触发,而其中一些信号通知会丢失。9 X$ h+ E# i2 O' L5 r
6 w: v) V- Y2 [7 k" T$ i
这种缺陷会导致进程无法及时响应I/O事件,影响应用程序的实时性。+ o7 h8 t% o4 S! v3 S
0 U( G) }( d1 }& w" V; m# T E
无法得知具体的事件类型
- {' G9 d2 j( w E2 P- U在默认的异步I/O信号处理函数中,进程无法直接获取文件描述符上具体的事件类型(如可读、可写、错误等),通常只能盲目地尝试执行I/O操作。$ \0 V, H0 e5 _- h1 p
, j- x6 b- ~% T+ g为此,我们可以利用实时信号来提供更精确的事件信息,并通过结构体siginfo_t的扩展字段来识别事件类型。' ? a& h$ D; v7 L; Q
6
# u. m# m3 ^# {9 g, X( L优化方法:使用实时信号替换默认信号
6 J7 S8 |8 d) }* w通过将SIGIO替换为实时信号(如SIGRTMIN),可以实现信号的排队机制,从而确保多次I/O事件通知不会被丢失。步骤如下:
3 \% o' O: y: @% ?; o$ b+ }& }5 s
$ d6 V4 [1 T8 {0 ]" x; _) H6.1、设置实时信号作为异步I/O通知信号7 { y' W) a$ R2 g' ~
使用fcntl函数的F_SETSIG命令,将实时信号(如SIGRTMIN)替换默认信号SIGIO:# R) n, [) `" b5 S4 W
5 d5 \" R# p$ b6 ^3 h. W1 ffcntl(fd, F_SETSIG, SIGRTMIN); // 将SIGRTMIN设为fd的异步I/O通知信号如果参数设置为0,则将恢复为默认的SIGIO信号。( f4 ^ x3 D# Z* x
7 n; h# _* W2 A6.2、使用sigaction注册信号处理函数
6 n+ ]' z' g6 d使用sigaction函数替代signal函数,以便支持更高级的信号处理方式。2 i( D9 t' N! t4 C; X
4 C; J. I9 z9 a, J% S9 |5 s通过为sa_flags设置SA_SIGINFO标志,我们可以在信号处理函数中使用扩展参数siginfo_t来获取更多事件信息:
2 A6 L# |5 l) g, V7 P% y: ?- a$ j. mvoid sigio_handler(int signo, siginfo_t *info, void *context) { if (info->si_signo == SIGRTMIN) { // 确认信号是SIGRTMIN int fd = info->si_fd; // 获取发生事件的文件描述符 int event = info->si_code; // 获取事件类型 // 根据事件类型进行不同的处理 if (event == POLL_IN) { // 可读取数据 // 执行读操作 } else if (event == POLL_OUT) { // 可写入数据 // 执行写操作 } else if (event == POLL_ERR) { // I/O错误 // 错误处理 } }}int main() { struct sigaction sa; sa.sa_flags = SA_SIGINFO; // 使用sa_sigaction处理函数 sa.sa_sigaction = sigio_handler; // 注册信号处理函数 sigaction(SIGRTMIN, &sa, NULL); // 绑定SIGRTMIN信号 // 设置文件描述符的异步I/O标志 int fd = open("example.txt", O_RDWR | O_NONBLOCK); int flags = fcntl(fd, F_GETFL); flags |= O_ASYNC; fcntl(fd, F_SETFL, flags); // 设置异步I/O事件的接收进程及信号 fcntl(fd, F_SETOWN, getpid()); fcntl(fd, F_SETSIG, SIGRTMIN); // 指定实时信号SIGRTMIN // 主程序继续执行 while (1) { sleep(1); } close(fd); return 0;}6.3、利用siginfo_t的扩展字段获取事件详情
9 z. k( u( A# A) W在实时信号的信号处理函数中,siginfo_t结构体的si_code和si_band字段可以帮助识别发生的事件类型,如下:
% l4 R& A7 \. F- A/ ?0 ]si_fd:发生事件的文件描述符。si_code:事件类型(如POLL_IN、POLL_OUT等),通过该字段可以确认文件描述符的状态。si_band:事件的位掩码,与poll()函数的revents字段一致,用于进一步确认事件细节。4 F$ {6 E) ` J O8 @+ O
例如:9 \: B4 \4 Q# k3 Z3 R; {' q
9 ^+ _7 @! J% X9 b2 y) r
2uqrpadzqbp6404873237.png
; g) k% B U- g通过这些扩展字段,可以在信号处理函数中更灵活地执行不同的I/O操作,避免盲目调用read或write操作,从而进一步提升性能和可靠性。
/ \! G# i+ r: Y9 @" Z/ Q
2 n8 M# l1 v2 b/ H% P) s: r通过实时信号优化异步I/O,可以有效解决通知丢失及事件类型不足的问题,使异步I/O在文件描述符多且并发高的场景下性能更加稳定和可靠。( t, U( r# a5 @
+ i6 g. Q1 Y, k# W0 a9 {/ n配合siginfo_t的扩展信息,信号处理函数可以更加精准地响应I/O事件。
, t- h+ ]" b% m! B" D7 f2 J# d* P1 ?) i5 ?
在应用开发中,可以根据文件描述符的数量、实时性要求、CPU资源占用等因素,综合考虑使用异步I/O或epoll来构建高效的I/O处理框架。
5 J* h" u6 f# Y
heuaoeccqic6404873337.jpg
- c8 {) ` b% H+ K
pufoxb4rmhg6404873437.gif
9 {' | {2 _. T( W点击阅读原文,更精彩~ |
|