setSendRequestOK(true); 发送失败 responseFuture.setSendRequestOK(false), 信号量通过 once 释放， 删 除缓存 Netty 接收 server 端响应，根据 opaque 从缓存获取 responseFuture，调用回调方法即接 口 InvokeCallback 实现 3. invokeOnewayImpl

下面是 CORBA Notification 规范中处理方式： (1). RejectNewEvents 拒绝新来的消息，吐 Producer 迒回 RejectNewEvents 错诨码。 (2). 挄照特定策略丢弃已有消息 a) AnyOrder - Any event may be discarded on overflow. This is the default setting 可以由应用自由设置。只有収送消息设置了 tags，消费方在订阅消息时，才可以利用 tags 在 broker 做消息过滤。 message.setTags("TagA"); 2. 每个消息在业务局面的唯一标识码，要设置到 keys 字段，方便将来定位消息丢失问题。服务器会为每个消 息创建索引（哈希索引），应用可以通过 topic，key 来查询返条消息内容，以及消息被谁消费。由亍是哈希 索引，请务必保证

当前最新的物理偏移量之间的差距查过 内存的 40%，下一次拉取会往从节点发送（当然前提是 slaveReadEnable = true）。 2. 当从节点开始接管消息消费时，下一次拉取请求一定会往从节点发送码？答案也是不一 定：  如果待拉取的消息偏移量与从节点最新的物理偏移量之间的差距超过内存的 30%，下 一次拉取请求还是会发往从节点。  如果待拉取的消息偏移量与从节点最新的物理偏移量之际的差距少于内存的 success 是发送成功。 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 153 > 1.16 RocketMQ 消息轨迹-设计篇  contextCode 消费状态码，可选值：SUCCESS,TIME_OUT,EXCEPTION,RETURNNULL, FAILED。 二、记录消息轨迹 消息中间件的两大核心主题：消息发送、消息消费，其核心载体就是消息，消息轨迹（消