【数据结构篇】请求队列InFlightRequest

1.请求队列简单介绍：

InFlightRequest是client的请求队列。max.in.flight.requests.per.connection配置请求队列大小，默认5，请求队列中存放的是在发送途中的请求，包括：正在发送的请求和已经发送的但还没有接收到response的请求;请求队列满了，发送消息将会发生阻塞。也就是发往同一个node的最大未响应请求数。

具体实现是：

sender线程在发送消息之前会调用NetworkClient的ready检查连接是否准备好了，这个时候会检查请求队列是否可用，详细查看

【网络核心层篇】NetworkClient—检查连接
如果请求队列已经满了，那么会认为连接不可用，将不会发送消息。就会发生阻塞。

如果可用则调用NetworkClient的send方法，这个时候会将请求入队。

在NetworkClient的poll中handleCompletedSends(responses, updatedNow);处理上次完成的请求，这个时候会从请求队列中移除已经收到响应的请求。

图解：

2.主要的成员

/**
 * The set of requests which have been sent or are being sent but haven't yet received a responseq
 * 请求队列
 *       1. 正在发送的请求
 *       2. 已经发送的但还没有接收到response的请求;
 */
final class InFlightRequests {
   
    /**
     * 每个连接最大执行中请求数-->max.in.flight.requests.per.connection
     */
    private final int maxInFlightRequestsPerConnection;
    /**
     * node->Deque<ClientRequest>
     *     双端队列Deque，其中的元素请求ClientRequest
     *     新请求从队列头部插入。发送从队列尾部取出
     */
    private final Map<String, Deque<NetworkClient.InFlightRequest>> requests = new HashMap<
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17