ThreadSafeRpcEndpoint对消息的处理都是串行的,即前一条消息处理完才能接着处理下一条消息。ThreadSafeRpcEndpoint的继承体系如图5-3所示。
5.3.2 RPC端点引用RpcEndpointRef
3.Inbox的消息来源
MessageLoop线程的执行逻辑是不断地消费各个EndpointData中Inbox里的消息,但是EndpointData是何时放入receivers中的?Inbox里的消息来自哪里?Dispatcher中有很多完成这些功能的方法,让我们一起看看Dispatcher中与此相关的一些方法。
(1)注册RpcEndpoint
根据OutboxMessage的名称,我们很容易与Dispatcher中Inbox里的InboxMessage类型的消息关联起来。OutboxMessage在客户端使用,是对外发送消息的封装。InboxMessage在服务端使用,是对所接收消息的封装。OutboxMessage的继承体系如图5-9所示。
根据本节对客户端发送请求的分析,现在我们可以将此流程用图5-10表示。