Как завершить вызов веб-сервиса CXF в Callable при отмене в будущем

Question

Редактировать

К настоящему времени этот вопрос прошел несколько итераций, поэтому не стесняйтесь просматривать изменения, чтобы увидеть некоторую справочную информацию об истории и опробованных вещах.

---

Я использую CompletionService вместе с ExecutorService и Callable, чтобы одновременно вызывать ряд функций в нескольких разных веб-сервисах с помощью кода, сгенерированного CXF.Все эти сервисы предоставляют разную информацию в единый набор данных, который я использую для своего проекта.Однако службы могут не отвечать в течение длительного периода времени, не создавая исключения, что продлевает ожидание объединенного набора информации.

Чтобы противостоять этому, я выполняю все вызовы служб одновременно, и через несколько минут хотел бы завершить все вызовы, которые еще не завершены, и желательно записать, какие из них еще не были выполнены, либо из вызываемого объекта, либо путем бросания подробное Исключение.

Вот очень упрощенный код, иллюстрирующий то, что я уже делаю:

private Callable<List<Feature>> getXXXFeatures(final WiwsPortType port, 
final String accessionCode) {
    return new Callable<List<Feature>>() {
        @Override
        public List<Feature> call() throws Exception {
            List<Feature> features = new ArrayList<Feature>();
            //getXXXFeatures are methods of the WS Proxy
            //that can take anywhere from second to never to return
            for (RawFeature raw : port.getXXXFeatures(accessionCode)) {
                Feature ft = convertFeature(raw);
                features.add(ft);
            }
            if (Thread.currentThread().isInterrupted())
                log.error("XXX was interrupted");
            return features;
        }
    };
}

И код, который одновременно запускает вызовы WS:

WiwsPortType port = new Wiws().getWiws();
List<Future<List<Feature>>> ftList = new ArrayList<Future<List<Feature>>>();
//Counting wrapper around CompletionService, 
    //so I could implement ccs.hasRemaining()
CountingCompletionService<List<Feature>> ccs = 
        new CountingCompletionService<List<Feature>>(threadpool);
ftList.add(ccs.submit(getXXXFeatures(port, accessionCode)));
ftList.add(ccs.submit(getYYYFeatures(port accessionCode)));
ftList.add(ccs.submit(getZZZFeatures(port, accessionCode)));

List<Feature> allFeatures = new ArrayList<Feature>();
while (ccs.hasRemaining()) {
            //Low for testing, eventually a little more lenient
    Future<List<Feature>> polled = ccs.poll(5, TimeUnit.SECONDS);
    if (polled != null)
        allFeatures.addAll(polled.get());
    else {
        //Still jobs remaining, but unresponsive: Cancel them all
        int jobsCanceled = 0;
        for (Future<List<Feature>> job : ftList)
            if (job.cancel(true))
                jobsCanceled++;
        log.error("Canceled {} feature jobs because they took too long",
                        jobsCanceled);
        break;
    }
}

Проблема, с которой я столкнулся с этим кодом, заключается в том, что Callables на самом деле не отменяются при ожидании возврата port.getXXXFeatures(...), но каким-то образом продолжают работать.Как вы можете видеть из if (Thread.currentThread().isInterrupted()) log.error("XXX was interrupted"); заявляет прерванный флаг является установленный после возврата port.getFeatures, он доступен только после нормального завершения вызова веб-сервиса, а не после его прерывания при вызове Cancel.

Может ли кто-нибудь сказать мне, что я делаю неправильно и как я могу остановить работающий вызов веб-службы CXF через определенный период времени и зарегистрировать эту информацию в своем приложении?

С уважением, Тим

Answer 1

Редактировать 3 Новый ответ.

Я вижу такие варианты:

• Опубликуйте свою проблему в Apache CXF как запрос на добавление функции.
• Исправьте ACXF самостоятельно и раскройте некоторые возможности.
• Найдите варианты поддержки асинхронных вызовов WS в Apache CXF.
• Рассмотрите возможность перехода на другого провайдера WS (JAX-WS?)
• Вызовите ли вы свой WS самостоятельно, используя RESTful API, если сервис его поддерживает (например,простой HTTP-запрос с параметрами)
• Только для экспертов über:используйте настоящие потоки/группу потоков и уничтожайте потоки неортодоксальными методами.

Answer 2

В документации CXF есть несколько инструкций по установке тайм-аута чтения для HTTPURLConnection:http://cwiki.apache.org/CXF20DOC/client-http-transport-включая-ssl-support.html

Вероятно, это удовлетворит ваши потребности.Если сервер не отвечает вовремя, возникает исключение, и вызываемый объект получит это исключение.(за исключением ошибки, из-за которой МОЖЕТ зависнуть.Я не могу вспомнить, было ли это исправлено в версии 2.2.2 или это сейчас только в СНИМКАХ.)