Clojure WebSocketクライアント

Question

Webソケット接続を受け入れる必要があるhttp-kitを使用してWebSocketサーバーをセットアップしました。これは、http-kitのマニュアルに示されている基本的な例です。

質問があります： どのように接続するClojureクライアントを作成しますか？

クライアントにはClojureのhttpライブラリを使用できますが、私は気にしません。私はすでにJavascriptクライアントについて知っており、JavaにはClojureから使用できるAPIがあると私は信じています。しかし、私が探しているのは、ウェブサーバをサポートするClojureライブラリとクライアントとの両方のサーバです。私は、http-kitコードではそれが簡単になることは何も見なかった。

Answer 1

aleph、サーバーとクライアントの両方でWebSocketをサポートしています。非同期スタイルとAlephのコア抽象に慣れるまでには時間がかかるかもしれませんが、一度それを取得すれば非常に良いツールになります。

Answer 2

this announcementによれば、http-kitはWebソケットをサポートしています。 http-kitクライアントが提供する非同期機能に縛られていない場合は、clj-httpも使用できます。彼らは非常に似たインターフェイスを持っているようです（私はまだclj-httpを使っていますが）。

---

(ns playground.experiments.ws 
    (:use aleph.http lamina.core)) 

(defn ws-client [] (websocket-client {:url "ws://echo.websocket.org:80"})) 

(defn echo [message] 
    (let [channel (wait-for-result (ws-client) 500)] 
    (enqueue channel message) 
     (let [echo (wait-for-result (read-channel channel) 500)] 
     (close channel) 
     echo))) 

(echo "Echo me!") 

Answer 3

http-kitのクライアントはまだWebSocketをサポートしていません（私はそれに対して良いAPIはないと思います）。 Alephは、この種のユースケースの良い選択肢です。もう1つのオプションはhttp.async.clientです。httpキットのサーバーのWebSocketユニットテストで使用しました。here

Answer 4

はClojureのWebSocketクライアントです。それはJettyのプロトコルの実装を包みます。

Answer 5

基本的なwebsocketクライアントとサーバーを構築しました。javaソケットを使用してWebSocketフレームをラップします。これは、サーバが通常のソケット接続とウェブソケットの両方を同時に受け付けることができるという点でユニークです。

http://github.com/viperscape/gulfstream

例のクライアントコード：2015にご参加人のために

(def clienthandler 
    (with-conn server 
    (send! server "i'm here!") 
    (with-data server data (prn "client received" data)) 
    (prn "client is now disconnected"))) 

(def ws-conn-details {:host "ws://echo.websocket.org/chat",:handler clienthandler}) 

(def client-conn (start-client ws-conn-details)) 

Answer 6

：これに新しいものは、私はすべてのさまざまなオプションが利用可能に試してしばらく過ごし、それはかなり困難でした単純なClojure WebSocketクライアントを簡単に設定できるライブラリを見つけることができます。 （公平には、WebSocketクライアントが非ブラウザ/ JavaScriptのコンテキストで動作するのはあまり一般的ではないようで、Clojure スクリプト WebSocketクライアントに重点を置いているようです）

それはよく文書化されていませんが、http.async.clientは私にとっては抵抗が最も少ない経路になってしまいました。私は正常のWebSocketサーバからストリーミングデータを読み込み、これを行うことで、コンソールにそれを印刷することができました：

(ns example.core 
    (:require [http.async.client :as client])) 

(def url "ws://localhost:1337") 

(defn on-open [ws] 
    (println "Connected to WebSocket.")) 

(defn on-close [ws code reason] 
    (println "Connection to WebSocket closed.\n" 
      (format "(Code %s, reason: %s)" code reason))) 

(defn on-error [ws e] 
    (println "ERROR:" e)) 

(defn handle-message [ws msg] 
    (prn "got message:" msg)) 

(defn -main [] 
    (println "Connecting...") 
    (let [client (client/create-client) 
     ws (client/websocket client 
          url 
          :open on-open 
          :close on-close 
          :error on-error 
          :text handle-message 
          :byte handle-message)] 
    (loop [] (recur)))) 

終わりに無限ループがちょうど終了からプロセスを維持することです。 Ctrl-Cを押すまで、ソケットから受信したメッセージはSTDOUTに出力されます。