1

我正在使用 Spring RestTemplate 对我的 RestService 进行 HTTP 调用。我使用的是 Spring Framework 3.2.8 版本的 RestTemplate。我无法升级它，因为在我们公司我们有一个父 POM，我们在其中使用 Spring Framework 版本 3.2.8，所以我需要坚持下去。

假设我有两台机器：

  • machineA：这台机器正在运行我的代码，它使用 RestTemplate 作为我的 HttpClient，并且从这台机器上我对在另一台机器（machineB）上运行的 RestService 进行 HTTP 调用。我将以下代码包装在多线程应用程序周围，以便我可以对我的客户端代码进行负载和性能测试。
  • machineB：在这台机器上，我正在运行我的 RestService。

现在我看到的问题是每当我在 machineA 上运行负载和性能测试时 - 意思是，我的客户端代码将对在 machineB 上运行的 RestService 进行大量 HTTPClient 调用，因为客户端代码是以多线程方式调用的。

我总是看到很多 TIME_WAIT 连接，machineA如下所示：

   298 ESTABLISHED
    14 LISTEN
     2 SYN_SENT
 10230 TIME_WAIT

  291 ESTABLISHED
   14 LISTEN
    1 SYN_SENT
17767 TIME_WAIT

    285 ESTABLISHED
   14 LISTEN
    1 SYN_SENT
24055 TIME_WAIT

我不认为我们在这里有很多 TIME_WAIT 连接是一个好兆头。 问题陈述：-

  • TIME_WAIT在 machineA 上用一种简单的语言来说，这种高度连接意味着什么？
  • RestTemplate 发生这种情况是否有任何原因，或者只是我使用 RestTemplate 的方式？如果我在使用 RestTemplate 的方式上做错了什么，那么正确的使用方法是什么？

使用 RestTemplate 时是否需要设置任何keep-alive标题或内容？Connection:Close非常感谢任何输入/建议，因为我对这里发生的事情感到困惑。

下面是我如何以一种简单的方式在我的代码库中使用 RestTemplate（只是为了解释我如何使用 RestTemplate 的整个想法）：

public class DataClient implements Client {

    private final RestTemplate restTemplate = new RestTemplate();
    private ExecutorService executor = Executors.newFixedThreadPool(10);

    // for synchronous call
    @Override
    public String getSyncData(DataKey key) {        
        String response = null;
        Future<String> handler = null;
        try {
            handler = getAsyncData(key);
            response = handler.get(100, TimeUnit.MILLISECONDS); // we have a 100 milliseconds timeout value set
        } catch (TimeoutException ex) {
            // log an exception
            handler.cancel(true);
        } catch (Exception ex) {
            // log an exception
        }

        return response;
    }

    // for asynchronous call
    @Override
    public Future<String> getAsyncData(DataKey key) {
        Future<String> future = null;

        try {
            Task task = new Task(key, restTemplate);
            future = executor.submit(task); 
        } catch (Exception ex) {
            // log an exception
        }

        return future;
    }
}

下面是我的简单任务类

class Task implements Callable<String> {

    private final RestTemplate restTemplate;
    private final DataKey key;

    public Task(DataKey key, RestTemplate restTemplate) {
        this.key = key;
        this.restTemplate = restTemplate;
    }

    public String call() throws Exception {
        ResponseEntity<String> response = null;

        String url = "some_url_created_by_using_key";

        // handling all try catch here
        response = restTemplate.exchange(url, HttpMethod.GET, null, String.class);

        return response.getBody();
    }
}
4

1 回答 1

0

“TIME_WAIT”是 TCP 连接在关闭（FIN/FIN 接收）后可配置的时间内保持的状态。这样，一个连接的可能“延迟”数据包不能与重用同一端口的后一个连接混合。

在高流量的测试中，有很多它们是正常的，但它们应该在几分钟测试完成后消失。

于 2015-06-05T10:26:37.060 回答