3

我编写了一个ratpack 处理程序来测量处理程序链的执行时间。

public class EndpointMetricsEmitter implements Handler {

  public static final String HANDLE_DURATION_METRIC = "HANDLE_DURATION_MILLIS";
  private final MetricContext baseContext;
  private MonitoringRegistry registry;

  public EndpointMetricsEmitter(MonitoringRegistry monitoringRegistry) {
    this.registry = monitoringRegistry;
    this.baseContext = MetricContext.newContext(REST);
  }

  @Override
  public void handle(Context ctx) throws Exception {
    Instant start = Instant.now();
    ctx.next();
    Instant end = Instant.now();
    long dur = Duration.between(start, end).toMillis();
    MetricContext endpointCtx = this.baseContext.withService(ctx.getPathBinding().getDescription());
    this.registry.timer(endpointCtx, HANDLE_DURATION_METRIC, dur);

  }

问题是我意识到这ctx.next()是一个异步方法并且它返回void.

有没有办法在链的最后一个处理程序返回时调用函数？

谢谢你

4

1 回答 1

-1

一种方法是使用 ChannelHandlerContext attributeMap api。

我要做的是创建某种统计信息 pojo，在第一个处理程序中对其进行初始化，并在您的最终处理程序中对其进行更新。

这样做的一个好处是，管道中的每个处理程序都可以选择跟踪其各自的性能并自行更新属性。

于 2020-05-06T02:07:25.287 回答