client_test.clj

(ns client-test
  (:use [lamina.core]
        [aleph.tcp]
        [aleph.netty.core]
        [gloss.core]
        [gloss.io])
  (:gen-class))
 
(def chopped-codec
  (finite-frame
   (prefix :int32)
   [:uuid :int32 (repeated (finite-frame (prefix :int16) (string :utf8)) :prefix :none)]))
 
(defn start-client []
  (let [client (tcp-client
                {:host "127.0.0.1" :port 9997 :encoder chopped-codec :decoder chopped-codec})]
    (receive-all @client (fn [msg] (println msg))
    client))
 
(defn -main []
  (let [client (start-client)]
   (enqueue @client (chopped-codec (encode chopped-codec [:uuid 199 ["first" "second"]))))

server_test.clj

(ns server-test
  (:use [lamina.core]
        [aleph.tcp]
        [aleph.netty.core]
        [gloss.core]
        [gloss.io]
       )
  (:gen-class))
 
(def chopped-codec
  (finite-frame
   (prefix :int32)
   [:uuid :int32 (repeated (finite-frame (prefix :int16) (string :utf8)) :prefix :none)]))
 
;; a simple echo server
(defn response-byte-buffer [msg] 
  msg)
 
(defn handler [ch client-info]
  "handler for incoming tcp messages"
  (siphon (map* response-byte-buffer ch) ch))
 
(defn start-server [] (start-tcp-server
                       handler
                       {:port 9997 :encoder chopped-codec :decoder chopped-codec}))
 
(defn -main []
  (start-server)
  (Thread/sleep 100000000))