全站最硬核 百万字强肝RocketMq源码 火热更新中~(十四)

文章目录

      • org.apache.rocketmq.remoting.exception.RemotingTimeoutException

可以看到接下来就是发送请求了,所谓同步调用invokeSync,其实就是使用netty的channel远程发送请求,并对结果做监听。

之后就是等待结果的返回,然后从响应表responseTable中移除对应的Future了。

然后这里对于自定义异常的写法,我们也看下:

org.apache.rocketmq.remoting.exception.RemotingTimeoutException

这个类比较短小,直接都贴过来看。没什么逻辑,但是写法值得学习,而且对异常信息的打印也很全。

回到NettyRemotingServer,在同步调用invokeSync下面自然就是异步调用invokeAsync

文章知识点与官方知识档案匹配,可进一步学习相关知识Java技能树首页概览93529 人正在系统学习中

声明:本站部分文章及图片源自用户投稿,如本站任何资料有侵权请您尽早请联系jinwei@zod.com.cn进行处理,非常感谢!

上一篇 2022年1月16日
下一篇 2022年1月16日

相关推荐