Отключение Атмосферных розеток в Граалях - PullRequest
Новая
       62

Отключение Атмосферных розеток в Граалях

1 голос
/ 12 марта 2012

Я пишу приложение Grails, которое использует плагин Atmosphere.Соединение работает, но каждый раз, когда я обновляю страницу в браузере, я вижу, что мой веб-сервер добавляет новую ветку Daemon, которая впоследствии никогда не выпускается.

После того, как число потоков достигнет 200, веб-сервер зависнет.

Кажется, что нет документации, объясняющей, как правильно обращаться с ресурсами (отключаться) с помощью плагина Atmosphere?

Мой код клиента делает это: 

var connectedEndpoint = null;

$(function() 
{
function callback(response)
{
    if (response.transport != 'polling' && response.state != 'connected' && response.state != 'closed') {
        if (response.status == 200) {
            eval(response.responseBody);
        }
    }
}

$.atmosphere.subscribe('${resource(dir: '/atmosphere/channel')}', callback, $.atmosphere.request = {transport: 'streaming'});
connectedEndpoint = $.atmosphere.response;

});

$(window).unload( function () 
{ 
    $.atmosphere.unsubscribe();
    connectedEndpoint = null;
});

Я использую обработчик атмосферы на стороне сервера; 

package demo

import javax.servlet.http.HttpServletRequest
import javax.servlet.http.HttpServletResponse
import org.atmosphere.cpr.AtmosphereHandler
import org.atmosphere.cpr.AtmosphereResource;
import org.atmosphere.cpr.AtmosphereResourceEvent;

class DemoController implements AtmosphereHandler<HttpServletRequest, HttpServletResponse> {

@Override
public void destroy() {
    println "destroy"
}

@Override
public void onRequest( AtmosphereResource<HttpServletRequest, HttpServletResponse> event) throws IOException 
{
    event.suspend()
}

@Override
public void onStateChange( AtmosphereResourceEvent<HttpServletRequest, HttpServletResponse> event) throws IOException 
{
    if (event.isSuspended()) 
    {
        event.resource.response.writer.with {
            def message = event.message
            write "set${message.paramName}(\"${message.id}\",\"${message.value}\");"
            flush()
        }
    }
}
}

Функция обработчика destroy никогда не вызывается!

На следующем рисунке показано, что у меня запущено 23 потока.Когда я запускаю свое приложение, их около 6, и они добавляются каждый раз, когда я нажимаю клавишу F5!Если я отключаю атмосферу, новые темы не добавляются, так что эта проблема связана с атмосферой.(Я использую SpringSource Tools Suite в Windows7).

Daemon threads

Если решение не тривиально, я был бы признателен за подробные пошаговые инструкции или пример.

ОБНОВЛЕНИЕ: После развертывания в Tomcat каждые 20 секунд появляются следующие ошибки: 

Apr 02, 2012 2:35:15 PM org.apache.catalina.startup.HostConfig deployDescriptor
INFO: Deploying configuration descriptor host-manager.xml
Apr 02, 2012 2:35:16 PM org.apache.catalina.startup.HostConfig deployDescriptor
INFO: Deploying configuration descriptor manager.xml
Apr 02, 2012 2:35:16 PM org.apache.catalina.startup.HostConfig deployDirectory
INFO: Deploying web application directory docs
Apr 02, 2012 2:35:16 PM org.apache.catalina.startup.HostConfig deployDirectory
INFO: Deploying web application directory examples
Apr 02, 2012 2:35:17 PM org.apache.catalina.startup.HostConfig deployDirectory
INFO: Deploying web application directory ROOT
Apr 02, 2012 2:35:17 PM org.apache.coyote.http11.Http11AprProtocol start
INFO: Starting Coyote HTTP/1.1 on http-8080
Apr 02, 2012 2:35:17 PM org.apache.coyote.ajp.AjpAprProtocol start
INFO: Starting Coyote AJP/1.3 on ajp-8009
Apr 02, 2012 2:35:17 PM org.apache.catalina.startup.Catalina start
INFO: Server startup in 11401 ms
2012-04-02 14:41:17,122 [http-8080-39] ERROR cpr.AsynchronousProcessor  - failed
 to timeout resource AtmosphereResourceImpl{, hasCode-1035775543,
 action=org.atmosphere.cpr.AtmosphereServlet$Action@f2718e,
 broadcaster=org.atmosphere.cpr.DefaultBroadcaster,
 cometSupport=org.atmosphere.container.TomcatCometSupport@107fff7,
 serializer=null,
 isInScope=true,
 useWriter=true,
 listeners=[]}
2012-04-02 14:42:15,034 [http-8080-69] ERROR cpr.AsynchronousProcessor  - failed
 to timeout resource AtmosphereResourceImpl{, hasCode-58082012,
 action=org.atmosphere.cpr.AtmosphereServlet$Action@ae4dd4,
 broadcaster=org.atmosphere.cpr.DefaultBroadcaster,
 cometSupport=org.atmosphere.container.TomcatCometSupport@107fff7,
 serializer=null,
 isInScope=true,
 useWriter=true,
 listeners=[]}
2012-04-02 14:44:41,159 [http-8080-13] ERROR cpr.AsynchronousProcessor  - failed
 to timeout resource AtmosphereResourceImpl{, hasCode648226529,
 action=org.atmosphere.cpr.AtmosphereServlet$Action@507e61,
 broadcaster=org.atmosphere.cpr.DefaultBroadcaster,
 cometSupport=org.atmosphere.container.TomcatCometSupport@107fff7,
 serializer=null,
 isInScope=true,
 useWriter=true,
 listeners=[]}

 ....

Ответы [ 2 ]

1 голос
/ 12 марта 2012

Salut,

, какой WebServer вы используете?Похоже, что WebServer не обнаруживает, когда браузер закрывает соединение.Вы можете добавить в web.xml следующий детектор времени ожидания

org.atmosphere.cpr.CometSupport.maxInactiveActivity = 30000 // 30 секунд

Дайте мне знать, как он работает.

A +

- Жанфрансуа

0 голосов
/ 23 апреля 2012

Я считаю, что ваша проблема в событии выгрузки."$ (Окно) .unload".Я знаю, по крайней мере, в Chrome, вы не можете сделать многое в событиях unload или beforeunload.следовательно, ваш браузер, вероятно, никогда не запускает функцию unsubscribe ().

если вы посмотрите пример jquery pubsub Atmospheres, то можете увидеть отписку перед подключением, function connect () {unsubscribe ();...

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

...