Сервер сервлетов Java-сервера Atmosphere отправил события

Question

Это мой первый раз, когда я работаю с атмосферой, и для меня это довольно сложно. Я хочу, чтобы пользователь получал push-сообщение от моего API (Java Servlet / Tomcat).

Я использую jquery.atmosphere.js и следующий код приложения:

checkForMenuUpdates: function () {
        var self = this;
        checkUpdates();
        function checkUpdates() {
            var request = {url: path.apiPath + 'user.checkUpdates?token=' + token,                    
                logLevel: 'debug',
                'enableXDR': true,
                transport: 'sse',
                trackMessageLength: "false",
                fallbackTransport: 'long-polling'};

            request.onOpen = function (response) {

            };
            request.onMessage = function (response) {

            }
            var socket = jqueryAtmosphere;
            var subSocket = socket.subscribe(request);
        }

    },

На стороне сервера: Контроллер:

  else if ("user.checkUpdates".equals(pathInfo)) {
            try {
              AtmosphereBroadcaster atmo=new AtmosphereBroadcaster();
              atmo.subscribe(response);
                //ServerSentEvents updates = new ServerSentEvents();
                //updates.establishConnection(token.getUserId(), response, callback);
            } catch (Exception ex) {
                ErrorHandler error = new ErrorHandler();
                error.Error400(response, callback);
            }
        }

"Вещатель":

private @PathParam("token")
Broadcaster topic;

public SuspendResponse<String> subscribe(HttpServletResponse httpResponse) {
    StandardResponse res = new StandardResponse();
    httpResponse = res.standardResponseSSE(httpResponse);
    return new SuspendResponse.SuspendResponseBuilder<String>()
            .broadcaster(topic)
            .outputComments(true)
            .addListener(new EventsLogger())
            .build();

}

public static void push(String message, String topic) {

    Collection<Broadcaster> broadcasters = BroadcasterFactory.getDefault().lookupAll();

    for (Broadcaster b : broadcasters) {
        System.out.println(b.toString());
    }

    System.out.println("Request to push- Message: " + message + ", Topic: " + topic);
    Broadcaster b = null;
    if (null != (b = BroadcasterFactory.getDefault().lookup(JerseyBroadcaster.class, topic))) {
        System.out.println("Request to push- Message: " + message + ", Topic: " + topic);
        b.broadcast(message + "\n");
    }
}

private class EventsLogger implements AtmosphereResourceEventListener {

    @Override
    public void onPreSuspend(AtmosphereResourceEvent are) {
        throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
    }

    @Override
    public void onSuspend(AtmosphereResourceEvent are) {
        throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
    }

    @Override
    public void onResume(AtmosphereResourceEvent are) {
        throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
    }

    @Override
    public void onDisconnect(AtmosphereResourceEvent are) {
        throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
    }

    @Override
    public void onBroadcast(AtmosphereResourceEvent are) {
        throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
    }

    @Override
    public void onThrowable(AtmosphereResourceEvent are) {
        throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
    }

    @Override
    public void onClose(AtmosphereResourceEvent are) {
        throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
    }

    @Override
    public void onHeartbeat(AtmosphereResourceEvent are) {
        throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
    }
}

И стандартный ответ:

  public HttpServletResponse standardResponseSSE(HttpServletResponse response) {        
    response.setContentType("text/event-stream");
    response.setCharacterEncoding("UTF-8");
    response.setHeader("Pragma", "no-cache");
    response.setHeader("Access-Control-Allow-Origin", "*");
    response.setDateHeader("Expires", -1);
    return response;
}

И я получаю следующий вывод из консоли Chrome:

SSE успешно открыл jquery.atmosphere.js? Bust=6539327597711.235:3171 Максимальное количество попыток повторного подключения SSE достигло 6

Для меня это звучит так, как будто нет обратного сообщения. У меня был очень простой пример ( https://weblogs.java.net/blog/swchan2/archive/2014/05/21/server-sent-events-async-servlet-example), который работал нормально. Но для меня SSE не работает с атмосферой.

Так какой смысл здесь? Что я делаю неправильно?

РЕДАКТИРОВАТЬ:

Я знаю, что код javascript странный - он "в разработке":)

Конечно - когда я добавляю этот код в EventsLogger, он работает:

public EventsLogger(HttpServletResponse response) {
        PrintWriter write = null;

        try {
            write = response.getWriter();
            while (true) {
                write.write("data:Test \n\n");
                write.flush();
                Thread.sleep(1000);
            }

        } catch (IOException ex) {
            Logger.getLogger(AtmosphereBroadcaster.class.getName()).log(Level.SEVERE, null, ex);
        } catch (InterruptedException ex) {
            Logger.getLogger(AtmosphereBroadcaster.class.getName()).log(Level.SEVERE, null, ex);
        } finally {
            write.close();
        }
    }

Это проблема с сердцебиением, которое посылает неправильно - как это решить?

Answer 1

Перестань:

    throw new UnsupportedOperationException("Not supported yet.");

в слушателе, и это будет работать:-)

- Жанфрансуа