基于akka-http搭建restfull框架

Posted 2021-01-11 netsharp

1.scala开发环境介绍

2.scala插件的demo模板介绍

3.akka-http提供demo研究

4.添加路由机制解析

 

package org.netsharp.rest

import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.model.{ContentTypes, HttpEntity}
import akka.http.scaladsl.server.Directives._
import akka.stream.ActorMaterializer

import scala.io.StdIn

object WebServer {

  def main(args:Array[String]):Unit={

    implicit val system = ActorSystem("netsharp")
    implicit val materializer = ActorMaterializer()
    implicit val executionContext = system.dispatcher

    val userRoute = path("user"){
      get{
        complete(HttpEntity(ContentTypes.`text/html(UTF-8)`, "<h1>Say user to akka-http</h1>"))
      }
    }

    val orderRoute = path("order"){
      get{
        complete(HttpEntity(ContentTypes.`text/html(UTF-8)`, "<h1>Say order to akka-http</h1>"))
      }
    }

    val customerRoute = path("customer"){
      get{
        complete(HttpEntity(ContentTypes.`text/html(UTF-8)`, "<h1>Say customer to akka-http</h1>"))
      }
    }

    val routes =
      pathPrefix("v1") {
        userRoute ~ orderRoute ~ customerRoute
      } ~ path("")(getFromResource("public/index.html"))

    val bindingFuture = Http().bindAndHandle(routes,"localhost",80)

    println(s"Server online at http://localhost:80/
Press RETURN to stop...")

    StdIn.readLine()

    bindingFuture.flatMap(_.unbind())
      .onComplete(_=>system.terminate())
  }
}

　　

 

5.akka-http与actor结合