내 클라우드의 여러 서버에 BIT (Built in tests)를 만들고 싶습니다. 큰 시간 초과시 실패하는 요청이 필요합니다.
Java로 어떻게해야합니까?
아래와 같이 시도해도 작동하지 않는 것 같습니다.
public class TestNodeAliveness {
public static NodeStatus nodeBIT(String elasticIP) throws ClientProtocolException, IOException {
HttpClient client = new DefaultHttpClient();
client.getParams().setIntParameter("http.connection.timeout", 1);
HttpUriRequest request = new HttpGet("http://192.168.20.43");
HttpResponse response = client.execute(request);
System.out.println(response.toString());
return null;
}
public static void main(String[] args) throws ClientProtocolException, IOException {
nodeBIT("");
}
}
-편집 : 사용중인 라이브러리를 명확히-
아파치에서 httpclient를 사용하고 있습니다. 여기에 관련 pom.xml 섹션이 있습니다.
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.0.1</version>
<type>jar</type>
</dependency>
답변
import org.apache.http.client.HttpClient;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.params.BasicHttpParams;
import org.apache.http.params.HttpConnectionParams;
import org.apache.http.params.HttpParams;
...
// set the connection timeout value to 30 seconds (30000 milliseconds)
final HttpParams httpParams = new BasicHttpParams();
HttpConnectionParams.setConnectionTimeout(httpParams, 30000);
client = new DefaultHttpClient(httpParams);
답변
Http Client 버전 4.3 이상을 사용하는 경우 다음을 사용해야합니다.
RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(30 * 1000).build();
HttpClient httpClient = HttpClientBuilder.create().setDefaultRequestConfig(requestConfig).build();
답변
HttpParams는 새로운 Apache HTTPClient 라이브러리에서 더 이상 사용되지 않습니다. Laz에서 제공하는 코드를 사용하면 지원 중단 경고가 표시됩니다.
HttpGet 또는 HttpPost 인스턴스에서 대신 RequestConfig를 사용하는 것이 좋습니다.
final RequestConfig params = RequestConfig.custom().setConnectTimeout(3000).setSocketTimeout(3000).build();
httpPost.setConfig(params);
답변
내가 알지 못하는 HttpClient API를 사용중인 것 같지만 핵심 Java를 사용하여 이와 유사한 것을 작성할 수 있습니다.
try {
HttpURLConnection con = (HttpURLConnection) new URL(url).openConnection();
con.setRequestMethod("HEAD");
con.setConnectTimeout(5000); //set timeout to 5 seconds
return (con.getResponseCode() == HttpURLConnection.HTTP_OK);
} catch (java.net.SocketTimeoutException e) {
return false;
} catch (java.io.IOException e) {
return false;
}
답변
나는의 설정에서 시간을 설정하는 것을 발견 HttpConnectionParams
하고 HttpConnectionManager
우리의 사건을 해결하지 않았다. org.apache.commons.httpclient
버전 3.0.1 사용으로 제한됩니다 .
나는 통화 java.util.concurrent.ExecutorService
를 모니터링하기 위해을 사용했습니다 HttpClient.executeMethod()
.
다음은 독립적 인 작은 예입니다.
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.methods.EntityEnclosingMethod;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.httpclient.methods.multipart.FilePart;
import org.apache.commons.httpclient.methods.multipart.MultipartRequestEntity;
import org.apache.commons.httpclient.methods.multipart.Part;
import java.io.File;
import java.io.IOException;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.*;
/**
* @author Jeff Kirby
* @since <pre>Jun 17, 2011</pre>
*/
public class Example {
private static final String SITE = "http://some.website.com/upload";
private static final int TIME_OUT_SECS = 5;
// upload a file and return the response as a string
public String post(File file) throws IOException, InterruptedException {
final Part[] multiPart = { new FilePart("file", file.getName(), file) };
final EntityEnclosingMethod post = new PostMethod(SITE);
post.setRequestEntity(new MultipartRequestEntity(multiPart, post.getParams()));
final ExecutorService executor = Executors.newSingleThreadExecutor();
final List<Future<Integer>> futures = executor.invokeAll(Arrays.asList(new KillableHttpClient(post)), TIME_OUT_SECS, TimeUnit.SECONDS);
executor.shutdown();
if(futures.get(0).isCancelled()) {
throw new IOException(SITE + " has timed out. It has taken more than " + TIME_OUT_SECS + " seconds to respond");
}
return post.getResponseBodyAsString();
}
private static class KillableHttpClient implements Callable<Integer> {
private final EntityEnclosingMethod post;
private KillableHttpClient(EntityEnclosingMethod post) {
this.post = post;
}
public Integer call() throws Exception {
return new HttpClient().executeMethod(post);
}
}
}
답변
Laz에 의해 가장 높은 상기 방법은 버전 4.3 이상에서 더 이상 사용되지 않습니다. 따라서 요청 구성 개체를 사용하고 HTTP 클라이언트를 빌드하는 것이 좋습니다.
private CloseableHttpClient createHttpClient()
{
CloseableHttpClient httpClient;
CommonHelperFunctions helperFunctions = new CommonHelperFunctions();
PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
cm.setMaxTotal(306);
cm.setDefaultMaxPerRoute(108);
RequestConfig requestConfig = RequestConfig.custom()
.setConnectTimeout(15000)
.setSocketTimeout(15000).build();
httpClient = HttpClients.custom()
.setConnectionManager(cm)
.setDefaultRequestConfig(requestConfig).build();
return httpClient;
}
PoolingHttpClientConnectionManager는 최대 기본 연결 수와 경로당 최대 연결 수를 설정하는 사용자입니다. 나는 그것을 각각 306과 108로 설정했습니다. 대부분의 경우 기본값으로는 충분하지 않습니다.
시간 제한 설정 :
RequestConfig 개체를 사용했습니다. 연결 관리자의 연결 대기 시간 제한을 설정하기 위해 연결 요청 시간 제한 속성을 설정할 수도 있습니다.
답변
이것은 benvoliot 의 의견에서 이미 언급되었습니다. 위의 . 그러나 나는 그것이 내 머리를 긁적이기 때문에 최상위 게시물의 가치가 있다고 생각합니다. 다른 사람에게 도움이 될 경우를 대비하여 게시하고 있습니다.
간단한 테스트 클라이언트를 작성했고이 경우 CoreConnectionPNames.CONNECTION_TIMEOUT
타임 아웃이 완벽하게 작동합니다. 서버가 응답하지 않으면 요청이 취소됩니다.
서버 코드 내부에서 실제로 테스트를 시도했지만 동일한 코드가 시간 초과되지 않습니다.
CoreConnectionPNames.SO_TIMEOUT
HTTP 연결 ( CoreConnectionPNames.CONNECTION_TIMEOUT
)이 아닌 소켓 연결 활동 ( ) 에서 시간 초과로 변경 하면 문제가 해결되었습니다.
또한 Apache 문서를주의 깊게 읽으십시오 : http://hc.apache.org/httpcomponents-core-ga/httpcore/apidocs/org/apache/http/params/CoreConnectionPNames.html#CONNECTION_TIMEOUT
말하는 비트에 유의하십시오.
이 매개 변수는 특정 로컬 주소에 바인딩 된 연결에만 적용 할 수 있습니다.
나는 그것이 내가 겪은 모든 머리를 긁는 다른 사람을 구하기를 바랍니다. 문서를 철저히 읽지 않도록 가르쳐 줄 것입니다!