Proxy.scala

import com.twitter.finagle.{Http, Service}
import com.twitter.util.{Await, Future}
import java.net.URI
import org.jboss.netty.handler.codec.http._

object Proxy extends App {
  val service = new Service[HttpRequest, HttpResponse] {
    def apply(req: HttpRequest): Future[HttpResponse] = {
      val client = Http.newService(s"${new URI(req.getUri).getAuthority}:80")
      val res = client(req)
      res onSuccess { res =>
        val buf = res.getContent
        val data = new Array[Byte](buf.capacity)
        buf.getBytes(0, data)
        println(new String(data, "UTF-8"))
      }
    }
  }
  val server = Http.serve(":8080", service)
  Await.ready(server)
}