Aleph, redis, compojure

core.clj

(ns cms.core
  (:use [clojure [pprint :only [pprint]]]
        [compojure core]
        [ring.adapter jetty]
        [ring.middleware reload stacktrace]
        [hiccup core page-helpers]
        [clojure.contrib json]
        [aleph redis]
        [lamina core])
  (:require [compojure [route :as route]])
  (:import [java.net URI]))

(def *server-port*)
(def env (System/getenv))

(def default-redis-config
  "redis://edw:XXXXPASSWORDXXXX@icefish.redistogo.com:9220/")
(def redis-uri (URI. (or (get env "REDISTOGO_URL") default-redis-config)))

(defn redis-uri-to-options [uri]
  (let [host (.getHost uri)
        port (.getPort uri)
        user-pass (.getUserInfo uri)
        pass (and user-pass (last (clojure.string/split user-pass #":")))
        options {:host host}]
    (merge {:host host}
           (if (> port 0) {:port port} {})
           (if pass {:password pass}))))

(def redis (redis-client (redis-uri-to-options redis-uri)))

(defn- text-response [s]
  {:status 200 :headers {"Content-type" "text/plain;charset=utf-8"} :body s})

(defroutes main-routes
  (GET "/REDIS_KEYS" []
       (text-response (with-out-str (pprint @(redis [:keys "*"])))))
  (GET "/REDIS/:key" [key]
       (text-response (with-out-str
                        (pprint {(keyword key) @(redis [:get key])}))))
  ;; Not found
  (HEAD "*" [] {:status 404})
  (ANY "*" [] {:status 404 :headers {"Content-type" "text/html"}
               :body "<h1>404 Error: Not found</h1>"}))

(defn app [] (-> main-routes (wrap-reload '(cms.core)) (wrap-stacktrace)))

(defn start-server 
  "Returns a started server. Use (.stop *1) to stop it."
  [] (run-jetty (app) {:port *server-port*}))

(defn -main []
  (let [env (System/getenv)]
    (binding [*server-port* (Integer/parseInt (get env "PORT" "8080"))]
      (start-server))))

On executing /REDIS/foo repeatedly:

Jul 6, 2011 1:36:36 PM clojure.contrib.logging$impl_write_BANG_ invoke
SEVERE: java.io.IOException: Connection reset by peer
java.io.IOException: Connection reset by peer
   at sun.nio.ch.FileDispatcher.read0(Native Method)
   at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:21)
   at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:237)
   at sun.nio.ch.IOUtil.read(IOUtil.java:204)
   at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:236)
   at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:321)
   at org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:280)
   at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:200)
   at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
   at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
   at java.lang.Thread.run(Thread.java:662)
java.io.IOException: Connection reset by peer
   at sun.nio.ch.FileDispatcher.read0(Native Method)
   at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:21)
   at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:237)
   at sun.nio.ch.IOUtil.read(IOUtil.java:204)
   at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:236)
   at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:321)
   at org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:280)
   at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:200)
   at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
   at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
   at java.lang.Thread.run(Thread.java:662)