摘要：而存在的意義就是保證請求或響應(yīng)對象可在線程池中被解碼，解碼完成后，就會(huì)分發(fā)到的。

目標(biāo)：從源碼的角度分析服務(wù)端接收到請求后的一系列操作，最終把客戶端需要的值返回。

上一篇講到了消費(fèi)端發(fā)送請求的過程，該篇就要將服務(wù)端處理請求的過程。也就是當(dāng)服務(wù)端收到請求數(shù)據(jù)包后的一系列處理以及如何返回最終結(jié)果。我們也知道消費(fèi)端在發(fā)送請求的時(shí)候已經(jīng)做了編碼，所以我們也需要在服務(wù)端接收到數(shù)據(jù)包后，對協(xié)議頭和協(xié)議體進(jìn)行解碼。不過本篇不講解如何解碼。有興趣的可以翻翻我以前的文章，有講到關(guān)于解碼的邏輯。接下來就開始講解服務(wù)端收到請求后的邏輯。

假設(shè)遠(yuǎn)程通信的實(shí)現(xiàn)還是用netty4，解碼器將數(shù)據(jù)包解析成 Request 對象后，NettyHandler 的 messageReceived 方法緊接著會(huì)收到這個(gè)對象，所以第一步就是NettyServerHandler的channelRead。

可以參考《dubbo源碼解析（十七）遠(yuǎn)程通信——Netty4》的（三）NettyServerHandler

public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    // 看是否在緩存中命中，如果沒有命中，則創(chuàng)建NettyChannel并且緩存。
    NettyChannel channel = NettyChannel.getOrAddChannel(ctx.channel(), url, handler);
    try {
        // 接受消息
        handler.received(channel, msg);
    } finally {
        // 如果通道不活躍或者斷掉，則從緩存中清除
        NettyChannel.removeChannelIfDisconnected(ctx.channel());
    }
}

NettyServerHandler是基于netty4實(shí)現(xiàn)的服務(wù)端通道處理實(shí)現(xiàn)類，而該方法就是用來接收請求，接下來就是執(zhí)行AbstractPeer的received。

可以參考《dubbo源碼解析（九）遠(yuǎn)程通信——Transport層》的（一）AbstractPeer

public void received(Channel ch, Object msg) throws RemotingException {
    // 如果通道已經(jīng)關(guān)閉，則直接返回
    if (closed) {
        return;
    }
    handler.received(ch, msg);
}

該方法比較簡單，之前也講過AbstractPeer類就做了裝飾模式中裝飾角色，只是維護(hù)了通道的正在關(guān)閉和關(guān)閉完成兩個(gè)狀態(tài)。然后到了MultiMessageHandler的received

可以參考《dubbo源碼解析（九）遠(yuǎn)程通信——Transport層》的（八）MultiMessageHandler

public void received(Channel channel, Object message) throws RemotingException {
    // 如果消息是MultiMessage類型的，也就是多消息類型
    if (message instanceof MultiMessage) {
        // 強(qiáng)制轉(zhuǎn)化為MultiMessage
        MultiMessage list = (MultiMessage) message;
        // 把各個(gè)消息進(jìn)行發(fā)送
        for (Object obj : list) {
            handler.received(channel, obj);
        }
    } else {
        // 直接發(fā)送
        handler.received(channel, message);
    }
}

該方法也比較簡單，就是對于多消息的處理。

可以參考《dubbo源碼解析（十）遠(yuǎn)程通信——Exchange層》的（二十）HeartbeatHandler。其中就是對心跳事件做了處理。如果不是心跳請求，那么接下去走到AllChannelHandler的received。

可以參考《dubbo源碼解析（九）遠(yuǎn)程通信——Transport層》的（十一）AllChannelHandler。該類處理的是連接、斷開連接、捕獲異常以及接收到的所有消息都分發(fā)到線程池。所以這里的received方法就是把請求分發(fā)到線程池，讓線程池去執(zhí)行該請求。

還記得我在之前文章里面講到到Dispatcher接口嗎，它是一個(gè)線程派發(fā)器。分別有五個(gè)實(shí)現(xiàn)：

這些Dispatcher的實(shí)現(xiàn)類以及對應(yīng)的Handler都可以在《dubbo源碼解析（九）遠(yuǎn)程通信——Transport層》中查看相關(guān)實(shí)現(xiàn)。dubbo默認(rèn)all為派發(fā)策略。所以我在這里講了AllChannelHandler的received。把消息送到線程池后，可以看到首先會(huì)創(chuàng)建一個(gè)ChannelEventRunnable實(shí)體。那么接下來就是線程接收并且執(zhí)行任務(wù)了。

ChannelEventRunnable實(shí)現(xiàn)了Runnable接口，主要是用來接收消息事件，并且根據(jù)事件的種類來分別執(zhí)行不同的操作。來看看它的run方法：

