Java bayeux клиент отключается с TimeoutException при простое - PullRequest
Новая
       85

Java bayeux клиент отключается с TimeoutException при простое

0 голосов
/ 20 февраля 2019

Я инициализирую клиента Bayeux: 

SslContextFactory sslContextFactory = new SslContextFactory(true);
HttpClient httpClient = new HttpClient(sslContextFactory);
httpClient.start();

Map<String, Object> options = new HashMap<String, Object>();
ClientTransport transport = new LongPollingTransport(options, httpClient);
BayeuxClient client =  new BayeuxClient("https://localhost:8483/cometd/", transport);

client.handshake();

boolean handshaken = client.waitFor(20000, BayeuxClient.State.CONNECTED);
if (!handshaken) {
    LOGGER.info("Failed to handshake");
    throw new RuntimeException("Failed to handshake");
}

Я использую его для некоторой связи с сервером, он работает, он подписывается на каналы, отправляет, получает, затем я оставляю его на некоторое время без дела.Я получаю следующие исключения: 

java.util.concurrent.TimeoutException: Idle timeout 20000 ms
at org.eclipse.jetty.client.http.HttpConnectionOverHTTP.onIdleExpired(HttpConnectionOverHTTP.java:145)
at org.eclipse.jetty.io.ssl.SslConnection.onIdleExpired(SslConnection.java:286)
at org.eclipse.jetty.io.AbstractEndPoint.onIdleExpired(AbstractEndPoint.java:401)
at org.eclipse.jetty.io.IdleTimeout.checkIdleTimeout(IdleTimeout.java:166)
at org.eclipse.jetty.io.IdleTimeout$1.run(IdleTimeout.java:50)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)

и несколько раз следующее: 

java.nio.channels.ClosedChannelException: null
at org.eclipse.jetty.io.WriteFlusher.onClose(WriteFlusher.java:502)
at org.eclipse.jetty.io.AbstractEndPoint.onClose(AbstractEndPoint.java:353)
at org.eclipse.jetty.io.ChannelEndPoint.onClose(ChannelEndPoint.java:216)
at org.eclipse.jetty.io.AbstractEndPoint.doOnClose(AbstractEndPoint.java:225)
at org.eclipse.jetty.io.AbstractEndPoint.close(AbstractEndPoint.java:192)
at org.eclipse.jetty.io.AbstractEndPoint.close(AbstractEndPoint.java:175)
at org.eclipse.jetty.io.ssl.SslConnection$DecryptedEndPoint.doClose(SslConnection.java:1132)
at org.eclipse.jetty.io.AbstractEndPoint.doOnClose(AbstractEndPoint.java:220)
at org.eclipse.jetty.io.AbstractEndPoint.close(AbstractEndPoint.java:192)
at org.eclipse.jetty.io.AbstractEndPoint.close(AbstractEndPoint.java:175)
at org.eclipse.jetty.client.http.HttpConnectionOverHTTP.close(HttpConnectionOverHTTP.java:195)
at org.eclipse.jetty.client.http.HttpConnectionOverHTTP.onIdleExpired(HttpConnectionOverHTTP.java:145)
at org.eclipse.jetty.io.ssl.SslConnection.onIdleExpired(SslConnection.java:286)
at org.eclipse.jetty.io.AbstractEndPoint.onIdleExpired(AbstractEndPoint.java:401)
at org.eclipse.jetty.io.IdleTimeout.checkIdleTimeout(IdleTimeout.java:166)
at org.eclipse.jetty.io.IdleTimeout$1.run(IdleTimeout.java:50)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)

Если я буду занят, это не даст сбоя.Я попытался изменить время ожидания httpclient, но это только задерживает проблему.Почему Байе закрывает канал, а не проводит опрос?Я использую последнюю версию, org.cometd.java 4.0.2.

Также следует отметить тот факт, что у меня есть клиент javascript, который работает без проблем.

Может кто-нибудь помочь?

Ответы [ 2 ]

0 голосов
/ 19 марта 2019

Оказывается, я блокировал потоки cometD:

Я создал инструмент командной строки для проверки сервера, и когда я получил сообщение (с потоком из cometD), я держал этот поток дляПользовательский ввод.Если я удерживаю этот поток достаточно долго, cometD отключается с вышеупомянутыми исключениями.

Решение: Когда вы получаете сообщение от CometD, не удерживайте его, используйте новый поток.

0 голосов
/ 20 февраля 2019

Пульс по умолчанию контролируется на стороне сервера параметром timeout и по умолчанию составляет 30 секунд.Это означает, что длительный опрос, когда система находится в режиме ожидания, происходит каждые 30 секунд.

Вы настроили клиент idleTimeout на 20 секунд, как это видно из трассировки стека исключений.

Когда система находится в режиме ожидания, клиент тайм-аут соединения , прежде чем ответ сердцебиение (длинный опрос), вызывая ошибки, которые вы видите.

Это должно быть достаточно для васнастройте для клиента idleTimeout значение, превышающее пульс timeout, или, что эквивалентно, установите для пульса timeout значение, меньшее, чем у клиента idleTimeout.

...