我正在尝试通过vertx事件总线发送大量消息，例如（使用hazelcast群集）而不阻塞：

EventBus eb = vertx.eventBus();

for (int i = 0; i < 100; i++) {
  vertx.setPeriodic(1, num -> {
    eb.send("clusteredEndpoint", "ping");
  });
}

当计时器的数量较少时，它可以正常工作，但是在大约100个计时器时，我会得到这个错误。
我想知道如何在不阻塞的情况下扩展到100k事件/秒（作为参考，我编写了一个vertxwebsocket测试，它可能会超过这个数字）。
如果不可能的话，我想了解什么是阻塞-看起来像是这门课上的东西：https://github.com/eclipse-vertx/vert.x/blob/master/src/main/java/io/vertx/core/eventbus/impl/clustered/serializer.java
参考-此代码不阻塞-即使使用1000个计时器：

HttpClient client = vertx.createHttpClient();
client.webSocket(8080, "localhost", "/", res -> {
  for (int i = 0; i < 1000; i++) {
    vertx.setPeriodic(1, num -> {
      res.result().writeTextMessage("ping");
    });
  }
});
});

2020年12月15日上午10:54:38 io.vertx.core.impl.blockedthreadchecker警告：线程[vert.x-eventloop-thread-1,5，main]已被阻塞36794毫秒，时间限制为2000毫秒io.vertx.core.vertxexception:线程在io.vertx.core.impl.future.futureimpl.addlistener（futureimpl。java:140)在io.vertx.core.impl.future.promiseimpl.addlistener（promiseimpl。java:23)在io.vertx.core.impl.future.futureimpl.oncomplete（futureimpl。java:133)在io.vertx.core.impl.future.promiseimpl.oncomplete（promiseimpl。java:23)在io.vertx.core.spi.cluster.impl.selector.selectors.withselector（选择器。java:48)在io.vertx.core.spi.cluster.impl.defaultnodeselector.selectforsend（defaultnodeselector。java:42)在io.vertx.core.eventbus.impl.clusteredeventbus$$lambda$1065/195695453.accept（未知在io.vertx.core.eventbus.impl.clustered.serializer$serializerqueue$serializedtask.process（serializer。java:147)位于io.vertx.core.eventbus.impl.clustered.serializer$serializerqueue.checkpending（序列化程序）。java:94)在io.vertx.core.eventbus.impl.clustered.serializer$serializerqueue.add（serializer。java:114)在io.vertx.core.eventbus.impl.clustered.serializer.queue（序列化程序。java:65)在io.vertx.core.eventbus.impl.clusteredeventbus.sendorpub（clusteredeventbus。java:172)在io.vertx.core.eventbus.impl.outbounddeliverycontext.next（outbounddeliverycontext。java:127)在io.vertx.core.eventbus.impl.eventbusimpl.SendorPubiInternal（eventbusimpl。java:394)在io.vertx.core.eventbus.impl.eventbusimpl.sendorpubinternal（eventbusimpl。java:400)在io.vertx.core.eventbus.impl.eventbusimpl.send（eventbusimpl。java:103)在io.vertx.core.eventbus.impl.eventbusimpl.send（eventbusimpl。java:97)在io.vertx.example.ebtestclient.lambda$start$0（ebtestclient。java:22)在io.vertx.example.ebtestclient$$lambda$1056/1487417027.handle（未知源）在io.vertx.core.impl.vertximpl$internaltimerhandler.handle（vertximpl。java:939)在io.vertx.core.impl.vertximpl$internaltimerhandler.handle（vertximpl。java:910)在io.vertx.core.impl.eventloopcontext.emit（eventloopcontext。java:52)在io.vertx.core.impl.contextimpl.emit（contextimpl。java:294)在io.vertx.core.impl.eventloopcontext.emit（eventloopcontext。java:24)在io.vertx.core.impl.abstractcontext.emit（abstractcontext。java:49)在io.vertx.core.impl.eventloopcontext.emit（eventloopcontext。java:24)在io.vertx.core.impl.vertximpl$internaltimerhandler.run（vertximpl。java:933)在io.netty.util.concurrent.promisetask.runtask（promisetask。java:98)在io.netty.util.concurrent.scheduledfuturetask.run（scheduledfuturetask。java:176)在io.netty.util.concurrent.abstracteventexecutor.safeexecute（abstracteventexecutor。java:164)在io.netty.util.concurrent.singlethreadeventexecutor.runalltasks（singlethreadeventexecutor。java:472)在io.netty.channel.nio.nioeventloop.run（nioeventloop。java:500)在io.netty.util.concurrent.singlethreadeventexecutor$4.run（singlethreadeventexecutor。java:989)在io.netty.util.internal.threadexecutormap$2.run（threadexecutormap。java:74)在io.netty.util.concurrent.fastthreadlocalrunnable.run（fastthreadlocalrunnable。java:30)在java.lang.thread.run（线程。java:748)