Использование механизма принудительной сессии Eclipse RAP

Фрагмент 1: Index.html

Все события, порожденные из пользовательского интерфейса, передаются OpenLayer 3через

BrowserUtil.evaluate(browser, <my_js_string> <my_callback_function> );

Таким образом, функциональность, предоставляемая OpenLayer 3  RAP, может быть вызвана. Все идет нормально!

Однако это не дает нам возможности реагировать на результаты, которые возвращаются OpenLayer 3, и на сосуды, которые покачиваются на воде! Эти данные предлагаются нескольким сервлетам, которые также зарегистрированы в реестре расширений, но теперь нам нужно отобразить эти данные в виджетах, и именно здесь вступает в действие механизм PushSession .

Push-сессия

Напомним, что теперь мы имеем дело с событиями, порожденными javascript и сервлетами, с которыми пользовательский интерфейс не знает, как и когда они происходят. Несомненно, есть кнопка, которая была нажата в какой-то момент, ссылка, по которой щелкали, но нет никакого способа сообщить, когда базовая модель и виджеты обновлены, и пользовательский интерфейс может быть обновлен. О да, и есть вероятность, что может быть возвращено больше событий, которые могут быть запущены из пользовательского интерфейса, но продолжают поступать впоследствии, например, когда собираются данные мониторинга.

Ребята из RAP придумали довольно изящное решение этой проблемы, а именно push-сессию . Хитрость заключается в том, чтобы эмулировать стандартный подход на основе браузера, запуская push-сессиюиз пользовательского интерфейса, который обрабатывается после обновления модели представления. Сразу после этого активируется следующий push-сеанс в ожидании другого возможного события. Поэтому push-сеанс не отвечает на события, которые должны произойти, как обычное событие пользовательского интерфейса, вместо этого он ожидает возможное событие и обрабатывает его, если оно происходит.

Рисунок 2: Диаграмма связи

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

Другая дополнительная проблема заключается в том, что обновление пользовательского интерфейса все еще должно выполняться в основном потоке пользовательского интерфейса, поэтому в какой-то момент мы должны включить хорошо известный Display.asyncexec()механизм. Для этого я создал абстрактный класс, который обрабатывает большинство проблем с потоками, которые вы можете увидеть во фрагменте 2:

import java.util.ArrayList;
import java.util.Collection;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.eclipse.rap.rwt.service.ServerPushSession;
import org.eclipse.swt.widgets.Display;

public abstract class AbstractPushSession {

    public static final int DEFAULT_TIMEOUT = 5000;

    private Display display;

    private ServerPushSession session;
    private ExecutorService es;
    private boolean refresh = false;
    private int timeout;

    private Collection<ISessionListener> listeners;

    protected AbstractPushSession() {
        this( DEFAULT_TIMEOUT );
    }

    protected AbstractPushSession( int timeout ) {
        this.timeout = timeout;
        listeners = new ArrayList<ISessionListener>();
        es = Executors.newCachedThreadPool();
    }

    private Runnable runnable = new Runnable() {
        public void run() {
            while(!refresh && !runSession()){
                try{
                    Thread.sleep( timeout );
                }
                catch( InterruptedException ex ){
                    ex.printStackTrace();
                }
            }
            if( display.isDisposed())
                return;
            display.asyncExec( new Runnable() {
                public void run() {
                    for(ISessionListener listener: listeners)
                        listener.notifySessionChanged( new SessionEvent( this ));
                    session.stop();
                    start();
                }
            });
        };
    };

    public void addSessionListener( ISessionListener listener ){
        this.listeners.add( listener );
    }

    public void removeSessionListener( ISessionListener listener ){
        this.listeners.remove( listener );
    }

    public void init( Display display ){
            this.display = display;
    }

    protected boolean hasRefreshed() {
        return refresh;
    }

    protected void setRefresh(boolean refresh) {
        this.refresh = refresh;
    }

    public synchronized void start(){
        session = new ServerPushSession();
        session.start();
        this.refresh = false;
        es.execute(runnable);
    }

    /**
     * Run the session. returns true if the session completed succesfully.
     * @return
     */
    protected abstract boolean runSession();

    public synchronized void stop(){
        this.listeners.clear();
        this.refresh = false;
        es.shutdown();
    }
}

public class MapSession extends AbstractPushSession {

    private Model model;
    private IModelListener listener =
      new IModelListener() {

      @Override
      public void notifyStatusChanged( ModelEvent event) {
           setRefresh( true );
           Thread.interrupted();
    }
  };

  private static MapSession session =
    new MapSession();

    public static MapSession getInstance(){
        return session;
    }   

    public void setModel( Model model) {
        this.model = model;
        this.model.addListener(listener);
    }

    @Override
    protected boolean runSession() {
        return ( this.model != null );
    }

    @Override
    public void stop() {
        if( this.model != null )
            this.model.removeListener(listener);
        super.stop();
    }
}

public class MyComposite extends Composite {

      private MapSession session =
              MapSession.getInstance();
      private ISessionListener sl =
        new ISessionListener(){

        @Override
        public void notifySessionChanged(SessionEvent
            event){
          refresh();       
        }   
    };

    public MyComposite(Composite parent, int style) {
        super(parent, style);
        ...
        this.session.addSessionListener(sl);
        this.session.init( Display.getDefault());
        this.session.start();
   }

    /**
     * Refresh the UI
     */
    public void refresh(){
       ...
    }

   @Override
   public void dispose() {
       session.stop();
       super.dispose();
   }
}

public class ModelServlet extends HttpServlet {
    private static final long serialVersionUID = 1L;

    private Model model;
    private MapSession session = MapSession.getInstance();

    @Override
    public void init() throws ServletException {
        session.setModel(model);
        super.init();
    }

    @Override
    public void doGet(HttpServletRequest req, HttpServletResponse resp)
            throws ServletException, IOException {
        ...
        updateModel();
        ...
    }
}