在控制器外部渲染scala模板？（第二场）

Question

我正试图将发送通知电子邮件与导致它们的事件分离开来。到目前为止，我正在将一个邮件对象（DocumentIssuedMail）从控制器传递给Akka actor（EmailDispatcher），然后它通过play mailer插件的play easymail包装发送邮件。邮件正文由邮件对象在传递给参与者后生成，HTML由Scala模板生成。

此模板包含带有绝对URL的链接，通过调用

@routes.SomeController.someAction().absoluteURL()

但是，在尝试呈现模板时，我遇到了RuntimeException。

堆栈跟踪如下所示：

java.lang.RuntimeException: There is no HTTP Context available from here.
    at play.mvc.Http$Context.current(Http.java:30)
    at play.mvc.Http$Context$Implicit.ctx(Http.java:196)
    at play.core.j.PlayMagicForJava$.requestHeader(TemplateMagicForJava.scala:56)
    at views.html.email._learner_main$.apply(_learner_main.template.scala:41)
    at views.html.documents.email.new_doc_unregistered$.apply(new_doc_unregistered.template.scala:47)
    at views.html.documents.email.new_doc_unregistered$.render(new_doc_unregistered.template.scala:67)
    at views.html.documents.email.new_doc_unregistered.render(new_doc_unregistered.template.scala)
    at email.DocumentIssuedMail.getUnregisteredMail(DocumentIssuedMail.java:71)
    at email.DocumentIssuedMail.getMail(DocumentIssuedMail.java:67)
    at actors.email.EmailDispatcher.onReceive(EmailDispatcher.java:32)
    at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:167)
    at akka.actor.ActorCell.receiveMessage(ActorCell.scala:498)
    at akka.actor.ActorCell.invoke(ActorCell.scala:456)
    at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:237)
    at akka.dispatch.Mailbox.run(Mailbox.scala:219)
    at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:386)
    at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

是否可以在该位置渲染模板，或者我需要在原始线程上进行渲染？

Answer 1

这个问题的一个可能解决方案是将http请求显式地传递给参与者，然后再传递给邮件模板。

在模板中，将此请求传递给absoluteURL（）方法：

@(requestHeader: play.api.mvc.RequestHeader)

@main("") {
    @routes.Application.someAction().absoluteURL()(requestHeader)
}

除了DocumentIssuedMail，您还需要向演员传递请求。这里是一个简单的DTO。

import play.api.mvc.RequestHeader;

public class DocumentIssuedMailWrapper {
    private DocumentIssuedMail documentIssuedMail;
    private RequestHeader requestHeader;

    public DocumentIssuedMailWrapper(DocumentIssuedMail documentIssuedMail, RequestHeader requestHeader) {
        this.documentIssuedMail = documentIssuedMail;
        this.requestHeader = requestHeader;
    }

    public DocumentIssuedMail getDocumentIssuedMail() {
        return documentIssuedMail;
    }

    public RequestHeader getRequestHeader() {
        return requestHeader;
    }
}

参与者将请求作为普通参数从DTO传递到邮件模板。

import akka.actor.UntypedActor;
import play.api.templates.Html;
import views.html.mail;

public class EmailDispatcher extends UntypedActor {

    @Override
    public void onReceive(Object message) throws Exception {
        if (message instanceof DocumentIssuedMailWrapper) {
            DocumentIssuedMailWrapper wrapper = (DocumentIssuedMailWrapper) message;
            Html mailTemplate = mail.render(wrapper.getRequestHeader());
            //sending mail
        }
    }

}

在控制器中，您可以通过调用ctx（）来获取请求_requestHeader（）方法。现在，您只需要与演员安排一个工作，并通过DTO传递请求。

import akka.actor.ActorRef;
import akka.actor.Props;
import play.libs.Akka;
import play.mvc.*;

import scala.concurrent.duration.Duration;

import java.util.concurrent.TimeUnit;

public class Application extends Controller {

    public static Result sendMail() {
        DocumentIssuedMailWrapper wrapper = new DocumentIssuedMailWrapper(new DocumentIssuedMail(), ctx()._requestHeader());

        ActorRef emailDispatcher = Akka.system().actorOf(Props.create(EmailDispatcher.class));
        Akka.system().scheduler().scheduleOnce(Duration.create(0, TimeUnit.MILLISECONDS), emailDispatcher, wrapper, Akka.system().dispatcher(), null);
        return ok("Mail sent");
    }

    public static Result someAction() {
        return ok("Some other action");
    }

}