2

ここの例に従いました。うまくいきます。しかし今、私はいくつかのビジネスロジックを実行する必要がありますcase get:Get =>

必要なビジネスロジックには、ディスパッチライブラリの使用が含まれます。一言で言えば、私はあるページにリクエストを行い、データを取得し、それをあるクラスでラップして、それを返します。

私の受信ケースは次のようになります。

case get:Get => {
  get.response.setContentType(MediaType.APPLICATION_JSON)
  val response = Sender.doLogin
  val battery = (response.batteryRemaining / response.batteryCapacity) * 100
  val soc = (response.pluginState + ", " + response.chargingStatus).replaceAll("_", " ")
  val jsonResult = pretty(render(("battery" -> battery) ~ ("soc" -> soc)))
  get OK jsonResult
  // get OK "works"
}

これは動作しません:

ERROR [akka:event-driven:dispatcher:event:handler-5] akka.event.slf4j.Slf4jEventHandler - 
    [akka.http.Servlet30ContextMethodFactory$$anon$2]
    [org.eclipse.jetty.io.EofException]
    [org.eclipse.jetty.io.UncheckedIOException: org.eclipse.jetty.io.EofException
    at org.eclipse.jetty.io.UncheckedPrintWriter.setError(UncheckedPrintWriter.java:107)
    at org.eclipse.jetty.io.UncheckedPrintWriter.write(UncheckedPrintWriter.java:280)
    at org.eclipse.jetty.io.UncheckedPrintWriter.write(UncheckedPrintWriter.java:295)
    at akka.http.RequestMethod$$anonfun$complete$1.apply(Mist.scala:346)
    at akka.http.RequestMethod$$anonfun$complete$1.apply(Mist.scala:343)
    at akka.http.RequestMethod$class.rawComplete(Mist.scala:357)
    at akka.http.Get.rawComplete(Mist.scala:407)
    at akka.http.RequestMethod$class.complete(Mist.scala:343)
    at akka.http.Get.complete(Mist.scala:407)
    at akka.http.RequestMethod$class.complete(Mist.scala:340)
    at akka.http.Get.complete(Mist.scala:407)
    at akka.http.RequestMethod$class.OK(Mist.scala:388)
    at akka.http.Get.OK(Mist.scala:407)
    at com.thenewmotion.caronline.services.rest.BatteryStatusService$$anonfun$receive$1.apply(BatteryStatusService.scala:36)
    at com.thenewmotion.caronline.services.rest.BatteryStatusService$$anonfun$receive$1.apply(BatteryStatusService.scala:28)
    at akka.actor.Actor$class.apply(Actor.scala:563)
    at com.thenewmotion.caronline.services.rest.BatteryStatusService.apply(BatteryStatusService.scala:27)
    at akka.actor.LocalActorRef.invoke(ActorRef.scala:890)
    at akka.dispatch.MessageInvocation.invoke(MessageHandling.scala:25)
    at akka.dispatch.ExecutableMailbox$class.processMailbox(ExecutorBasedEventDrivenDispatcher.scala:214)
    at akka.dispatch.ExecutorBasedEventDrivenDispatcher$$anon$4.processMailbox(ExecutorBasedEventDrivenDispatcher.scala:120)
    at akka.dispatch.ExecutableMailbox$class.run(ExecutorBasedEventDrivenDispatcher.scala:186)
    at akka.dispatch.ExecutorBasedEventDrivenDispatcher$$anon$4.run(ExecutorBasedEventDrivenDispatcher.scala:120)
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
    at java.lang.Thread.run(Thread.java:662)
    at akka.dispatch.MonitorableThread.run(ThreadPoolBuilder.scala:181)
Caused by: org.eclipse.jetty.io.EofException
    at org.eclipse.jetty.server.HttpOutput.write(HttpOutput.java:150)
    at org.eclipse.jetty.server.HttpOutput.write(HttpOutput.java:97)
    at java.io.ByteArrayOutputStream.writeTo(ByteArrayOutputStream.java:109)
    at org.eclipse.jetty.server.HttpWriter.write(HttpWriter.java:283)
    at org.eclipse.jetty.server.HttpWriter.write(HttpWriter.java:107)
    at org.eclipse.jetty.io.UncheckedPrintWriter.write(UncheckedPrintWriter.java:271)
    ... 25 more
]

また、で応答したHTTP 200 OK、(ディスパッチライブラリを使用して)要求を開始しているようです。

ここで何が問題になる可能性がありますか?

4

1 に答える 1

3

接続をオフにしてみてください-閉じる:https ://github.com/jboner/akka/blob/master/config/akka-reference.conf#L262

于 2011-08-26T13:34:08.460 に答える