Akka HTTP api 路由结构

Question

我正在编写基于 Akka-HTTP 的 REST API。由于我是 Akka 和 Scala 的新手，我不确定在我的项目中组织代码的最佳方式是什么。我将有大约。具有基本 CRUD 的 7 个不同实体。这意味着我将在 API 中有超过 25 条路由。我想根据逻辑关联的实体对路由进行分组。什么是实现这一目标的好方法？目前，我从 GitHub 上的一些可用项目中获得灵感，并将这些路线分组为特征。我有一个主要特征，其中包括一些通用内容，扩展指令并添加编组：

trait Resource extends Directives with JsonSupport{
   ...
}

然后我安排了其他路线，如下所示。

trait UserResource extends Resource{

  def userRoutes:Route =
    pathPrefix("authenticate") {
      pathEndOrSingleSlash {
        post {
          entity(as[LoginRequest]) { request =>
            ...
            }
          }
        }
      }
    } ~
    pathPrefix("subscribe") {
      pathEndOrSingleSlash {
        post {
          entity(as[UserSubscribeRequest]) { request =>
            ...
            }
          }
        }
      }
    }
}

有一个类定义异常处理程序，实例化一些帮助程序并将路由放在一起：

class Routes extends UserResource with OtherResource with SomeOtherResource{

  ... handlers definitions ...
  ... helpers ...

  def allRoutesUnified: Route =
    handleErrors {
     cors() {
        pathPrefix("api") {
          authenticateOAuth2("api", PasswordAuthenticator) { _ =>
            //Routes defined in other traits
            otherRoutes ~ someOtherRoutes
          } 
        } ~ userRoutes  
      }
   }
}

终于在app入口点：

object Main extends App{

  ... usual Akka stuff ..

  val routes = new Routes ()
  val router = routes.allRoutesUnified
  Http().bindAndHandle(router, "localhost", 8080)
}

还有什么更好或更优雅的路线组织方式？

Answer 1

问题中的编码组织和结构更类似于面向对象编程，而不是函数式编程。功能是否比 OO 更好不在 stackoverflow 的范围内，但大概我们选择 scala 而不是 java 是有原因的。

此外，在特定示例中，即使您要走 OO 路线，似乎也不太需要继承。继承实现的唯一一件事就是避免使用单个 import 语句。

职能组织

更实用的方法是在对象而不是类中指定更简单的路由。此外，您创建的 Route 值不需要使用 def 进行实例化，因为您可以为不同的目的反复重用相同的 Route：

import akka.http.scaladsl.server.Directives._

//an object, not a class
object UserResource {

  //Note: val not def
  val userRoutes : Route = { 
    //same as in question 
  }

}

使用对象仍然允许您将相似的路由组合在一个统一的结构下，但无需实例化类对象来访问路由。

同样，您对allRoutesUnified 的定义应该是一个以“内部逻辑”作为参数的高阶函数。这将有助于更好地组织代码并使单元测试更容易：

object Routes {
  import UserResources.userRoutes

  def allRoutesUnified(innerRoute : Directive0 = userRoutes) : Route = 
    handleErrors {
      cors() {
        pathPrefix {
          authenticateOAuth2("api", PasswordAuthenticator) { _ =>
            innerRoute
          }
        }
      }
    }
}

现在这个函数可以用于userRoutes以外的路由。

最后，统一高阶函数可以通过类似问题的方式访问，但无需使用new创建Routes对象：

object Main extends App {

  //no need to create a routes objects, i.e. no "new Routes()"

  Http().bindAndHandle(
    Routes.allRoutesUnified(), 
    "localhost", 
    8080
  )
}