Akka HTTPでWeb APIに仕立てる

リスト16：HTTPサーバーの起動

// レジ係アクターを生成
val cashierActor = system.actorOf(CashierActor.props, "cashierActor")

// HTTPサーバーの起動
val bindingFuture = Http().bindAndHandle(route, "localhost", 8080)
bindingFuture
  .map { serverBinding =>
    log.info(s"Server online at ${serverBinding.localAddress}")

    // 初期化メッセージを送信しカフェをスタートさせる
    cashierActor ! CashierActor.Initialize
    // ..

リスト17：マーシャラーの定義

import cafe._3_tellpattern.BaristaActor.Order

// JSON形式とOrder型のマーシャリング・アンマーシャリング
implicit val orderFormat = jsonFormat2(Order)

リスト18：ルート定義

val route: Route =
  path("order") {
    put {
      log.info("received PUT /order")
      entity(as[Order]) { order =>
        // レジ係アクターへOrderメッセージを送信
        cashierActor ! order
        complete(s"Received order: ${order.product} * ${order.count}")
      }
    }
  }

リスト19：オーダー受け付けのレスポンス

> http PUT http://localhost:8080/order product="Coffee" count:=10
HTTP/1.1 200 OK
Content-Length: 27
Content-Type: text/plain; charset=UTF-8
Date: Mon, 10 Sep 2018 08:16:20 GMT
Server: akka-http/10.1.5

Received order: Coffee * 10

リスト20：ルート定義（アクターからの応答あり）

import cafe._4_askpattern.CashierActor.OrderCompleted

val route =
  put {
    path("order") {
      entity(as[Order]) { order =>
        log.info("receive PUT request /order")

        implicit val timeout: Timeout = 5.seconds
        // レジ係アクターへOrderを送信
        val response: Future[Any] = cashierActor ? order

        // レジ係アクターからの応答を受信したときの処理
        onComplete(response.mapTo[OrderCompleted]) {
          case Success(orderCompleted) =>
            // 成功した場合は完了メッセージを返す
            complete(s"${orderCompleted.message}")
          case Failure(t) =>
            // 失敗した場合は例外メッセージを返す
            complete(s"${t.getMessage}")
        }
      }
    }
  }

リスト21：実行結果

> http post http://localhost:8080/order product="Coffee" count:=10
HTTP/1.1 200 OK
Content-Length: 11
Content-Type: text/plain; charset=UTF-8
Date: Mon, 10 Sep 2018 08:18:32 GMT
Server: akka-http/10.1.5

ok