Scala2.10.3 から Redis 弄ってみた

scala-redis

https://github.com/debasishg/scala-redis

Maven のURLも無いし、ドキュメントはそのままビルドしてそうな感じだったので、clone して publpish-local して使った。

Apache2 ライセンスなので、ソース取り込むのが正解かもしれない。jar 配布って出来たかは知らんけど。

import com.redis._

object Sample extends App {
  val client = new RedisClient("localhost", 6379)
  val isSet = client.set("SampleString", "SampleMessage")

  println(isSet)

  val result = client.get("SampleString")

  println(result)
}

まず、set の内部実装が

  def set(key: Any, value: Any)(implicit format: Format): Boolean =
    send("SET", List(key, value))(asBoolean)

なので、おおよそ Format を実装すれば複雑な型もいけると推測できる

これのデフォルト実装が

object Format {
  def apply(f: PartialFunction[Any, Any]): Format = new Format(f)

  implicit val default: Format = new Format(Map.empty)

  def formatDouble(d: Double, inclusive: Boolean = true) =
    (if (inclusive) ("") else ("(")) + {
      if (d.isInfinity) {
        if (d > 0.0) "+inf" else "-inf"
      } else {
        d.toString
      }
    }

}

class Format(val format: PartialFunction[Any, Any]) {
  def apply(in: Any): Array[Byte] =
    (if (format.isDefinedAt(in)) (format(in)) else (in)) match {
      case b: Array[Byte] => b
      case d: Double => Format.formatDouble(d, true).getBytes("UTF-8")
      case x => x.toString.getBytes("UTF-8")
    }

  def orElse(that: Format): Format = Format(format orElse that.format)

  def orElse(that: PartialFunction[Any, Any]): Format = Format(format orElse that)
}

なので、Format(f:Any => String) なシリアライザを書けば割とどうとでもなると。っていうか Generics 使いなさいよと思わなくない。

で、 get は

  def get[A](key: Any)(implicit format: Format, parse: Parse[A]): Option[A] =
    send("GET", List(key))(asBulk)

で、parse が入ってくるわけだが、Parse の定義は下記

object Parse {
  def apply[T](f: (Array[Byte]) => T) = new Parse[T](f)

  object Implicits {
    implicit val parseString = Parse[String](new String(_, "UTF-8"))
    implicit val parseByteArray = Parse[Array[Byte]](x => x)
    implicit val parseInt = Parse[Int](new String(_, "UTF-8").toInt)
    implicit val parseLong = Parse[Long](new String(_, "UTF-8").toLong)
    implicit val parseDouble = Parse[Double](new String(_, "UTF-8").toDouble)
  }

  implicit val parseDefault = Parse[String](new String(_, "UTF-8"))

  val parseStringSafe = Parse[String](xs => new String(xs.iterator.flatMap{
    case x if x > 31 && x < 127 => Iterator.single(x.toChar)
    case 10 => "\\n".iterator
    case 13 => "\\r".iterator
    case x => "\\x%02x".format(x).iterator
  }.toArray))
}

class Parse[A](val f: (Array[Byte]) => A) extends Function1[Array[Byte], A] {
  def apply(in: Array[Byte]): A = f(in)
}

バイナリで返ってくるんですね。

いずれにせよバイト配列を、デシリアライズできればよい。

配列的に突っ込むのは別IFらしく

  client.lpush(key, value1, value2, ...)(implicit Format)
  client.rpush(key, value1, value2, ...)(implicit Format)
  client.lpop(key)(implicit Format, Parser)
  client.rpop(key)(implicit Format, Parser)
  

もう突っ込まないよ

object Sample extends App {
  val client = new RedisClient("localhost", 6379)

  import serialization._
  import Parse.Implicits._

  client.hmset("hashMapSet", Map("field1" -> 32, "field2" -> 64))

  println(
    client.hmget[String, Int]("hashMapSet", "field1", "field2")
  )
}

ただし、Map[String, Any] はうまく走ってくれなかった。まぁ仕方ないか、、、。

非同期取得もあるけど、基本そのまま動く。

scala-redis-nb

何かまだアルファ版もいいとこらしい。

https://github.com/debasishg/scala-redis-nb

name := "RedisSample"                                                             

version := "1.0"

scalaVersion := "2.10.3"

resolvers += "spray" at "http://repo.spray.io/"

libraryDependencies ++= Seq(
  "net.debasishg" %% "redisreact" % "0.3",
  "io.spray" %%  "spray-json" % "1.2.5"
)

として、公式ほぼ写経で

import akka.actor.ActorSystem
import akka.util.Timeout
import com.redis.RedisClient
import scala.concurrent.duration._

case class User(id:Int, name:String, age:Int)

case class Group(id:Int, name:String, users:List[User])

object Sample extends App {
  implicit val system = ActorSystem("redis-client")
  implicit val executionContext = system.dispatcher

  val client = RedisClient("127.0.0.1", 6379)

  import spray.json.DefaultJsonProtocol._
  import com.redis.serialization.SprayJsonSupport._

  implicit val childClass = jsonFormat3(User)
  implicit val groupClass = jsonFormat3(Group)

  val sampleValue = User(2, "delick", 28)

  client.set("key", sampleValue)

  import scala.concurrent.Await
  implicit val timeout = Timeout(5000)

  val result = Await.result(client.get[User]("key"), 5 seconds)
  println(result)

  system.shutdown()
}

としてみた所、Nullpo落ち。

[error] (run-main) java.lang.NullPointerException
java.lang.NullPointerException
        at akka.pattern.AskableActorRef$.ask$extension(AskSupport.scala:136)
        at com.redis.api.StringOperations$class.set(StringOperations.scala:23)
        at com.redis.RedisClient.set(RedisClient.scala:26)
        at Sample$delayedInit$body.apply(Sample.scala:24)
/* 中略 */
[trace] Stack trace suppressed: run last compile:run for the full output.

呼び出しに関して、明らかに素の Akka にないような呼び出ししてるし、import も書かれてないから呼び出し方が間違ってるのかもしれない。

いずれにせよ、情報無さすぎで使わない判断。