scala
import com.redis._
val redisClient = new RedisClient("localhost", 6379)
scala
redisClient.set("key", "value")
val value = redisClient.get("key")
println(value.getOrElse("Key not found."))
scala
redisClient.rpush("list", "item1", "item2", "item3")
val list = redisClient.lrange("list", 0, -1)
list.foreach(println)
scala
val subscriber = new RedisSubscriber[String] {
def onMessage(channel: String, message: String) {
println(s"Received message: $message from channel: $channel")
}
}
val channels = Seq("channel1", "channel2")
redisClient.subscribe(subscriber, channels: _*)
