Vert.x 4.x如何设置MessageProducer写入队列最大大小并监控队列状态

Vert.x 4.x 并未移除MessageProducer的队列大小限制、状态监控能力，只是在API重构时将原本依赖WriteStream接口实现的队列管控能力，直接下沉为MessageProducer的原生方法，方法签名、运行逻辑和3.x版本完全一致，可直接实现等价的背压管控效果。

对应能力映射关系 #

• 写队列最大长度设置：直接调用MessageProducer自带的setWriteQueueMaxSize(int maxSize)方法即可，和3.x中WriteStream接口提供的同名方法用法完全一致，传入你需要的队列阈值即可生效。
• 队列满状态检测：直接调用MessageProducer自带的writeQueueFull()方法，返回true时代表当前待发送消息队列已经达到设置的阈值，和3.x的判断逻辑无差异。
• 队列可写状态监听：直接调用MessageProducer自带的drainHandler(Handler<Void> handler)方法，当队列占用从满阈值回落到安全水位时，注册的处理器会被触发，用来恢复暂停的消息发送流程。

代码使用示例 #

// 初始化消息生产者
MessageProducer<String> producer = vertx.eventBus().sender("target.biz.address");
// 设置队列最大长度为1000
producer.setWriteQueueMaxSize(1000);

// 批量发送消息时的背压管控逻辑
public void sendBatch(List<String> messageList) {
  for (String msg : messageList) {
    if (producer.writeQueueFull()) {
      // 队列打满时暂停发送，注册drainHandler等待队列可写后继续
      int currentIndex = messageList.indexOf(msg);
      producer.drainHandler(v -> sendBatch(messageList.subList(currentIndex, messageList.size())));
      return;
    }
    producer.write(msg);
  }
}

注：4.x调整MessageProducer和WriteStream的继承关系，核心目的是收敛EventBus发送端的API能力，避免暴露WriteStream接口中不适用EventBus场景的多余方法，所有和队列管控相关的核心能力均做了保留，不需要额外依赖其他组件即可实现和3.x完全一致的管控逻辑。

内容的提问来源于stack exchange，提问作者zxz