playframework java异步方法调用

Question

playframework 2.2（java 7）

我有REST api，在那里接收一些json，用json数据我正在做一些事情，最后我发送电子邮件并返回结果。发送电子邮件有点慢，所以我希望在处理json后在其他线程中调用此电子邮件方法，或者我希望执行异步并返回结果，而不必等待电子邮件方法的执行。

如何在控制器中实现和调用异步方法？

下面是代码示例

 public static Result register() {
    JsonNode json = request().body().asJson();
    if (json == null)
        Logger.info("bad json request");
    try {
        RegistrationHandler registrationHandler = new RegistrationHandler();
        if(!registrationHandler.isEmailUnique(json)){
            return ok("false");
        }else{
            registrationHandler.saveUser(json);
            String email = json.findValue("email").asText();
            sendRegistrationEmail(email); // I don't want wait this for execution
            return ok("success");
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
    return ok("error");
}

编辑：

不确定它是否好，但有效。

 JsonNode json = request().body().asJson();
    if (json == null)
        Logger.info("bad json request");
    try {
        RegistrationHandler registrationHandler = new RegistrationHandler();
        if(!registrationHandler.isEmailUnique(json)){
            return ok("false");
        }else{
            registrationHandler.saveUser(json);
            String email = json.findValue("email").asText();
            F.Promise<java.lang.Boolean> emailPromise = F.Promise.promise(
              new F.Function0<java.lang.Boolean>() {
                public java.lang.Boolean apply() {
                    return sendRegistrationEmail(email);
                }
              }
            );

            return ok("success");
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
    return ok("error");     

Answer 1

如果您创建一个promise来处理JSON检索和处理，那么可以在兑现promise时附加一个回调。

此代码基于此处的示例。

public static Promise<Result> index() {
    final Promise<SomethingFromJson> eventualObject = WS.url("http://example.com/json")
                                                        .get()
                                                        .map(response -> // do something with the json);

    // add a callback to send mail when the json has been processed
    // this will happen in another thread
    eventualObject.onRedeem(new F.Callback<SomethingFromJson>() {
        // send email
    }, executionContext);

    return eventualObject.map(
        new Function<SomethingFromJson, Result>() {
            public Result apply(SomethingFromJson obj) {
                return ok(// whatever you do with obj);
        } 
      }
    );
}

Answer 2

我在中使用了您的代码和示例https://www.playframework.com/documentation/2.2.x/JavaAsync#Async-结果，但我从未实际运行过此代码（也没有编译）。

关键是你必须回报一个promise。游戏处理其余部分。您可以在第一次promise调用sendRegistrationEmail（email）后返回ok（），但如果发送过程中出现问题，您将失去发送“错误”的能力。

public static Promise<Result> myMethod() {
    JsonNode json = request().body().asJson();
    if (json == null) {
        Logger.info("bad json request");
        return badRequest();
    }

    RegistrationHandler registrationHandler = new RegistrationHandler();
    if(!registrationHandler.isEmailUnique(json)) {
        return ok("false");
    }

    registrationHandler.saveUser(json);
    String email = json.findValue("email").asText();
    F.Promise<Boolean> emailPromise = F.Promise.promise(
        new F.Function0<Boolean>() {
        public Boolean apply() {
            // This method takes a while
            return sendRegistrationEmail(email);
        }
    });

    return emailPromise.map(new Function<Boolean, Result>() {
        public Result apply(Boolean successful) {
            if (successful) {
                return ok("success");
            } else {
                return ok("error");
            }
        } 
    });
}