测量Spring RestTemplate的HTTP请求时间

Question

我想要测量一个RestTemplate.getForObject请求的HTTP GET请求时间，但不希望包括解析响应所需的时间，只需要远程HTTP调用所需的时间。我已经尝试设置ClientHttpRequestInterceptor，但我认为这不是正确的方法，因为时间似乎是错误的。

public class PerfRequestSyncInterceptor implements ClientHttpRequestInterceptor {
private Logger log = Logger.getLogger(this.getClass());

@Override
  public ClientHttpResponse intercept(HttpRequest request, byte[] body,
        ClientHttpRequestExecution execution) throws IOException {

    long start = System.nanoTime();
    ClientHttpResponse resp = execution.execute(request, body);

    log.debug("remote request time: "
            + ((System.nanoTime() - start) * Math.pow(10, -9)));
    return resp;
  }
}

呼叫：

RestTemplate rest = new RestTemplate();
List<ClientHttpRequestInterceptor> interceptors = new ArrayList<ClientHttpRequestInterceptor>();
interceptors.add(new PerfRequestSyncInterceptor());
rest.setInterceptors(interceptors);

Response inob = rest.getForObject(xmlURL, Response.class);

我该如何测量 RestTemplate HTTP 请求的时间？

- whlk

---

我曾经遇到过同样的问题。你需要在响应对象上调用一个方法来阻止执行，直到响应可用。 - jaydfwtx

Answer 1

您可以使用Spring框架提供的AOP和内置的PerformanceMonitorInterceptor来实现性能监控。您需要正确定义要拦截哪个类的哪些方法，然后就可以进行测量。您可以配置如下内容：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xsi:schemaLocation="http://www.springframework.org/schema/beans      
        http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
        http://www.springframework.org/schema/aop   
        http://www.springframework.org/schema/aop/spring-aop-2.0.xsd">
    <bean id="springMonitoredService"
        class="com.myorg.service.springmon.MyServiceSpringImpl"/>


    <bean id="springMonitoringAspectInterceptor"        
class="org.springframework.aop.interceptor.PerformanceMonitorInterceptor">
        <property name="loggerName"     
                value="com.myorg.SPRING_MONITOR"/>      
    </bean>


    <aop:config>
            <aop:pointcut id="springMonitoringPointcut"
                   expression="execution(* java.net.HttpURLConnection.connect(..))"/>




                <aop:advisor pointcut-ref="springMonitoringPointcut" 
            advice-ref="springMonitoringAspectInterceptor"/>      
    </aop:config>

</beans>

- Peter Szanto

---

我应该配置哪种方法来进行测量？ - whlk

在内部，RestTemplate 使用 java.net.HttpURLConnection，您需要测量 connect() 方法。此外，您还可以尝试 getDoOutput() 方法。 - Peter Szanto

我可以请您更新答案以指向这些方法吗？ - whlk

这对我不起作用。但是，如果我将表达式更改为我的类的公共方法，该方法使用rest template，则可以正常工作。我的模板版本是否未使用HttpURLConnection？ - Asif

Answer 2

你可以使用计时器来完成这个任务。

public class PerfRequestSyncInterceptor implements ClientHttpRequestInterceptor {

    private final static Logger LOG = LoggerFactory.getLogger(PerfRequestSyncInterceptor.class);

    @Override
    public ClientHttpResponse intercept(HttpRequest hr, byte[] bytes, ClientHttpRequestExecution chre) throws IOException {
        StopWatch stopwatch = StopWatch.createStarted();
        ClientHttpResponse response = chre.execute(hr, bytes);
        stopwatch.stop();

        LOG.info("method=" + hr.getMethod() + ", uri="+hr.getURI() + ", response_time=" + stopwatch.elapsed(TimeUnit.MILLISECONDS) + ", response_code=" + response.getStatusCode().value());

        return response;
    }
}

在实例化restTemplate的类中。

private final List<ClientHttpRequestInterceptor> requestInterceptors = new ArrayList<>();
requestInterceptors.add(new PerfRequestSyncInterceptor());
this.restTemplate.setInterceptors(requestInterceptors);

在maven中添加秒表依赖：

<dependency>
  <groupId>com.google.guava</groupId>
  <artifactId>guava</artifactId>
  <version>r05</version>
</dependency>

- Sergio Felipe Riquelme Hurtado

---

谢谢您的回答。我尝试了，但结果并非预期。可能是由于Spring的更改（我没有进行调查）。只想在这里提醒其他人，在这种情况下不要依赖结果。我在调试模式下向服务器发出了一个请求，所以我必须在服务器上按两次Resume，但拦截器测量到1ms的时间 - 这是不可能的。 - J.R.

我也遇到了由@J.R.所述的同样问题，请勿使用此。 - Sahil333

Answer 3

我想要衡量一个RestTemplate.getForObject调用的 HTTP GET 请求时间，而不计算解析响应所需的时间。 我有同样的要求。我想知道服务器响应时间，以判断服务器在没有任何 RestTemplate 响应处理的情况下响应需要多长时间。我向 HttpClientBuilder 添加了两个拦截器和一个映射，以便我可以测量低级请求和响应之间的时间。

HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();

// Attach interceptors
ResponseTimeInterceptor interceptor = new ResponseTimeInterceptor();
httpClientBuilder.addInterceptorFirst( (HttpRequestInterceptor) interceptor );
httpClientBuilder.addInterceptorFirst( (HttpResponseInterceptor) interceptor );

// Use client with RestTemplate or on its own
HttpClient client = httpClientBuilder.build();

这是最小的双重拦截器：

public class ResponseTimeInterceptor implements HttpRequestInterceptor, HttpResponseInterceptor {
    private final Map<HttpContext, Long> requestMap = new MaxSizeHashMap<>( 50 );

    @Override
    public void process( HttpRequest httpRequest, HttpContext httpContext ) throws HttpException, IOException {
        requestMap.put( httpContext, System.currentTimeMillis() );
    }

    @Override
    public void process( HttpResponse httpResponse, HttpContext httpContext ) throws HttpException, IOException {
        long startTime = requestMap.getOrDefault( httpContext, 0L );
        long diff = System.currentTimeMillis() - startTime;
        System.out.println( "Response time: " + diff + "ms" );
    }
}

响应拦截器返回后，响应数据继续进入RestTemplate响应处理程序。

注意：MaxSizeHashMap取自https://dev59.com/NW035IYBdhLWcg3wJccv#5601377。

- Drakes