Swoole native curl协程化思路

Comments

这个还是有点复杂的，记录一下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
┌──────────────────────────┐                                                                                                                                                                      
│                          │                                                                                                                                                                      
│                          │                                                                                                                                                                      
│           co 1           │                                                                                                                                                                      
│                          │                                                                                                                                                                      
│       1. curl exec       │                                                                                                                                                                      
│                          │                                                                                                                                                                      
│                          │                                                                                                                                                                      
└──────────────────────────┘                                                                                                                                                                      
              │                                                                                                                                                                                   
              │                                                                                                                                                                                   
              ▼                                                                                                                                                                                   
┌──────────────────────────┐                                                                                                                                                                      
│                          │                                                                                                                                                                      
│                          │                                                                                                                                                                      
│           co 1           │                                                                                                                                                                      
│                          │                                                                                                                                                                      
│       2. add timer       │                                                                                                                                                                      
│                          │                                                                                                                                                                      
│                          │                                                                                                                                                                      
└──────────────────────────┘                                                                                                                                                                      
              │                                                                                                                                                                                   
              │                                                                                                                                                                                   
              ▼                                                                                                                                                                                   
┌──────────────────────────┐                                     ┌──────────────────────────────────┐           ┌──────────────────────────────────┐                                              
│                          │                                     │                                  │           │                                  │                                              
│                          │                                     │                                  │           │                                  │                                              
│           co 1           │                                     │            event loop            │           │   curl_multi_socket_action ->    │                                              
│                          │────────────────────────────────────▶│                                  │──────────▶│  connect -> add write event ->   │                                              
│        3. yield_m        │                                     │            4. timeout            │           │       return to event loop       │                                              
│                          │                                     │                                  │           │                                  │                                              
│                          │                                     │                                  │           │                                  │                                              
└──────────────────────────┘                                     └──────────────────────────────────┘           └──────────────────────────────────┘                                              
                                                                                   │                                                                                                              
                                                                                   │                                                                                                              
                                                                                   │                                                                                                              
                                                                                   ▼                                                                                                              
                                                                 ┌──────────────────────────────────┐           ┌──────────────────────────────────┐                                              
                                                                 │                                  │           │                                  │                                              
                                                                 │                                  │           │                                  │                                              
                                                                 │            event loop            │           │ curl_multi_socket_action -> send │                                              
                                                                 │                                  │──────────▶│   request -> add read event ->   │                                              
                                                                 │           5. writeable           │           │       return to event loop       │                                              
                                                                 │                                  │           │                                  │                                              
                                                                 │                                  │           │                                  │                                              
                                                                 └──────────────────────────────────┘           └──────────────────────────────────┘                                              
                                                                                   │                                                                                                              
                                                                                   │                                                                                                              
                                                                                   │                                                                                                              
                                                                                   │                                                                                                              
                                                                                   │                                                                                                              
                                                                                   ▼                                                                                                              
                                                                 ┌──────────────────────────────────┐           ┌──────────────────────────────────┐          ┌──────────────────────────────────┐
                                                                 │                                  │           │                                  │          │                                  │
                                                                 │                                  │           │                                  │          │ 6.3 curl_multi_socket_action ->  │
                                                                 │            event loop            │           │ 6.1 curl_multi_socket_action ->  │          │CURLOPT_WRITEFUNCTION func -> read│
                                                                 │                                  │──────────▶│   call CURLOPT_HEADERFUNCTION    │─────────▶│body -> delete all event -> delete│
                                                                 │           6. readable            │           │                                  │          │        timer -> resume_m         │
                                                                 │                                  │           │                                  │          │                                  │
                                                                 │                                  │           │                                  │          │                                  │
                                                                 └──────────────────────────────────┘           └──────────────────────────────────┘          └──────────────────────────────────┘
                                                                                                                                  │                                             │                 
                                                                                                                                  │                                             │                 
                                                                                                                                  │                                             │                 
                                                                                                             if set CURLOPT_HEADER│UNCTION in user code                         │                 
                                                                                                                                  │                                             │                 
                                                                                                                                  │                                             │                 
                                                                                                                                  ▼                                             ▼                 
                                                                                                                ┌──────────────────────────────────┐          ┌──────────────────────────────────┐
                                                                                                                │                                  │          │                                  │
                                                                                                                │                                  │          │                                  │
                                                                                                                │6.2 set write_header for coroutine│          │ 6.4 read_info -> CURLMSG_DONE -> │
                                                                                                                │           -> resume_m            │          │             resume_m             │
                                                                                                                │                                  │          │                                  │
                                                                                                                │                                  │          │                                  │
                                                                                                                └──────────────────────────────────┘          │                                  │
                                                                                                                                  │                           └──────────────────────────────────┘
                                                                                                                                  │                                             │                 
                                                                                                                                  │                                             │                 
                                                                                                                                  │                                             │                 
                                                                                                                                  ▼                                             │                 
                                                                                                           ┌────────────────────────────────────────────┐                       │                 
                                                                                                           │                                            │                       │                 
                                                                                                           │                                            │                       │                 
                                                                                                           │                    co 1                    │                       │                 
                                                                                                           │                                            │                       │                 
                                                                                                           │write_header func to get response header -> │                       │                 
                                                                                                           │      yield_m (Notice: Every time the       │                       │                 
                                                                                                           │fn_write_header reads a row of headers in a │                       │                 
                                                                                                           │callback, a scheduler-to-coroutine switch is│                       │                 
                                                                                                           │                 required)                  │                       │                 
                                                                                                           │                                            │                       │                 
                                                                                                           │    why we should call it in coroutine?     │                       │                 
                                                                                                           │  Because this callback function may have   │                       │                 
                                                                                                           │                blocking IO                 │                       │                 
                                                                                                           │                                            │                       │                 
                                                                                                           │                                            │                       │                 
                                                                                                           └────────────────────────────────────────────┘                       │                 
                                                                                                                                                                                │                 
                                                                                                                                                                                │                 
                                                                                                                                                                                │                 
                                                                                                                                                                                │                 
                                                                                                                                                                                │                 
                                                                                                                                                                                │                 
  ┌──────────────────────────────────────────────┐                                                                                                                              │                 
  │                                              │                                                                                                                              │                 
  │                                              │                                                                                                                              │                 
  │                     co 1                     │                                                                                                                              │                 
  │                                              │◀─────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────┘                 
  │            7. continue to run...             │                                                                                                                                                
  │                                              │                                                                                                                                                
  │                                              │                                                                                                                                                
  └──────────────────────────────────────────────┘

codinghuangPHP Developer

PHP开发者~