Я создал http-прокси-мост верблюжьей пристани для моих сервисов отдыха для загрузки/выгрузки документов. Эти сервисы вызываются для получения/загрузки документов разных типов, в большинстве случаев размер файла превышает 100 МБ.
Когда я вызываю службу загрузки остальных (HTTP POST) напрямую (не маршрутизируя ее через HTTP-прокси верблюжьей пристани), чтобы загрузить документ размером 100 МБ, для завершения загрузки и получения ответа требуется всего около 2-3 минут, однако, когда я маршрутизирую запрос через верблюжий маршрут занимает более 15 минут, что довольно странно, поскольку верблюжий маршрут в игре - это не что иное, как HTTP-прокси.
Ниже приведены некоторые сведения:
Версия Camel: 2.15.1
Определение верблюжьего маршрута:
<route>
<from uri="jetty:http://0.0.0.0:8383/sqidds/document?disableStreamCache=true&matchOnUriPrefix=true&enableMultipartFilter=false&continuationTimeout=-1" />
<log id="incomingMessage" message="incomingMessage - \n[id = ${id}]\n [headers = ${headers}]" />
<to uri="jetty:http://somehost:8080/sqidds/document?bridgeEndpoint=true&throwExceptionOnFailure=false&httpClient.timeout=3200000" />
<log id="outgoingMessage" message="outgoingMessage - \n[id = ${id}]\n [headers = ${headers}]" />
</route>
Выдержка POM проекта Camel:
.
.
.
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
<version>2.15.1.redhat-621084</version>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-spring</artifactId>
<version>2.15.1.redhat-621084</version>
</dependency>
.
.
.
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-jetty</artifactId>
<version>2.15.1.redhat-621084</version>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-http</artifactId>
<version>2.15.1.redhat-621084</version>
<!-- use the same version as your Camel core version -->
</dependency>
.
.
.
Код службы отдыха (Spring MVC):
@RequestMapping(method = RequestMethod.POST, consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
public @ResponseBody String saveFile(@RequestPart("file") MultipartFile file) throws IOException, DocumentNotSavedException {
String targetPath = null;
if (file != null) {
String repoDirectoryPath = "SOME_REPO_PATH";
String uniqueFileName = FileUtil.getUniqueFileName(repoDirectoryPath, file.getOriginalFilename());
File targetFile = new File(repoDirectoryPath, uniqueFileName);
targetPath = targetFile.getCanonicalPath();
FileUtils.copyInputStreamToFile(file.getInputStream(), targetFile);
} else {
log.error("File is null");
throw new DocumentNotSavedException("File data could not be saved");
}
return targetPath;
}
Код RestClient:
public String putDocument(File file,String fileName) throws RestClientException{
ResponseEntity<String> response = null;
try {
File file = new File("SOME_100MB_FILE.pdf");
byte[] fileBytes = new byte[(int)file.length()];
LinkedMultiValueMap<String, Object> map = new LinkedMultiValueMap();
ByteArrayResource contentsAsResource = new ByteArrayResource(fileBytes, fileName) {
@Override
public String getFilename() {
return this.getDescription();
}
};
map.add("file", contentsAsResource);
httpHeaders.setContentType(MediaType.MULTIPART_FORM_DATA);
HttpEntity<LinkedMultiValueMap<String, Object>> requestEntity = new HttpEntity<LinkedMultiValueMap<String, Object>>(map, httpHeaders);
response = restTemplate.exchange(serverUri, HttpMethod.POST, requestEntity, String.class);
} catch (Exception e) {
logger.error("Exception in put document service", e);
throw new RestClientException("Exception in put document service :",e);
}
return response.getBody();
}
ПРИМЕЧАНИЕ. Для файла размером 100 МБ журнал маршрута верблюда для входящего сообщения регистрируется в течение секунды после вызова службы, однако я вижу исходящий журнал примерно через 15 минут. Я думаю, что может быть что-то не так с верблюжьим маршрутом производителя.