从 Clojure 序列化反序列化的代码

Question

我正在关注http://patternhatch.com/2013/06/12/messaging-using-clojure-and-zeromq/这里的示例

我已经验证我可以序列化 MarketData 并为它构建了 protobuf。

我决定尝试我新学到的 protobuf 序列化知识，而不是使用 chesire 序列化。当我将该示例中的函数修改为它们的 gpb 版本时，当我运行

(future-call market-data-publisher-gpb)

好像没问题。但是，当我运行客户端时

(get-market-data-gpb 100)

什么都没有发生。我有两个问题：

1) Clojure 是否有某种图形或其他调试器？ 2）如果有人可以指出我在修改后的示例中做错了什么，那也将有所帮助。

我似乎记得通过带有 [protobuf] 二进制数据有效负载的 ZMQ 需要一组不同的调用？

(ns clj-zmq.core
  (:import [org.jeromq ZMQ])
)

(use 'flatland.protobuf.core)

(import com.example.Example$MarketData)
(def MarketData (protodef Example$MarketData))


(def ctx (ZMQ/context 1))

(defn market-data-publisher-gpb
[]
  (let [s (.socket ctx ZMQ/PUB)
        market-data-event (fn []
                            {:symbol (rand-nth ["CAT" "UTX"])
                             :size (rand-int 1000)
                             :price (format "%.2f" (rand 50.0))})]
    (.bind s "tcp://127.0.0.1:6666")
    (while :true
      (.send s ( protobuf-dump(market-data-event))))))

; Client
(defn get-market-data-gpb
  [num-events]
  (let [s (.socket ctx ZMQ/SUB)]
    (.subscribe s "")
    (.connect s "tcp://127.0.0.1:6666")
    (dotimes [_ num-events]
      (println (protobuf-load MarketData (.recv s))))
    (.close s)))

Answer 1

Eclipse 逆时针和 IntelliJ Cursive 都支持 Clojure 调试。

另外，您的地址看起来很糟糕 - 应该是“tcp://127.0.0.1:6666”。