Vertx 中 init() 的用途和行为 class

Question

我有以下 Verticle 用于测试目的：

public class UserVerticle extends AbstractVerticle {

  private static final Logger log = LoggerFactory.getLogger(UserVerticle.class);

  @Override
  public void start(Future<Void> sf) {
    log.info("start()");
    JsonObject cnf = config();
    log.info("start.config={}", cnf.toString());
    sf.complete();
  }

  @Override
  public void stop(Future<Void> sf) {
    log.info("stop()");
    sf.complete();
  }

  private void onMessage(Message<JsonObject> message) { ... }
    log.info("onMessage(message={})", message);
  }

}

Is 是从主 Verticle 部署的

  vertx.deployVerticle("org.buguigny.cluster.UserVerticle",
                 new DeploymentOptions()
                 .setInstances(1)
                 .setConfig(new JsonObject()
                        .put(some_key, some_data)
                        ),
                 ar -> {
                   if(ar.succeeded()) {
                     log.info("UserVerticle(uname={}, addr={}) deployed", uname, addr);
                     // continue when OK
                   }
                   else {
                     log.error("Could not deploy UserVerticle(uname={}). Cause: {}", uname, ar.cause());
                     // continue when KO
                   }
                 });

这段代码工作正常。

我查看了 Verticle 文档并 发现了 一个我以前没见过的 init() 回调方法。由于文档没有太多说明它的实际作用，我定义它是为了查看它在 Verticle 的生命周期中的哪个位置被调用。

  @Override
  public void init(Vertx vertx, Context context) {
    log.info("init()");
    JsonObject cnf = context.config();
    log.info("init.config={}", cnf.toString());
  }

但是，当定义 init() 时，我在 start() 中调用 JsonObject cnf = config(); 的行上得到一个 java.lang.NullPointerException:

java.lang.NullPointerException: null
    at io.vertx.core.AbstractVerticle.config(AbstractVerticle.java:85)
    at org.buguigny.cluster.UserVerticle.start(UserVerticle.java:30)
    at io.vertx.core.impl.DeploymentManager.lambda$doDeploy(DeploymentManager.java:494)
    at io.vertx.core.impl.ContextImpl.executeTask(ContextImpl.java:320)
    at io.vertx.core.impl.EventLoopContext.lambda$executeAsync[=14=](EventLoopContext.java:38)
    at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
    at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:462)
    at io.netty.util.concurrent.SingleThreadEventExecutor.run(SingleThreadEventExecutor.java:897)
    at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
    at java.lang.Thread.run(Thread.java:748)

我的问题是：

Q1：有什么线索可以抛出 NullPointerException 吗？

Q2 : init() 的目的是什么？它是 Vertx 内部的还是可以由客户端代码实现，例如，在部署配置中传递的 Verticle 对象中定义一些字段？

Answer 1

init 方法供内部使用，并在 Javadoc 中作了记录。这是源代码：

  /**
   * Initialise the verticle.<p>
   * This is called by Vert.x when the verticle instance is deployed. Don't call it yourself.
   * @param vertx  the deploying Vert.x instance
   * @param context  the context of the verticle
   */
  @Override
  public void init(Vertx vertx, Context context) {
    this.vertx = vertx;
    this.context = context;
  }

如果 init 记录在任何用户文档中是错误的，请报告。

Vertx 中 init() 的用途和行为 class

Purpose and behaviour of init() in Vertx class

vert.x

vertx-verticle