3

単純なサーバーとクライアント HTTP を作成するためにHTTP-KITを使用しています。そして今、光沢を使用してエンコードされたデータを送信したいと思います。

私のグロスコードは次のようなものです:

(gcore/defcodec sized-string (gcore/finite-frame :uint16-be
                                     (gcore/string :utf-8)))

(gcore/defcodec ordered-map-codec 
          (gcore/ordered-map :msg sized-string
                             :type sized-string))

このコードはうまく機能します:

(def data {:msg "Hello World", :type "alert"})

(def encoded
  (gio/encode ordered-map-codec data))

(gio/decode ordered-map-codec encoded)

私のサーバー/クライアント HTTP コードには、次のものがあります。

サーバーの場合:

(defonce server (atom nil))

(defn handler [request]
  (println (gio/decode ordered-map-codec (get request :body ))))

(defn -main
  []
  (reset! server (run-server handler  {:port 8080})))

クライアントの場合:

(def options {:timeout 200
              :body (gio/encode ordered-map-codec data)})

(http/post "http://localhost:8080" options
          (fn [{:keys [status headers body error]}] 
            (if error
              (println "Failed, exception is " error)
              (println "Async HTTP GET: " status))))

次に、クライアントを使用していくつかを送信しようとするとdata:

Sat Apr 18 11:24:24 BRT 2015 [worker-3] ERROR - GET /
java.lang.Exception: Insufficient bytes to decode frame.
    at gloss.io$decode.invoke(io.clj:85)
    at gloss.io$decode.invoke(io.clj:79)
    at tapahtuma_server.server$handler.invoke(server.clj:35)
    at org.httpkit.server.HttpHandler.run(RingHandler.java:91)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Async HTTP GET:  500

ここで助けてくれてありがとう

4

0 に答える 0