消息中间件RocketMQ原理解析 - 斩秋invokeSyncImpl 和 invokeAsyncImpl 都使用了 请求方会 new 一个 ResponseFuture 对象缓存起来 ConcurrentHashMap<Integer /* opaque */, ResponseFuture>,并且设置 opaque 值 Broker 接收请求将 opaque 直接把这个值设置回响应对象,客户端接收到这个响应,通0 码力 | 57 页 | 2.39 MB | 1 年前3
Apache RocketMQ 从入门到实战remainBufferNumbs() { if (storeConfig.isTransientStorePoolEnable()) { return availableBuffers.size(); } return Integer.MAX_VALUE; } 如果启用 transientStorePoolEnable 机制,返回当前可用的 ByteBuffer 个数,即整 个 isTransientStorePoolDeficient0 码力 | 165 页 | 12.53 MB | 1 年前3
共 2 条
- 1













