单个Vert.x实例Event Bus线程数及执行模型配置咨询

线程数量与配置规则 #

Vert.x Event Bus 没有独立的专属线程池，默认的消息派发、本地处理逻辑全部复用Vert.x核心的Netty EventLoop线程池：

• 默认线程数为当前部署环境的CPU逻辑核心数 * 2，和Netty默认EventLoop配置一致
• 线程数支持自定义调整，在初始化Vert.x实例时通过VertxOptions配置即可，示例代码：

VertxOptions options = new VertxOptions()
  // 调整EventLoop线程池大小，即Event Bus默认派发使用的线程数
  .setEventLoopPoolSize(16)
  // 调整worker线程池大小，供worker模式消息处理器、executeBlocking逻辑使用，默认值为20
  .setWorkerPoolSize(32);
Vertx vertx = Vertx.vertx(options);

注意：如果是worker模式的Event Bus消息处理器，执行逻辑不会占用EventLoop线程，而是运行在上面配置的worker线程池中。集群模式下Event Bus的节点间网络IO也复用EventLoop线程池资源，不会额外开辟独立线程。

核心执行模型 #

Event Bus 遵循Vert.x整体的异步非阻塞线程模型，核心规则如下：

• 线程绑定规则：普通（非worker）模式注册的消息处理器，会永久绑定到一个固定的EventLoop线程上，同一个处理器永远不会被多线程并发调用，处理器内部不需要额外加锁做线程同步。
• 消息派发逻辑：点对点发送的消息会以轮询策略派发给目标地址注册的某一个处理器；发布订阅模式的消息会派发给目标地址注册的所有处理器，整个派发过程不会阻塞EventLoop线程。
• 低开销优化：如果消息发送方和接收方绑定在同一个EventLoop线程上，消息会直接就地执行处理逻辑，没有额外线程切换开销；如果两者不在同一个EventLoop，消息会被封装为异步任务投递到接收方绑定的EventLoop任务队列，等待对应线程调度执行。
• 阻塞约束：普通模式的消息处理器绝对不能执行阻塞操作（比如长时间休眠、同步JDBC调用、同步HTTP请求等），否则会卡住绑定的EventLoop线程，导致该线程挂载的所有IO任务、其他消息处理器全部暂停响应。存在阻塞需求的逻辑需要注册为worker模式处理器，或者通过executeBlocking方法将逻辑调度到worker线程池执行。
• 集群模式逻辑：跨节点的Event Bus消息会通过节点间维护的集群TCP链路传输，消息到达目标节点后，完全遵循单节点的派发规则调度到对应处理器执行，对上层业务代码透明。

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