如何在Clojure中使用WebSocket實(shí)現(xiàn)實(shí)時(shí)通訊

在Clojure中實(shí)現(xiàn)WebSocket通信通常需要使用一個(gè)庫，比如http-kit或者aleph。以下是一個(gè)簡單的示例：

(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)

在這個(gè)示例中，我們首先定義了一個(gè)handle-message函數(shù)來處理接收到的消息。然后，我們啟動了一個(gè)WebSocket服務(wù)器并監(jiān)聽端口3000。最后，我們定義了一個(gè)send-message函數(shù)來發(fā)送消息到WebSocket服務(wù)器。

要運(yùn)行這個(gè)示例，你需要在項(xiàng)目的依賴中添加aleph庫，然后運(yùn)行(start-websocket-server)來啟動WebSocket服務(wù)器。接著你可以調(diào)用(send-message “Hello”)來發(fā)送消息到服務(wù)器。