如何在scala akka-http中定义通用路由
在Scala Akka-HTTP中定义通用路由可以通过以下步骤实现：
- 导入必要的依赖：import akka.http.scaladsl.server.Directives._ import akka.http.scaladsl.server.Route
- 创建一个通用路由对象：object CommonRoutes { def apply(): Route = { // 在这里定义你的通用路由 path("hello") { get { complete("Hello, World!") } } } }
- 在你的主路由中包含通用路由：val routes: Route = { // 其他路由定义 CommonRoutes() }
这样，你就可以在主路由中包含通用路由，并在其中定义你的具体路由逻辑。在上面的示例中，我们定义了一个简单的路由，当访问路径为"/hello"时，返回"Hello, World!"。
关于Akka-HTTP的更多信息和用法，你可以参考腾讯云的Akka-HTTP产品文档：Akka-HTTP产品介绍。
请注意，以上答案仅供参考，具体的实现方式可能因项目需求和框架版本而有所不同。
相关·内容
我试图确保来自服务器的所有响应都是通过GZIP编码/压缩的。它对定义的路径非常有用，但我一直无法找到如何实现“拒绝”路径的方法。
import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.coding.Gzip
import akka.http.scaladsl.model._
import akka.http.scaladsl.server.Directives._
import akka.stream.ActorMaterializer
import scala.concu
浏览 3提问于2016-05-27得票数 1
如何在akka-http中将mongo ObjectId转换为字符串id，反之亦然，用于此用户类的JSON响应。
case class User(_id: ObjectId, email: String, name: Option[String], birthDate: Option[String])
这个jsonFormat4不工作。
implicit val userFormat = jsonFormat4(User.apply)
引发此错误。
错误：(21，40)找不到JsonSupport.this.JForg.mongodb.scala.bson.ObjectId隐式userForm
浏览 0提问于2018-07-06得票数 2
回答已采纳
我想知道是否有可能将一个实例转换为另一个的实例。如果是这样，那我该怎么做呢？我在akka-http文档中没有找到任何提到这一点的地方。我正在尝试编写一个实现Java接口的类，该接口返回akka-http应用程序的基本路由，但在内部我想用Scala实现该类。
浏览 19提问于2017-02-18得票数 0
回答已采纳
2回答
我在akka-http中有5个控制器。每个端点有5个端点(路由)。现在我需要为它们引入版本控制。所有端点都应以/version1为前缀。例如，如果现在有一个端点xyz，那么它应该是/version1/xyz。其中一种方法是添加一个pathPrefix，但需要将其添加到每个控制器。有没有办法将它添加到一个公共位置，以便对所有端点显示它。
我在scala中使用akka-http。
浏览 0提问于2018-11-21得票数 1
我在多项目sbt中有一个scala交叉构建设置。在其中一个项目中，我试图禁用针对scala版本的构建，因为它依赖于akka-http，而2.10版本不支持akka-http。
我试图从该crossScalaVersions字段中删除特定版本，但sbt仍然尝试针对2.10构建它。我怀疑这是因为这个项目依赖于另一个与2.10交叉构建的兄弟项目
sbt如下所示(为便于阅读而缩写)：
lazy val commonSettings = Seq(
........... Common settings ................
)
// aggregate root project
lazy
浏览 2提问于2018-09-03得票数 0
1回答
访问资源中的scala.js输出
、、、、
我正在尝试使用scala.js、scalatags、akka-http和mill作为我的构建工具来构建一个应用服务器。在浏览器尝试查找包含生成的scala.js代码的脚本之前，一切都很顺利。这是成功构建并引用编译后的scala.js代码(HiPage.js -在mill中构建为ScalaJSModule )的scalatags代码。当它运行时，下面的println打印输出: file:/Users/nnovod/projects/lims/LIMS/resources/HiPage.js，这确实是我放置来自scala.js的javascript输出的位置 object HiPage {
浏览 50提问于2020-10-08得票数 0
回答已采纳
我使用的是akka-http 10.0.10，并且有以下文件(我将其解压到单个文件中，以稍微缩小导入范围，但问题是相同的)：
import akka.http.scaladsl.model.StatusCodes
import akka.http.scaladsl.server._
import akka.http.scaladsl.server.Directives._
object RouteHelpers {
def indexRoute(dir : String): Route =
pathEndOrSingleSlash {
getFromFile(dir
浏览 0提问于2020-02-26得票数 0
我在请求中向我的akka-http发送以下头："Content-type": "application/json"、"Accept": "application/json"、"AppId": "some_id"。
如何在我的akka-http路由中获得"AppId“自定义标题？
(get & parameters("id")) { (id) =>
complete {
val appId = ?? // I want to get c
浏览 3提问于2015-09-16得票数 4
回答已采纳
在scala并发包中，有一个不返回任何内容的onComplete方法，而在akka-http指令中，它返回Directive1。
这是唯一的区别吗？我有时会对这两种方法感到困惑。
浏览 0提问于2015-12-23得票数 0
我想知道是否有一种方法可以连接RPC(这样客户端知道他可以调用什么，服务器知道他应该响应什么)和HTTP Rest(这样任何其他没有共享代码库的客户端都可以进行调用)。
有很多用于scala的http库(akka-http、http4s等)。还有很好的RPC lib autowire。但我看不出有什么方法能把它们联系起来。我知道autowire是协议不可知的，但这是一个缺点，因为我希望路由发生在http层(例如akka-http)，而不是rpc(autowire)。
我想知道这是否可能。如果是，是否有任何正在进行的实现？
浏览 4提问于2016-12-20得票数 4
回答已采纳
1回答
我是AKKA世界的新手
我从上面的帖子中得到了如何使用Akka-HTTP在RESTAPI响应中发送文件的解决方案，但我想为该文件提供一个名称和扩展名。那么，用文件名和扩展名将文件作为响应发送的方法是什么呢?这意味着我希望下载的文件在Akka-HTTP with scala中应该有一个带有.zip扩展名的名称
浏览 2提问于2021-04-15得票数 0
1回答
我正在尝试使用带有akka-http的scala启动REST API。我是akka和角色模型范例的新手，所以我想实现一个类型化的角色系统，但我遇到了这个sbt编译错误：
could not find implicit value for parameter system: akka.actor.ActorSystem (implicit ActorRefFactory required: if outside of an Actor you need an implicit ActorSystem, inside of an actor this should be the implicit
浏览 13提问于2020-06-07得票数 0
我需要为我的服务构建REST API，而且我还是个Scala新手。我开始了解finatra和akka-http。在学习了一段时间后，我更倾向于finatra，因为它为web服务提供了java-style语法和方法。然而，akka与scala有着非常密切的关系，在这一点上学习akka-http可能会对我的scala之旅有所帮助。 任何帮助都是非常感谢的。
浏览 19提问于2019-10-11得票数 1
我正在从代码喷雾(版本：1.3.4)迁移到akka-http (版本：10.0.13)。
我们有一个现有的客户端，他们像Content-Type一样发送application/vnd.awesome.value; mykey="custom/custom"
下面的代码在spray中运行良好，但在akka-http参数(mykey)中被去掉
request.header[`Content-Type`].map { header =>
// HERE PARAMS IS EMPTY MAP
val myKeyValue = header.contentType.med
浏览 5提问于2019-11-28得票数 0
我正在重新学习Scala，我想做一个系统流程，如下所示
路由(Akka-Http)，它询问Actor Model(Akka)，然后Actor Model (Akka)通过Slick模型询问数据库。
就像这样
路由
path("rooms"){
get {
val rooms = (actorRoom ? GetRooms).mapTo[Seq[Room]] //bad code
complete(rooms) //bad code
}
}
ActorRoom
def receive = {
case GetRooms => sender() !
浏览 4提问于2017-02-18得票数 0
1回答
我正在努力将一个应用程序从Spray.io迁移到Akka-http。这个应用程序是基于微服务的，有许多我们建立在上面的小型库。下面是在一个特定的微服务中组合指令和路由的示例：
val routes =
(decompressRequest & compressResponseIfRequested) {
metricsRoute ~
healthStatusRoute ~
apiRoutes // only these are my app's routes
}
除apiRoutes之外，上述所有内容都是在内部库中定义的
浏览 1提问于2016-09-21得票数 3
回答已采纳
在编辑一个简单的路由定义时，语法高亮的更新非常慢。更新需要几秒钟，这实际上破坏了编辑/将此编译流。
我以前没有这个。也许有什么改变了。其他人也在经历吗？
IntelliJ IDEA 2017.1.4构建#IC-171.4694.23，JRE: 1.8.0_112-release-736-b21 x86_64 JVM: OpenJDK 64位服务器VM，由JetBrains s.r.o Mac 10.12.5构建
Scala 2.12.2 akka-http 10.0.7
浏览 2提问于2017-06-16得票数 3
3回答
我有一个多项目的sbt构建，它挂在执行的不同阶段(在编译了一个或多个模块之后)。
我希望能提供任何关于它被挂的可能原因的信息.
为了提供上下文，这个构建包含三个模块()
前端: scala.js模块
后端: akka-http中的web服务器
模型:模型和json序列化器的共享代码
build.sbt文件：
name := "my-project"
version := "0.1"
scalaVersion := "2.12.4"
lazy val `my-project` = (project in file("
浏览 1提问于2018-01-30得票数 1
回答已采纳
PlayFramework2Scala中play.mvc.Router.routes的等价物是什么？
在playframework 1.x中，我可以遍历控制器中的可用路由：
for(Route route:Router.routes){
...
}
我该如何使用playframework 2 scala做到这一点呢？
not found 似乎能够遍历它们，但我需要在控制器中执行此操作。
浏览 3提问于2012-05-11得票数 3
回答已采纳
我想用相同的URI定义两个不同的GET REST端点，一个没有任何查询参数，另一个带有查询参数。
例如：
(不带查询参数的uri)
(带有查询参数的uri)
如何使用scala在Akka-HTTP中实现上述需求，同时也需要URI中的段(资源ID)。
提前谢谢。
浏览 2提问于2021-04-19得票数 0
回答已采纳
在我的Akka-http路由中，我得到了一条特定的消息，我希望将其内容包装为错误消息，如下所示：
val response:Future[T] = (actor ? command).mapTo[T]
response match {
case err : Future[InvalidRequest] =>
HttpResponse(408, entity = err.map(_.toJson).????)
case r : Future[T] => r.map(_.toJson)
}
case class Inval
浏览 3提问于2016-07-12得票数 2
回答已采纳
我正在使用Scala中的Akka-Http开发一个简单的HTTP服务器。
我的代码如下所示：
object HttpServer extends App {
override def main(args: Array[String]): Unit = {
implicit val system = ActorSystem("my-system")
implicit val materializer = ActorMaterializer()
implicit val executionContext = system.dispat
浏览 0提问于2017-03-02得票数 2
回答已采纳
1回答
Akka-HTTP与JAX-RS
、、、、
我最近开始学习Akka，并且很难找到一个答案。
我们知道，像泽西、RestEasy这样的库遵循一个公共接口/API，即JAX。而Akka-HTTP也是一套库.那么，Akka-HTTP也遵循JAX-RS吗？
如果不是，那么Akka-HTTP与JAX-RS有什么不同？
对此的任何答复都将不胜感激。提前谢谢。
浏览 4提问于2020-05-03得票数 0
1回答
我有一个简单的akka-http应用程序，可以将文件以块的形式上传到服务器。它有两条路径，第一条/打开一个HTML来搜索文件，第二条路由将上传按钮链接到将文件分成块并上传的逻辑。然后我构造了一个单元测试。规范)测试这两条路线。第一个很简单，它只是识别我可以打开的网页。但我要测试的第二件事是：
如果表单上没有文件，我应该在Spec上识别异常，如果表单上有一个文件，我检查逻辑，并测试它是否真的上传了该文件。
这是我的akka-http应用程序：
import akka.Done
import akka.actor.ActorSystem
import akka.http.scaladsl.Http
浏览 1提问于2021-02-03得票数 1
回答已采纳
我想在Scala Akka-HTTP中创建可重用的通用路由，这样我就可以对我定义的其余路由使用相同的通用路由。
到目前为止，我可以像下面这样定义路由，它可以完美地工作。
class TestApi(val modules: Configuration with PersistenceService)(implicit executionContext: ExecutionContext) extends BaseApi with CirceSupport {
override val oauth2DataHandler = modules.oauth2DataHandler
val
浏览 1提问于2017-01-05得票数 0
回答已采纳
这更像是一个Scala问题，但灵感来自于这个http-scala示例。
val route =
path("hello") {
get {
complete(HttpEntity(ContentTypes.`text/html(UTF-8)`, "<h1>Say hello to akka-http</h1>"))
}
}
根据示例，path似乎是一个以String作为第一个参数，Route作为第二个参数的临时方法，尽管我在API中没有看到这样的实现。有人能告诉我
浏览 5提问于2017-04-18得票数 0
我有一个用scala和akka-http构建的http服务器。有没有一种方法可以记录发送给客户端的错误响应？
浏览 1提问于2016-09-21得票数 2
回答已采纳
1回答
我正在将rest移植到scala，使用akka-http和spray。
旧API的响应如下：
{
"result": { ... },
"error": null
}
现在我想要保持完全的向后兼容性，所以当没有错误时，我想要一个带有error值的null键。
不过，我看不出喷雾器里有什么支持。当我用None错误序列化以下内容时：
case class Response(result: Result, error: Option[Error])
我最后
{
"result": { ... }
}
并且它完全降低了错误值。
浏览 1提问于2020-03-19得票数 2
回答已采纳
我正在使用akka和akka-http 2.4.2，我试图理解它们的内部组件。
akka和akka-http使用什么来启动rest网络服务？
它使用的是嵌入式uses服务吗？(比如Jetty?)
我怎么得到它的版本？
启动rest web服务的代码是：
implicit val actorSystem = ActorSystem("system")
implicit val actorMaterializer = ActorMaterializer()
val route: Route = {
blablabla ...
}
val bind = Http()
浏览 2提问于2016-03-10得票数 4
回答已采纳
我正在尝试向我的应用程序添加一个路由，这样我就可以在ajax调用中使用它。
下面是我的application.ini中的内容
;Routes
resources.router.routes.products.route = "/backend/api/:command"
resources.router.routes.products.defaults.module = "backend"
resources.router.routes.products.defaults.controller = "api"
resources.router.r
浏览 0提问于2011-08-25得票数 0
回答已采纳
我想知道是否有一种简单的方法可以让像NewRelic这样的监控甚至端点在我的基于akka-http的服务器上有指标(每分钟的查询次数，平均响应时间，端点的统计数据，404的数量，等等)
我当前的akka-http服务器版本是10.0.0，我使用的是scala 2.11.8
谢谢你的帮忙
浏览 10提问于2017-07-11得票数 2
回答已采纳
1回答
我正在使用akka-http (scala)开发微服务。目前，我找不到任何将swagger直接集成到akka-http中的方法。尽管如此，我还是从swagger 2.0规范开始了我的微服务。
现在的挑战之一是向消费应用程序显示统一的API规范。我不想将多个规格分享给消费者，因此希望将多个swagger规格聚合到一个规格中(如果这可以在运行中完成，那就太好了)。另外，这将如何与swagger-ui一起工作？
浏览 7提问于2016-01-27得票数 1
1回答
首先，如果这个问题已经得到了回答，或者如果有关于它的完整文档/教程，我很抱歉，我是Scala新手，我肯定错过了一些东西。
我有C#背景，我正在努力扩展我学习Scala的知识。我希望在微服务架构中包含一个Scala微服务，该微服务架构实际上是使用.NET项目构建的。为了在.NET项目中实现共享的架构代码，我开发了一系列的基础项目，所有的微服务项目都引用了这些基础项目，使用VS的这个操作非常简单，但是我没有掌握如何在Scala上实现相同的功能。
特别是，我想了解是否有一种方法可以引用位于项目B的本地文件夹中的项目A，就像这样引用Maven中的项目一样，例如：
libraryDependencies
浏览 0提问于2018-05-07得票数 1
2回答
我无法确定下面的代码代表什么，因为Scala文档中没有列出这些语法。有人能在下面的每一条线上说明一些信息吗？如果需要将上面的标题改为对他人有益的东西，请告诉我。
val route =
path("hello") {
get {
complete(HttpEntity(ContentTypes.`text/html(UTF-8)`, "<h1>Say hello to akka-http</h1>"))
}
}
参考文献：
浏览 7提问于2017-09-14得票数 1
回答已采纳
正在尝试包含简单的HTML5页面，而不是scala模板。
为此，我尝试在我的views中创建一个简单的HTML页面，但是如何将我的应用程序重定向到这个页面？
我试图实现的是使用超文本标记语言页面作为我的UI和播放控制器的POST和GET JSON数据到ui页面，这将允许我解耦UI
浏览 4提问于2012-08-06得票数 1
回答已采纳
在akka-http
//ContentType.scala
val `application/json` = ContentType(MediaTypes.`application/json`)
同样，我如何创建一个ContentType
application/schema+jsonapplication/schema-instance+json
参考资料：
//MediaType.scala
val `application/json` = awfc("json", HttpCharsets.`UTF-8`, "json"
浏览 3提问于2021-02-24得票数 0
我基准喷雾和akka-http，以了解可能的吞吐量，我可以得到。经过测试的应用程序简单。它在静态GET路径上返回静态输出。但在这两种框架中，当静态响应长度从7增加到2 040个字符时，吞吐量从~64000降到~22000 rps。
还有人经历过这样的行为吗？如何改善这种情况呢？
在这里可以找到经过测试的代码：
它的灵感来自于中描述的测试。
旧版本：
ubuntu 14.04，scala 2.11.8，oracle jdk 1.8
akka-http: 2.4.11
喷雾剂: 1.3.1与akka 2.3.6
浏览 4提问于2016-10-06得票数 0
回答已采纳
如果我的Startup.cs中有以下路由：
app.UseMvc(routes =>
{
routes.MapRoute(
name: "default",
template: "{controller=Home}/{action=Index}/{id?}");
});
app.UseMvc(routes =>
{
浏览 0提问于2018-02-14得票数 0
上下文: Scala项目的导入库，如akka-http。
IDE: Eclipse (火星)+Scala 4.3
操作系统: Windows
我已经将sbt配置为下载与依赖项目相关的源代码，以便更全面地查看/检查库。
当我打开akka.http.scaladsl.server.Directive时，我只会在大纲视图中看到该类的前几个成员。我可以看到代码中没有显示在大纲中的其他成员。
为什么我没看到完整的大纲？
浏览 2提问于2016-02-03得票数 1
回答已采纳
2回答
我想在rest服务中使用akka-http和新的mongo-scala-driver。
这段代码起作用了
val routes = {
pathPrefix("info") {
pathEndOrSingleSlash {
get {
val mongoClient: MongoClient = MongoClient("mongodb://localhost:27017,localhost:27018,localhost:27019/?replicaSet=rs0")
val database: Mong
浏览 2提问于2017-03-10得票数 0
我写这封信是为了写任何的编码器/解码器。假设我的课是
case class Demo(
field1: Any
)
然后我试着通过
val myDemo=Demo(field1=None)
print(myDemo.asJson+"\n")
我把编码器译码器定义为
implicit val valueEncoderValue: Encoder[Any] = Encoder.encodeString.contramap[Any](x=>{
x.toString})
implicit val valueDecoderValue: Decoder[Any] =
浏览 8提问于2022-11-10得票数 1
如果数组元素小于10，我尝试用0填充数组元素。也就是说，如果数组1,2,12中有元素，我想打印0102，12，我在剧本框架中的scala模板中尝试这样做。因此，我现在尝试的是使用scala中的if和else状态，查看元素是否小于10，然后将其设置为零。
@for(element <- myarray){
@if(element.getValue < 10){@element} else{@element}
}
myarray是由me定义的Uint8数组，getValue是UINT8类中的函数。它一直告诉我not found: value element。还
浏览 3提问于2013-09-15得票数 0
回答已采纳
我正在寻找一种方法，通过akka-http访问请求路径的段列表：
val route = Seq(
path("api" / "sub" / IntNumber / IntNumber) { sub }
).reduce(_~_)
def sub(request: RequestContext): Future[RouteResult] = get {
// how to have access to the two IntNumbers?
}(request)
我知道我可以直接把它们写进路由代码：
path("api" / "
浏览 0提问于2018-12-02得票数 1
回答已采纳
我是Akka框架的新手，当我试图运行我的代码时，我会收到下面的错误消息。
通过api代码调用的方法返回一个Future[List[HashMap[String,Object]]]。
调用此方法的api代码(akka-http路由)：
@GET
@Path("getList/{name}")
@Authorization("basicAuth")
@Operation(summary = "Get list", description = "Returns a list",
parameters = Array(
浏览 4提问于2022-09-02得票数 0
回答已采纳
我正在看这个akka-http文档示例(它链接到akka-http测试代码)：
这实际上是来自github代码的测试。我的问题是，这里导入的隐式Marshaller在哪里？我正在寻找进口，但我找不到它？我尝试使用IntelliJ来显示隐式导入，但是我仍然不能理解。其中是import语句，该语句获取传递给的Marshaller的隐式声明：
val entityFuture = Marshal(string).to[MessageEntity]
在21行？它调用
def to[B](implicit m: Marshaller[A, B], ec: ExecutionContext): Fu
浏览 11提问于2017-07-05得票数 1
回答已采纳
1回答
我用的是Akka-HTTP。我有以下URI
/a
/b
我将在/a URI上接受命中，并且在满足该条件时有一个条件，然后我想重定向到/b URI。
如果该条件没有得到满足，那么我将返回错误的请求。
现在的问题是Akka-HTTP重定向URI是标准路由类型的，因此我想返回HTTP响应，因此无法运行代码。
有人能告诉我如何用Akka中的HTTP响应类型重定向吗？
浏览 1提问于2017-08-01得票数 1
回答已采纳
2回答
我正在尝试编写一个Akka HTTP微服务(akka版本2.4.11，Scala版本2.11.8，这两个版本都是撰写本文时的最新版本)，它知道客户端服务的IP (即远程地址)，而我无法让它工作。
我可以创建和运行一个服务，上面写着“你好！”使用这样的路线：
val routeHello: Route = path("SayHello") {
get {
entity(as[String]) {
body => complete {
HttpResponse(entity = HttpEntit
浏览 0提问于2016-10-19得票数 5
我是新来的阿克卡/喷雾和斯卡拉。我从akka文档中看到，有HttpRequest，这是Http请求类，也有根据akka文档的RequestContext。
当HttpRequest通过akka-http路由结构时封装它的上下文。
请问这里“上下文”一词的含义是什么？
谢谢
浏览 2提问于2017-05-05得票数 0
回答已采纳
我正在尝试用scala中的akka api创建一个Http-server，但是我得到了NoClassDefFoundError。
我查了和
但我不能把它们和我的案子联系起来。
/usr/lib/jvm/default-runtime/bin/java ...
Exception in thread "main" java.lang.NoClassDefFoundError: akka/actor/ActorRefFactory
at main.scala.Main.main(main.scala)
Caused by: java.lang.ClassNotFoundEx
浏览 21提问于2018-01-22得票数 0
回答已采纳
在尝试使用akka-http对某个内部端点执行简单的POST请求时，我遇到了一个问题。当执行这段代码时：
for {
request <- Marshal(merchantTransactionRequest).to[RequestEntity]
response <- Http().singleRequest(
HttpRequest(
method = HttpMethods.POST,
uri = "http://foo/bar:8080",
entity =
浏览 0提问于2017-09-25得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