public void run() {
    // 如果是接收的消息
    if (state == ChannelState.RECEIVED) {
        try {
            // 直接調(diào)用下一個(gè)received
            handler.received(channel, message);
        } catch (Exception e) {
            logger.warn("ChannelEventRunnable handle " + state + " operation error, channel is " + channel
                    + ", message is " + message, e);
        }
    } else {
        switch (state) {
            //如果是連接事件請求
        case CONNECTED:
            try {
                // 執(zhí)行連接
                handler.connected(channel);
            } catch (Exception e) {
                logger.warn("ChannelEventRunnable handle " + state + " operation error, channel is " + channel, e);
            }
            break;
            // 如果是斷開連接事件請求
        case DISCONNECTED:
            try {
                // 執(zhí)行斷開連接
                handler.disconnected(channel);
            } catch (Exception e) {
                logger.warn("ChannelEventRunnable handle " + state + " operation error, channel is " + channel, e);
            }
            break;
            // 如果是發(fā)送消息
        case SENT:
            try {
                // 執(zhí)行發(fā)送消息
                handler.sent(channel, message);
            } catch (Exception e) {
                logger.warn("ChannelEventRunnable handle " + state + " operation error, channel is " + channel
                        + ", message is " + message, e);
            }
            break;
            // 如果是異常
        case CAUGHT:
            try {
                // 執(zhí)行異常捕獲
                handler.caught(channel, exception);
            } catch (Exception e) {
                logger.warn("ChannelEventRunnable handle " + state + " operation error, channel is " + channel
                        + ", message is: " + message + ", exception is " + exception, e);
            }
            break;
        default:
            logger.warn("unknown state: " + state + ", message is " + message);
        }
    }

}

可以看到把消息分為了幾種類別，因?yàn)檎埱蠛晚憫?yīng)消息出現(xiàn)頻率明顯比其他類型消息高，也就是RECEIVED，所以多帶帶先做處理，根據(jù)不同的類型的消息，會(huì)被執(zhí)行不同的邏輯，我們這里主要看state為RECEIVED的，那么如果是RECEIVED，則會(huì)執(zhí)行下一個(gè)received方法。

可以參考《dubbo源碼解析（九）遠(yuǎn)程通信——Transport層》的（七）DecodeHandler。可以看到received方法中根據(jù)消息的類型進(jìn)行不同的解碼。而DecodeHandler 存在的意義就是保證請求或響應(yīng)對象可在線程池中被解碼，解碼完成后，就會(huì)分發(fā)到HeaderExchangeHandler的received。

public void received(Channel channel, Object message) throws RemotingException {
    // 設(shè)置接收到消息的時(shí)間戳
    channel.setAttribute(KEY_READ_TIMESTAMP, System.currentTimeMillis());
    // 獲得通道
    final ExchangeChannel exchangeChannel = HeaderExchangeChannel.getOrAddChannel(channel);
    try {
        // 如果消息是Request類型
        if (message instanceof Request) {
            // handle request.
            // 強(qiáng)制轉(zhuǎn)化為Request
            Request request = (Request) message;
            // 如果該請求是事件心跳事件或者只讀事件
            if (request.isEvent()) {
                // 執(zhí)行事件
                handlerEvent(channel, request);
            } else {
                // 如果是正常的調(diào)用請求，且需要響應(yīng)
                if (request.isTwoWay()) {
                    // 處理請求
                    handleRequest(exchangeChannel, request);
                } else {
                    // 如果不需要響應(yīng)，則繼續(xù)下一步
                    handler.received(exchangeChannel, request.getData());
                }
            }
        } else if (message instanceof Response) {
            // 處理響應(yīng)
            handleResponse(channel, (Response) message);
        } else if (message instanceof String) {
            // 如果是telnet相關(guān)的請求
            if (isClientSide(channel)) {
                // 如果是客戶端側(cè)，則直接拋出異常，因?yàn)榭蛻舳藗?cè)不支持telnet
                Exception e = new Exception("Dubbo client can not supported string message: " + message + " in channel: " + channel + ", url: " + channel.getUrl());
                logger.error(e.getMessage(), e);
            } else {
                // 如果是服務(wù)端側(cè)，則執(zhí)行telnet命令
                String echo = handler.telnet(channel, (String) message);
                if (echo != null && echo.length() > 0) {
                    channel.send(echo);
                }
            }
        } else {
            // 如果都不是，則繼續(xù)下一步
            handler.received(exchangeChannel, message);
        }
    } finally {
        // 移除關(guān)閉或者不活躍的通道
        HeaderExchangeChannel.removeChannelIfDisconnected(channel);
    }
}

該方法中就對消息進(jìn)行了細(xì)分，事件請求、正常的調(diào)用請求、響應(yīng)、telnet命令請求等，并且針對不同的消息類型做了不同的邏輯調(diào)用。我們這里主要看正常的調(diào)用請求。見下一步。

void handleRequest(final ExchangeChannel channel, Request req) throws RemotingException {
    // 創(chuàng)建一個(gè)Response實(shí)例
    Response res = new Response(req.getId(), req.getVersion());
    // 如果請求被破壞了
    if (req.isBroken()) {
        // 獲得請求的數(shù)據(jù)包
        Object data = req.getData();

        String msg;
        // 如果數(shù)據(jù)為空
        if (data == null) {
            //消息設(shè)置為空
            msg = null;
            // 如果在這之前已經(jīng)出現(xiàn)異常，也就是數(shù)據(jù)為Throwable類型
        } else if (data instanceof Throwable) {
            // 響應(yīng)消息把異常信息返回
            msg = StringUtils.toString((Throwable) data);
        } else {
            // 返回請求數(shù)據(jù)
            msg = data.toString();
        }
        res.setErrorMessage("Fail to decode request due to: " + msg);
        // 設(shè)置錯(cuò)誤請求的狀態(tài)碼
        res.setStatus(Response.BAD_REQUEST);

        // 發(fā)送該消息
        channel.send(res);
        return;
    }
    // find handler by message class.
    // 獲得請求數(shù)據(jù) 也就是 RpcInvocation 對象
    Object msg = req.getData();
    try {
        // 繼續(xù)向下調(diào)用 返回一個(gè)future
        CompletionStage