我在本地机器上运行了一个 finch (0.11.1) 应用程序,如果我这样做了
curl -XPOST localhost:8081/lfdjalfjla // some non-existing url
我收到一个 404 响应,响应正文为空。假设我想给出某个错误消息作为响应,我将在哪里配置它?我没有在用户指南中找到答案(还)。
.toServiceAs
我认为实现这一点的合理方法是在调用返回的服务之上应用 Finagle 过滤器。
import com.twitter.finagle.http.{Request, Response, Status}
import com.twitter.finagle.{Service, SimpleFilter}
import com.twitter.util.Future
class OnNotFound(rep: Response) extends SimpleFilter[Request, Response] {
def apply(req: Request, s: Service[Request, Response]): Future[Response] = {
s(req).map {
case r if r.status == Status.NotFound => rep
case r => r
}
}
}
进而。
scala> import io.finch._, com.twitter.finagle.http.Status
scala> val e = get("foo") { Ok("bar") }
e: io.finch.Endpoint[String] = GET /foo
scala> val s = new OnNotFound(Response(Status.InternalServerError)).andThen(e.toServiceAs[Text.Plain])
s: com.twitter.finagle.Service[com.twitter.finagle.http.Request,com.twitter.finagle.http.Response] = <function1>
scala> Http.server.serve(":8080", s)
res0: com.twitter.finagle.ListeningServer = Group(/0:0:0:0:0:0:0:0:8080)
最后用 HTTPie 进行一些测试。
$ http :8080/foo
HTTP/1.1 200 OK
Content-Encoding: gzip
Content-Length: 29
Content-Type: text/plain
Date: Fri, 03 Mar 2017 23:59:34 GMT
bar
$ http :8080/bar
HTTP/1.1 500 Internal Server Error
Content-Length: 0