import io.vertx.core.spi.metrics.HttpServerMetrics; //导入依赖的package包/类
@Override
public HttpServerMetrics createMetrics(final HttpServer server, final SocketAddress localAddress, final HttpServerOptions options) {
    HttpServerMetricsImpl httpServerMetricsImpl = new HttpServerMetricsImpl(statfulMetricsOptions);
    httpServerMetricsImpl.setSender(this.getOrCreateSender());
    this.poolMetricsCollectors.forEach(collector -> collector.setSender(this.getOrCreateSender()));
    return httpServerMetricsImpl;
}
 

import io.vertx.core.spi.metrics.HttpServerMetrics; //导入依赖的package包/类
@Override
default HttpServerMetrics<?, ?, ?> createMetrics(HttpServer server, SocketAddress localAddress, HttpServerOptions options) {
    return DummyVertxMetrics.DummyHttpServerMetrics.INSTANCE;
}
 

import io.vertx.core.spi.metrics.HttpServerMetrics; //导入依赖的package包/类
public DispatchingHttpServerMetrics(List<? extends HttpServerMetrics> delegates) {
    super(delegates);
}
 

import io.vertx.core.spi.metrics.HttpServerMetrics; //导入依赖的package包/类
@Override
public Map<HttpServerMetrics, ?> requestBegin(Map<HttpServerMetrics, ?> socketMetric,
                                              HttpServerRequest request) {
    return unmapWithResult(socketMetric, (m, c) -> m.requestBegin(c, request));
}
 

import io.vertx.core.spi.metrics.HttpServerMetrics; //导入依赖的package包/类
@Override
public void requestReset(Map<HttpServerMetrics, ?> requestMetric) {
    unmap(requestMetric, (m, c) -> m.requestReset(c));
}
 

import io.vertx.core.spi.metrics.HttpServerMetrics; //导入依赖的package包/类
@Override
public Map<HttpServerMetrics, ?> responsePushed(Map<HttpServerMetrics, ?> socketMetric,
                                                HttpMethod method, String uri, HttpServerResponse response) {
    return unmapWithResult(socketMetric,
            (m, c) -> m.responsePushed(c, method, uri, response));
}
 

import io.vertx.core.spi.metrics.HttpServerMetrics; //导入依赖的package包/类
@Override
public void responseEnd(Map<HttpServerMetrics, ?> requestMetric, HttpServerResponse response) {
    unmap(requestMetric, (m, c) -> m.responseEnd(c, response));
}
 

import io.vertx.core.spi.metrics.HttpServerMetrics; //导入依赖的package包/类
@Override
public Map<HttpServerMetrics, ?> upgrade(Map<HttpServerMetrics, ?> requestMetric, ServerWebSocket serverWebSocket) {
    return unmapWithResult(requestMetric, (m, c) -> m.upgrade(c, serverWebSocket));
}
 

import io.vertx.core.spi.metrics.HttpServerMetrics; //导入依赖的package包/类
@Override
public Map<HttpServerMetrics, ?> connected(Map<HttpServerMetrics, ?> socketMetric, ServerWebSocket serverWebSocket) {
    return unmapWithResult(socketMetric, (m, c) -> m.connected(c, serverWebSocket));
}
 

import io.vertx.core.spi.metrics.HttpServerMetrics; //导入依赖的package包/类
@Override
public void disconnected(Map<HttpServerMetrics, ?> serverWebSocketMetric) {
    unmap(serverWebSocketMetric, (m, c) -> m.disconnected(c));
}
 

import io.vertx.core.spi.metrics.HttpServerMetrics; //导入依赖的package包/类
@Override
public HttpServerMetrics<?, ?, ?> createMetrics(HttpServer server, SocketAddress localAddress, HttpServerOptions options) {
    return this.<HttpServerMetrics<?, ?, ?>> createSubMetrics(v -> v.createMetrics(server, localAddress, options),
            d -> new DispatchingHttpServerMetrics(d));
}
 

import io.vertx.core.spi.metrics.HttpServerMetrics; //导入依赖的package包/类
@Override
public HttpServerMetrics<?, ?, ?> createMetrics(HttpServer server, SocketAddress localAddress,
                                                HttpServerOptions options) {
    return new HttpServerMetricsImpl(counterService, gaugeService, properties.getHttp().getServer());
}
 

import io.vertx.core.spi.metrics.HttpServerMetrics; //导入依赖的package包/类
@Override
public HttpServerMetrics<Long, Void, Void> createMetrics(HttpServer server, SocketAddress localAddress, HttpServerOptions options) {
  HttpServerMetricsSupplier supplier = (HttpServerMetricsSupplier) metricSuppliers.get(HTTP_SERVER);
  return supplier != null ? new HttpServerMetricsImpl(localAddress, supplier) : super.createMetrics(server, localAddress, options);
}
 

import io.vertx.core.spi.metrics.HttpServerMetrics; //导入依赖的package包/类
@Override
public HttpServerMetrics<?, ?, ?> createMetrics(HttpServer server, SocketAddress localAddress, HttpServerOptions options) {
  String baseName = MetricRegistry.name(nameOf("http.servers"), TCPMetricsImpl.addressName(localAddress));
  return new HttpServerMetricsImpl(registry, baseName, this.options.getMonitoredHttpServerUris(), localAddress);
}