Finch 配置对不存在端点的响应
Finch configure response to non existing endpoint
我的本地计算机上有一个 finch (0.11.1) 应用程序 运行,如果我有
curl -XPOST localhost:8081/lfdjalfjla // some non-existing url
我收到 404 响应,响应主体为空。
假设我想给出某个错误消息作为响应,我应该在哪里配置它?
我没有在 user guide 中找到答案(还)。
我认为合理的实现方式是在 .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
我的本地计算机上有一个 finch (0.11.1) 应用程序 运行,如果我有
curl -XPOST localhost:8081/lfdjalfjla // some non-existing url
我收到 404 响应,响应主体为空。 假设我想给出某个错误消息作为响应,我应该在哪里配置它? 我没有在 user guide 中找到答案(还)。
我认为合理的实现方式是在 .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