Удаленные службы OSGi и ECF — асинхронные службы

В
блоге, опубликованном ранее на этой неделе ,
Питер Криенс рассказал о некоторых усилиях, предпринимаемых в EEG по добавлению асинхронной поддержки для удаленных (и даже локальных) сервисов. Один из его комментариев в этой публикации в блоге заключался в том, что асинхронную поддержку ECF можно считать неловкой из-за сложности / незнакомого использования API.

Я намеревался добавить более простые / более естественные механизмы для асинхронного удаленного доступа, чем то, что у нас уже есть, и то, что происходит в EEG и блоге Питера, было отличным стимулом для завершения еще некоторой этой работы. Существующие механизмы
имеют несколько неуклюжих, но они также делают очень сильный / гибкий фундамент … и поэтому можно строить новые механизмы на основе существующих механизмов.

Нормальные / синхронные прокси

В нашем
примере удаленных сервисов ‘hello’ у нас есть сервисный интерфейс:

public interface IHello {
    public void hello(String from); 
}

Потребители этой удаленной службы получают прокси-сервер, который реализует интерфейс IHello, а затем клиенты могут синхронно вызывать метод hello для выполнения удаленного вызова:

proxy.hello{"slewis");

Так как в вызовах метода java блокируются, поток, который вызывает метод hello, будет блокироваться, если (например) сеть медленная, хост службы медленный (или блокирует). Было бы хорошо, если бы у нас был способ (на потребителе / ​​клиенте) вызвать метод hello и гарантировать, что он не будет блокироваться … при этом все равно каким-то образом получаться результат (если есть) … когда удаленный вызов успешен … или получение информации о сбое, если что-то не работает / идет не так (например, из-за сбоя сети)

Асинхронные прокси

Мы только что добавили поддержку асинхронных прокси в реализации удаленных сервисов ECF. Это означает, что если интерфейс объявлен так (и в том же пакете, что и интерфейс IHello):

public interface IHelloAsync extends IAsyncRemoteServiceProxy {

    public void helloAsync(String from, IAsyncCallback callback);

    public IFuture helloAsync(String from);

}

распределение удаленной службы ECF система будет автоматически создавать прокси — сервер , который
реализует интерфейс IHelloAsync на потребителя / клиента.

proxy.helloAsync("slewis",new IAsyncCallback() {
    void onSuccess(Object result) {
        System.out.println("we got result="+result);
    }
    void onFailure(Throwable exception) {
        System.out.println("oh no!");
        exception.printStackTrace();
    }
});

    public IFuture helloAsync(String from);