async, non-blocking memcached client using akka

inspired by, but much simpler than, this project: https://github.com/derekjw/fyrie-redis

info on akka io / iteratee library: http://doc.akka.io/docs/akka/2.0.3/scala/io.html

This client is has not seen extensive production testing and should be used with care.

• Zack Grannan (@zgrannan)
• David Y. Ross (@dyross)

• Supports set, get, and delete memcached instructions
• All instructions are non-blocking.
• The set and delete methods are fire-and-forget, the get method returns an akka.dispatch.Future
• Uses consistent hashing to distribute data across multiple memcached servers
• Deduplicates keys: If multiple clients make a request for the same key, only a single get request will be made for that key, and results will be forwarded to each requesting client
• Will reconnect to memcached if the connection is lost, and will complete any pending futures if the connection is re-established

• Requires sbt https://github.com/harrah/xsbt/wiki
• cd into the akka-memcached directory and run sbt package
• The jar will be located in target/scala-2.9.1

• Include this jar in your project
• Create a new instance of RealMemcachedClient
• It is necessary to have an implicit serializer when calling the get or set client methods

import akka.util.duration._
import akka.util.Timeout
import akka.dispatch.Await
import com.klout.akkamemcached.RealMemcachedClient
import com.klout.akkamemcached.Serialization.JBoss

object Test {
	// Create a client that connects to localhost on a single connection
    val client = new RealMemcachedClient(List(("localhost", 11211)), 1)

    // Store a value
    client.set("key", "value", 1 hour)

    // Retrieve a value
    val valueFuture = client.get("key")
    val result = Await.result(valueFuture, 5 seconds)

    // Delete a value
    client.delete("key")
}