rocketmq netty底层设计

rocketmq底层网络使用的netty框架，类图如下

 

　　RecketMQ通信模块的顶层结构是RemotingServer和RemotingClient，分别对应通信的服务端和客户端

首先看看RemotingServer

 1 public interface RemotingServer extends RemotingService {
 2 
 3     void registerProcessor(final int requestCode, final NettyRequestProcessor processor,
 4         final ExecutorService executor);
 5 
 6     void registerDefaultProcessor(final NettyRequestProcessor processor, final ExecutorService executor);
 7 
 8     int localListenPort();
 9 
10     Pair<NettyRequestProcessor, ExecutorService> getProcessorPair(final int requestCode);
11 
12     RemotingCommand invokeSync(final Channel channel, final RemotingCommand request,
13         final long timeoutMillis) throws InterruptedException, RemotingSendRequestException,
14         RemotingTimeoutException;
15 
16     void invokeAsync(final Channel channel, final RemotingCommand request, final long timeoutMillis,
17         final InvokeCallback invokeCallback) throws InterruptedException,
18         RemotingTooMuchRequestException, RemotingTimeoutException, RemotingSendRequestException;
19 
20     void invokeOneway(final Channel channel, final RemotingCommand request, final long timeoutMillis)
21         throws InterruptedException, RemotingTooMuchRequestException, RemotingTimeoutException,
22         RemotingSendRequestException;
23 
24 }

RemotingServer