1) Выкачиваем скрипт запуска sbt
curl -O https://raw.github.com/twitter/finagle/master/sbt
chmod 775 sbt
2) Создаем файл project/Build.scala для sbt
mkdir project
cat > project/Build.scala
import sbt._
import Keys._
import Tests._
import sbtassembly.Plugin._
object TestTwitterServer extends Build {
lazy val testTwitterServer = Project(
id = "test-twitter-server",
base = file("."),
settings = Project.defaultSettings ++
assemblySettings
).settings(
name := "test-twitter-server",
libraryDependencies ++= Seq(
"com.twitter" %% "twitter-server" % "1.0.1"
),
resolvers += "twitter-repo" at "http://maven.twttr.com"
)
}
CTRL-D
3) Создаем файл project/plugins.sbt для sbt
cat > project/plugins.sbt
resolvers += Resolver.url("sbt-plugin-releases", new URL("http://scalasbt.artifactoryonline.com/scalasbt/sbt-plugin-releases"))(Resolver.ivyStylePatterns)
addSbtPlugin("com.eed3si9n" % "sbt-assembly" % "0.9.0")
CTRL-D
4) Создаем файл приложения app.scala
cat > app.scala
import com.twitter.conversions.time._
import com.twitter.finagle.http.HttpMuxer
import com.twitter.finagle.{Http, Service}
import com.twitter.server.TwitterServer
import com.twitter.util.{Await, Duration, Future, Time}
import java.net.InetSocketAddress
import org.jboss.netty.buffer.ChannelBuffers.copiedBuffer
import org.jboss.netty.handler.codec.http._
import org.jboss.netty.util.CharsetUtil.UTF_8
object AdvancedServer extends TwitterServer {
val what = flag("what", "hello", "String to return")
val addr = flag("bind", new InetSocketAddress(0), "Bind address")
val durations = flag("alarms", (1.second, 5.second), "2 alarm durations")
val counter = statsReceiver.counter("requests_counter")
val service = new Service[HttpRequest, HttpResponse] {
def apply(request: HttpRequest) = {
log.debug("Received a request at " + Time.now)
counter.incr()
val response =
new DefaultHttpResponse(request.getProtocolVersion, HttpResponseStatus.OK)
val content = copiedBuffer(what() + "\n", UTF_8)
response.setContent(content)
Future.value(response)
}
}
def main() {
// We can create a new http server but in that case we profit from the
// one already started for /admin/*
// The `TwitterServer` trait exposes a `httpServer` that serve all routes
// registered in the HttpMuxer object, we just have to add our own.
HttpMuxer.addHandler("/echo", service)
// And wait on the server
Await.ready(httpServer)
}
}
CTRL-D
5) Стартуем
$ ./sbt run
CTRL-C
6) Собираем в один jar
$ ./sbt assembly
