3.stream_proxy深度解析

ngx_stream_upstream.c

ngx_stream_upstream_round_robin.c

ngx_stream_write_filter_module.c

ngx_stream_proxy_module.c

<b>指令配置项中解析:&nbsp;<br><font color="#a23c73">ngx_stream_upstream_commands</font>[]{<br></b><span style="font-size: inherit; font-weight: bold;">&nbsp; &nbsp; &nbsp; &nbsp; </span><span style="font-size: inherit;">ngx_string</span><span style="font-size: inherit; font-weight: bold;">(</span><font style="font-size: inherit; font-weight: bold;" color="#358e90"><b style="">"server"</b></font><span style="font-size: inherit; font-weight: bold;">),&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;----server{}中解析配置</span><b><br></b>&nbsp; &nbsp; &nbsp; &nbsp; <b><font color="#569230">ngx_stream_upstream_server</font></b>,&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ----解析处理函数<br>}<br><br>typedef&nbsp;struct&nbsp;{<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_str_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; <b>name</b>;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;//域名<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_addr_t&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<b>*addrs;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;</b>//解析地址<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_uint_t&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<b>&nbsp;naddrs;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;</b>//解析出的地址个数<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_uint_t&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<b>&nbsp;&nbsp;weight;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;</b>//服务器所在权重<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_uint_t&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<b>max_conns;&nbsp; &nbsp;&nbsp;</b>//服务器最大连接数<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_uint_t&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<b>&nbsp;max_fails;</b><br>&nbsp;&nbsp;&nbsp;&nbsp;time_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;<b>fail_timeout;</b><br>&nbsp;&nbsp;&nbsp;&nbsp;<font color="#9e9e9e">ngx_msec_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; </font><b><font color="#9e9e9e">&nbsp;slow_start</font>;&nbsp; &nbsp; <font color="#9e9e9e">//开源版本未使用</font></b><br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_uint_t&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<b>&nbsp;&nbsp;&nbsp;down;</b><br><br>&nbsp;&nbsp;&nbsp;&nbsp;unsigned&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<b>&nbsp;backup:1;</b><br>}&nbsp;<b><font color="#314aa4">ngx_stream_upstream_server_t</font></b>;<br>

<b>typedef&nbsp;struct&nbsp;{</b><br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_stream_upstream_init_pt&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;init_upstream;<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_stream_upstream_init_peer_pt&nbsp; &nbsp; &nbsp; init;<br>&nbsp;&nbsp;&nbsp;&nbsp;void&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; *data;<br>}&nbsp;<b><font color="#314aa4">ngx_stream_upstream_peer_t</font></b>;<br><br>struct&nbsp;<b><font color="#314aa4">ngx_stream_upstream_srv_conf_s</font></b>&nbsp;{<br>&nbsp; &nbsp; <b><font color="#314aa4">ngx_stream_upstream_peer_t</font></b>&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;peer;<br>&nbsp;&nbsp;&nbsp;&nbsp;void&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;**srv_conf;<br>&nbsp; &nbsp; //服务器数组<br>&nbsp;&nbsp;&nbsp;&nbsp;<b><font color="#4669ea">ngx_array_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;*servers;</font>&nbsp;</b> &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---上游服务器结构(<b><font color="#4669ea">ngx_stream_upstream_server_t</font></b>)<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_uint_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;flags;<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_str_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;host;<br>&nbsp;&nbsp;&nbsp;&nbsp;u_char&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;*file_name;<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_uint_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;line;<br>&nbsp;&nbsp;&nbsp;&nbsp;in_port_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;port;<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_uint_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; no_port;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;/*&nbsp;unsigned&nbsp;no_port:1&nbsp;*/<br>}&nbsp;<br>

<br><br>typedef&nbsp;struct&nbsp;{<br>&nbsp;&nbsp;&nbsp;&nbsp;<b><font color="#a66a30">ngx_peer_connection_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;</font></b>peer;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---从upstream获取的上游的server连接<br><br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_buf_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;downstream_buf;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---下行缓冲区<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_buf_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;upstream_buf;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---上行缓冲区<br><br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_chain_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; *free;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---缓冲区的free空闲链表<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_chain_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; *upstream_out;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---上行(下游往上游)发送缓冲链表<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_chain_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; *upstream_busy;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---上行(下游往上游)最终发送缓冲链表<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_chain_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; *downstream_out;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---下行(上游往下游)发送缓冲链表&nbsp;<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_chain_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; *downstream_busy;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;---下行(上游往下游)发送缓冲链表<br><br>&nbsp;&nbsp;&nbsp;&nbsp;off_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;received;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---接收到的总字节数<br>&nbsp;&nbsp;&nbsp;&nbsp;time_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; start_sec;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---开始连接后端的时间,&nbsp; 限速配置开启时，用于计算速率<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_uint_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;requests;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---上行接收到的包个数<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_uint_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;responses;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_msec_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;start_time;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---开始启动连接时间， 毫秒<br><br>&nbsp;&nbsp;&nbsp;&nbsp;size_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;upload_rate;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---上行速率<br>&nbsp;&nbsp;&nbsp;&nbsp;size_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;download_rate;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;---下行速率<br><br>&nbsp;&nbsp;&nbsp;&nbsp;<strike>ngx_str_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;ssl_name;&nbsp;</strike><br><br>&nbsp;&nbsp;&nbsp;&nbsp;<font color="#314aa4"><b>ngx_stream_upstream_srv_conf_t</b></font>&nbsp; &nbsp; &nbsp; &nbsp; *upstream;&nbsp; &nbsp; &nbsp; &nbsp; ---上游服务块相关配置<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_stream_upstream_resolved_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;*resolved;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---上游服务地址解析<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_stream_upstream_state_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; *state;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---上游服务器连接状态查询信息<br>&nbsp;&nbsp;&nbsp;&nbsp;unsigned&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;connected:1;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---是否已经成功连接上游服务器<br>&nbsp;&nbsp;&nbsp;&nbsp;unsigned&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;proxy_protocol:1;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---是否启用了代理协议<br>&nbsp;&nbsp;&nbsp;&nbsp;unsigned&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;half_closed:1;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---是否已经处于半关闭状态<br>}&nbsp;<b><font color="#314aa4">ngx_stream_upstream_t</font></b>;

a. 轮询算法

<b>typedef&nbsp;struct&nbsp;{</b><br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_addr_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; *addr;<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_stream_complex_value_t&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*value;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---连接上游服务器的各种参数(超时、缓冲大小等)<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_uint_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;transparent;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---开启透明代理，需要配合iptables路由表使用<br>}&nbsp;<b><font color="#5b79e8">ngx_stream_upstream_local_t</font><font color="#314aa4">;</font></b><br><br><b>typedef&nbsp;struct&nbsp;{</b><br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_msec_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; connect_timeout;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---连接上游事件超时时间<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_msec_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; timeout;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---读写事件超时<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_msec_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; next_upstream_timeout;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---连接上游服务器超时时间<br>&nbsp;&nbsp;&nbsp;&nbsp;size_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; buffer_size;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---上游读取数据缓冲区大小<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_stream_complex_value_t&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*upload_rate;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---上行速率<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_stream_complex_value_t&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*download_rate;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;---下行速率<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_uint_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; requests;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---上行的包统计数<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_uint_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; responses;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---下行的包统计数<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_uint_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; next_upstream_tries;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---上行断开重试次数<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_flag_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; next_upstream;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---默认值为1(是否有upstream? )<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_flag_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; proxy_protocol;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---是否开启了代理协议<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_flag_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; half_close;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---半关闭:&nbsp; 只有双方都读取到EOF才关闭连接<br>&nbsp;&nbsp;&nbsp;<b><font color="#5b79e8">&nbsp;ngx_stream_upstream_local_t</font></b>&nbsp; &nbsp;*local;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---如上: 本端的一些配置<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_flag_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; socket_keepalive;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;---是否开启TCP keepAlive保活<br>&nbsp; &nbsp; ......................<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_stream_upstream_srv_conf_t&nbsp;&nbsp;*upstream;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---转发上游服务器集群upstream{}块<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_stream_complex_value_t&nbsp; &nbsp; &nbsp; &nbsp; *upstream_value;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---upstream支持的复杂变量<br>}&nbsp;<b><font color="#314aa4">ngx_stream_proxy_srv_conf_t</font></b>;<br>

struct&nbsp;<font color="#a66a30"><b>ngx_peer_connection_s&nbsp;</b>{</font><br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_connection_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; *connection;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---事件连接器<br>&nbsp;&nbsp;&nbsp;&nbsp;struct&nbsp;sockaddr&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;*sockaddr;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---上游服务地址<br>&nbsp;&nbsp;&nbsp;&nbsp;socklen_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; socklen;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_str_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;*name;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---上游服务名称<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_uint_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; tries;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---最大重试次数<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_msec_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; start_time;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---连接开始的时间，即发起主动连接的时刻<br><br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_event_get_peer_pt&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; get;&nbsp; &nbsp; &nbsp; &nbsp;---从upstream{}里获取一个上游server地址,&nbsp;如:&nbsp;ngx_stream_upstream_get_round_robin_peer()<br>&nbsp; &nbsp; ngx_event_free_peer_pt&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;free;&nbsp; &nbsp; &nbsp; ---释放一个上游地址，如:ngx_stream_upstream_free_round_robin_peer()<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_event_notify_peer_pt&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; notify;&nbsp; &nbsp;---服务可用或者不可用状态变化,如:&nbsp;ngx_stream_upstream_notify_round_robin_peer()<br>&nbsp;&nbsp;&nbsp;&nbsp;void&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;*data;&nbsp; &nbsp; &nbsp;---get/free函数所需的参数<br>&nbsp; &nbsp;&nbsp;<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_addr_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;*local;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---本地地址<br>&nbsp;&nbsp;&nbsp;&nbsp;int&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;type;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---标记tcp/udp<br>&nbsp;&nbsp;&nbsp;&nbsp;int&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;rcvbuf;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---接收缓冲区大小<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_log_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;*log;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---日志对象<br><br>&nbsp;&nbsp;&nbsp;&nbsp;unsigned&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; cached:1;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---连接是否已经缓存, 可以重复使用TCP连接, 避免重建TCP(HTTP中较为场景)<br>&nbsp;&nbsp;&nbsp;&nbsp;unsigned&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; transparent:1;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---透明代理标记<br>&nbsp;&nbsp;&nbsp;&nbsp;unsigned&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; so_keepalive:1;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---TCP连接保活标记<br>&nbsp;&nbsp;&nbsp;&nbsp;unsigned&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; down:1;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---上游是否处于不可用状态<br>};<br>

typedef&nbsp;struct&nbsp;{<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_chain_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; *from_upstream;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ---上行发送缓存<br>&nbsp;&nbsp;&nbsp;&nbsp;ngx_chain_t&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; *from_downstream;&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;---下行发送缓存<br>}&nbsp;<b>ngx_stream_write_filter_ctx_t</b>;