Обработчик запросов Vert.x и блокировка запросов к БД - PullRequest
Новая
       32

Обработчик запросов Vert.x и блокировка запросов к БД

0 голосов
/ 05 июля 2019

Как я могу правильно перевести этот фрагмент кода в vert.x?

обычно, весной или в простом сервлете с механизмом шаблонов для вывода html-ответа, я сделаю вот так 

function test(request, response) {
  templatecontext tc = getContext();

  init conditions

  if (condition1) {
    retrieve data from db ({
      asyncresult -> {
        tc.put("data1", data1)
      })
  } else if (condition2) {
    other code

    if (condition 2.1) {        
      retrieve data from db ({
        asyncresult -> {
          tc.put("data2", data2)
        })
    }
  }

  get other data from db and put in context
  template.eval("templatefile", tc)
  write to response
}

проблема в том, что получение данных из базы данных является обработчиком asyncresult, поэтому я не могу допустить, чтобы оценка шаблона выполнялась с data1 или data2, потому что извлечение асинхронности без попадания в ад обратного вызова.

Я не совсем понял rxjava2, но чувствую, что пытаюсь убить боб ложкой.

1 Ответ

1 голос
/ 05 июля 2019

Вы можете использовать фьючерсы и композиции . См. ComposeExample в vertx-examples репо: 

public class ComposeExample extends AbstractVerticle {    

  @Override
  public void start() throws Exception {
    Future<String> future = anAsyncAction();
    future.compose(this::anotherAsyncAction)
      .setHandler(ar -> {
        if (ar.failed()) {
          System.out.println("Something bad happened");
          ar.cause().printStackTrace();
        } else {
          System.out.println("Result: " + ar.result());
        }
      });
  }

  private Future<String> anAsyncAction() {
    Future<String> future = Future.future();
    // mimic something that take times
    vertx.setTimer(100, l -> future.complete("world"));
    return future;
  }

  private Future<String> anotherAsyncAction(String name) {
    Future<String> future = Future.future();
    // mimic something that take times
    vertx.setTimer(100, l -> future.complete("hello " + name));
    return future;
  }
}
...