用aleph处理websocket客户端消息

Question

在我寻求学习Clojure的过程中，我目前面临着建立websocket通信的问题。经过许多不同的方法之后，我最终使用了阿列弗。

我所取得的成就：

• 新客户端连接的处理
• 处理客户端断开连接
• 随心所欲地从服务器到客户端交谈

我所缺少的是，每当一个连接的客户端通过websocket发送一些东西时，就可以触发一个处理程序函数。

到目前为止我的代码是：

(ns wonders7.core.handler
  (:require [compojure.core :refer :all]
            [compojure.route :as route]
            [ring.middleware.defaults :refer [wrap-defaults site-defaults]]
            [aleph.http :as http]
            [manifold.stream :as stream]
            [clojure.tools.logging :refer [info]]))

(defn uuid [] (str (java.util.UUID/randomUUID)))

(def clients (atom {}))

(defn ws-create-handler [req]
  (let [ws @(http/websocket-connection req)]
    (info "ws-create-handler")
    (stream/on-closed ws #(swap! clients dissoc ws))
    (swap! clients assoc ws (uuid))))

(defroutes app-routes
  (GET "/ws" [] ws-create-handler)
  (route/not-found "Not Found"))

(def app
  (wrap-defaults app-routes site-defaults))

(defn msg-to-client [[client-stream uuid]]
  (stream/put! client-stream "The server side says hello!"))

(defn msg-broadcast []
  (map #(msg-to-client %) @clients))

;(stream/take! (first (first @clients)))
;(http/start-server app {:port 8080})

我使用注释掉的http/ start -server aleph调用启动Netty服务器。我还设法通过手动流/抓取从客户端获取消息！呼叫(也评论掉)。我需要弄清楚的是，当有什么东西进来的时候，如何自动触发它。

提前感谢您的帮助！

Answer 1

您要寻找的函数是(manifold.stream/consume callback stream)，它将为流中的每个消息调用回调。

Answer 2

在这个例子中，作者使用来自aleph的recieve-all和siphon来完成一个非常类似的任务，我将大致解释为：

(let [chat (named-channel room (receive-all ch #(println "message: " %)))]
  (siphon chat ch)