tcp - 带 Aleph 的 Clojure TCP 服务器

Question

我正在尝试使用 Aleph 编写一个简单的 TCP 服务器。一切正常，除了我不确定应该如何检测 channel 何时关闭。

来自documentation :

When the client closes the connection, both sides of the channel will be immediately sealed. The final message from the channel will be nil

但是，我似乎从来没有收到过这个最终的 nil信息。如果我检查 channel ，我确实看到它已关闭。这是我的代码:

(use 'lamina.core 'aleph.tcp 'gloss.core)

(defn process-msg [ch msg]
  (if (closed? ch)
    (println "Channel has been closed") ;This never happens
    (do-some-processing msg)))

(start-tcp-server
  (fn [ch client-info]
    (receive-all ch
      (partial process-msg ch))
  {:port 10000, :frame (string :utf-8 :delimiters ["\n"])})

我应该做些不同的事情吗？我的框架是否阻止处理 nil 消息？我可以有一个单独的线程监视我的 channel 并检查它们是否已关闭，但这似乎是一个糟糕的设计。我更愿意使用 Aleph，但现在看起来我需要使用原始 Netty 处理程序。直接使用 Netty 会很好，但如果可能的话，我更愿意使用 Aleph，因为它感觉更加地道。

Answer 1

To register a callback for when a channel is closed or drained, use (on-closed ch callback) or (on-drained ch callback), which both take a callback with zero arguments.

https://github.com/ztellman/lamina/wiki/Channels