引言

本文主要是介绍RocketMQ的通信模块，通过对于源码的阅读，拆解其中的底层通信原理。一篇文章很难完全讲清楚这其中的道道，所以会分几篇文章来进行阐述。

• 模块介绍
• 为何使用Netty通信作为底层通信框架
• 总结

一、模块介绍

Remoting模块的类结构图如下所示：

其中RemotingService是顶层接口，该接口中提供了三个方法如下所示：

public interface RemotingService {
    void start();

    void shutdown();

    void registerRPCHook(RPCHook rpcHook);
}

其中RemotingClient和RemotingSever同时继承了顶层接口RemotingService，

public interface RemotingServer extends RemotingService {

    void registerProcessor(final int requestCode, final NettyRequestProcessor processor,
        final ExecutorService executor);

    void registerDefaultProcessor(final NettyRequestProcessor processor, final ExecutorService executor);

    int localListenPort();

    Pair<NettyRequestProcessor, ExecutorService> getProcessorPair(final int requestCode);

    RemotingCommand invokeSync(final Channel channel, final RemotingCommand request,
        final long timeoutMillis) throws InterruptedException, RemotingSendRequestException,
        RemotingTimeoutException;

    void invokeAsync(final Channel channel, final RemotingCommand request, final long timeoutMillis,
        final InvokeCallback invokeCallback) throws InterruptedException,
        RemotingTooMuchRequestException, RemotingTimeoutException, RemotingSendRequestException;

    void invokeOneway(final Channel channel, final RemotingCommand request, final long timeoutMillis)
        throws InterruptedException, RemotingTooMuchRequestException, RemotingTimeoutException,
        RemotingSendRequestException;

}

NettyRemotingAbstract：Netty通信处理的抽象类，定义并封装了Netty处理的公共处理方法；

NettyRemotingClient以及NettyRemotingServer：分别实现了RemotingClient和RemotingServer，都继承了NettyRemotingAbstract抽象类。RocketMQ中其他的组件（如client、nameServer、broker在进行消息的发送和接收时均使用这两个组件）。

二、为何使用Netty通信作为底层通信框架

在看RocketMQ中的reomoting模块时，我们可以发现它的RPC调用部分是通过Netty来进行封装实现的。Netty是一个异步事件驱动的网络通信应用程序框架，通过它可以快速开发可维护的高性能协议服务器和客户端。详细的介绍这里不会再展开，后面会通过专题进行详细介绍。大致的结构如下所示：

现在的问题是，RocketMQ为什么选择Netty作为其底层通信框架呢？那可能要从Netty的优点来说了，我相信大多数框架选择其作为通信框架的原因。总结其中的优点如下：
1、Netty实现了对于JDK的NIO的封装，这样就屏蔽了NIO的复杂概念以及繁琐的编程细节，不需要再关心Selector、ServerSocketChannel、SocketChannel、ByteBuffer等这些细节，对于开发者来说更加容易上手；
2、Netty已经在多个开源项目（Hadoop的RPC框架avro使用Netty作为通信框架）中都得到了充分验证，健壮性/可靠性比较好；
3、Netty框架内部对线程，selector做了一些细节的优化，精心设计的reactor多线程模型，可以实现非常高效地并发处理；
4、Netty解决了（准确地说应该是采用了另一种方式完美规避了）JDK NIO的Bug（Epoll bug，会导致Selector空轮询，最终导致CPU 100%）；
5、对于开发者来说，我们可以根据业务的要求进行定制化开发，通过Netty的ChannelHandler对通信框架进行灵活的定制化扩展；

三、总结

本文主要介绍了RocketMQ的大致代码结构，以及为什么选择Netty作为其底层的通信框架。后续的文章中再深入阐述其中的实现细节。