分布式Vertx系统中日志事件的关联

Question

任何我们可以实现的解决方案或模式？

Answer 1

在基于线程的系统中，当前上下文由当前线程保存，因此MDC或任何ThreadLocal都可以。

在Vertx这样的基于actor的系统中，上下文就是消息，因此必须为发送的每条消息添加一个相关ID。

对于任何处理程序/回调，您必须将其作为方法参数传递，或者引用最终的方法变量。

vertx.eventBus().send("someAddr", 
  new JsonObject().put("correlationId", "someId")
                  .put("payload", yourPayload));

//send
vertx.eventBus().send("someAddr", "someMsg", 
            new DeliveryOptions().addHeader("correlationId", "someId"));

//receive    
vertx.eventBus().consumer("someAddr", msg -> {
        String correlationId = msg.headers().get("correlationId");
        ...
    });