公正な警告、私は Scala を初めて使用するので、ここで単純なものが欠けている可能性があります。
私はこのコードを持っています、それはうまくいきます
import java.net.InetSocketAddress
import com.twitter.finagle.builder.Server
import com.twitter.finagle.builder.ServerBuilder
import com.twitter.finagle.http.Http
import com.twitter.finagle.http.Request
import com.twitter.finagle.http.RichHttp
import java.util.logging.Logger
import com.typesafe.config.ConfigFactory
import org.jboss.netty.buffer.ChannelBuffers.copiedBuffer
import org.jboss.netty.util.CharsetUtil.UTF_8
import com.twitter.finagle.Service
import com.twitter.finagle.http.Response
import com.twitter.util.Future
import com.twitter.finagle.http.service.RoutingService
import org.jboss.netty.handler.codec.http.HttpResponse
import org.jboss.netty.handler.codec.http.HttpRequest
import com.twitter.finagle.SimpleFilter
object TestServer extends App {
val myService = new Service[Request, Response] {
def apply(request: Request) = {
// If you throw an exception here, the filter will catch it.
// throw new RuntimeException("s")
Future {
val response = Response()
response.setContent(copiedBuffer("Hello World", UTF_8))
response
}
}
}
val routingService = RoutingService.byPath {
case "/" => myService
}
val server: Server = ServerBuilder()
.codec(RichHttp[Request](Http()))
.bindTo(new InetSocketAddress(8080))
.name("httpserver")
.build(routingService)
println("Server is up.")
class Authorize extends SimpleFilter[HttpRequest, HttpResponse] {
def apply(request: HttpRequest, continue: Service[HttpRequest, HttpResponse]) = {
println("filtered")
continue(request)
}
}
}
しかし、その Authorize フィルターを自分のサービスに追加したいと考えています。これを追加すると:
val authorize = new Authorize
val aService: Service[HttpRequest, HttpResponse] = authorize andThen myService
コンパイル エラーが発生します。
[error] found : com.twitter.finagle.Service[com.twitter.finagle.http.Request,com.twitter.finagle.http.Response]
[error] required: com.twitter.finagle.Service[org.jboss.netty.handler.codec.http.HttpRequest,org.jboss.netty.handler.codec.http.HttpResponse]
サービスのタイプを Service[HttpRequest, HttpResponse] に変更すると、routingService として使用できなくなります。
[error] found : com.twitter.finagle.Service[org.jboss.netty.handler.codec.http.HttpRequest,org.jboss.netty.handler.codec.http.HttpResponse]
[error] required: com.twitter.finagle.Service[?,com.twitter.finagle.http.Response]
これらの型のエラーが原因で、ルーティング サービスをフィルターで動作させるのに苦労しています。
ありがとう!
編集:
以下の@Septemの回答を使用して動作するコードの例を追加したかっただけです。これをフィルターに使用します。
class Authorize extends Filter[Request, Response, Request, Response] {
def apply(request: Request, continue: Service[Request, Response]) = {
println("filtered")
continue(request)
}
}
finagle と scala についてはまだ少しぼんやりしていますが、ここで起こっていたことは、特定のタイプのサービスを既に想定している SimpleFilter を使用していたことだと思います。