micolossДоброго времени суток!
Задача следующая. Есть JAX WS сервис, который через пул соединений делает запрос на сторонний TCP сервер. Каждое соединение в пуле работает в отдельном потоке, соответственно ответ от TCP сервера обрабатывается в run(). Логика следующая, при обращению в сервис создается пакет, который отправляется в свободное на данный момент соединение в пуле, затем получает ответ от TCP сервера, возвращает соединение в пул и отдает ответ в сервис. Вопрос в следующим, каким образом правильнее всего дождаться ответ TCP сервера и передать этот ответ в метод сервиса, откуда запрос был инициирован, поскольку ответ от TCP сервера может придти с задержкой. Спасибо!Клиент JAX-WS поддерживает пулирование исполнения. Возможно хватит.
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
import com.cdyne.ws.weatherws.ArrayOfWeatherDescription;
import com.cdyne.ws.weatherws.Weather;
import com.cdyne.ws.weatherws.WeatherSoap;
import java.util.concurrent.Executors;
/**
* Date: 26.02.2015.
* Time: 20:35
*/
public class Main {
public static void main(String[] args) {
Weather service = new Weather();
service.setExecutor(Executors.newFixedThreadPool(10));
WeatherSoap port = service.getWeatherSoap();
ArrayOfWeatherDescription weatherInformation = port.getWeatherInformation();
System.out.println(weatherInformation);
}
}
