RocketMQ生产者同步发送消息
2020-10-28 17:02:26 13 举报RocketMQ生产者同步发送消息
作者其他创作
大纲/内容
根据broker name获取broker地址
invokeSyncImpl
selectOneMessageQueue
选取一个MessageQueue
MQClientAPIImpl
获取topicInfo
invokeSync
sendKernelImpl
sendMessage
send(msg)
MQClientInstance
NettyRemotingClient
DefaultMQProducerImpl
findBrokerAddressInPublish
sendMessageSync
tryToFindTopicPublishInfo
DefaultMQProducer
0 条评论
下一页
