如何在Clojure中使用WebSocket实现实时通讯

在Clojure中实现WebSocket通信通常需要使用一个库，比如http-kit或者aleph。以下是一个简单的示例：

(ns my-app.core
  (:require [aleph.http :as http]
            [aleph.ws :as ws]
            [clojure.core.async :as async]))

(defn handle-message [ws-channel message]
  (println "Received message:" message)
  (ws/send! ws-channel "Message received!"))

(defn start-websocket-server []
  (http/start-server
    (fn [request]
      (if (= "/ws" (:uri request))
        (ws/start-websocket {:on-receive (partial handle-message)} request)
        (http/response 404 {})))
    {:port 3000})
  (println "WebSocket server started on port 3000"))

(defn send-message [message]
  (let [ws-channel (async/chan)]
    (ws/connect! "ws://localhost:3000/ws" {:on-message #(async/put! ws-channel %)}
    (ws/send! ws-channel message)))

(start-websocket-server)

在这个示例中，我们首先定义了一个handle-message函数来处理接收到的消息。然后，我们启动了一个WebSocket服务器并监听端口3000。最后，我们定义了一个send-message函数来发送消息到WebSocket服务器。

要运行这个示例，你需要在项目的依赖中添加aleph库，然后运行(start-websocket-server)来启动WebSocket服务器。接着你可以调用(send-message “Hello”)来发送消息到服务器。