scala
libraryDependencies += "com.livestream" %% "scredis" % "2.0.0"
scala
import scredis._
import scala.concurrent.ExecutionContext.Implicits.global
scala
val redis = Redis("localhost", 6379)
scala
val value: Future[Option[String]] = redis.get("key")
scala
redis.set("key", "value")
scala
val pipeline = redis.pipelined
pipeline.set("key1", "value1")
pipeline.set("key2", "value2")
pipeline.sync()
scala
val listener = new PubSubMessageListener {
override def onMessage(message: Message): Unit = {
println(s"Received message: ${message.payload}")
}
}
val subscriptionFuture = redis.subscribe(listener, channels = Seq("channel"))
scala
redis.quit()
redis.stop()