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()


上一篇:
下一篇:
切换中文