向 websocket 发送消息时地址已被使用

Address already in use when sending message to websocket

我正在使用 manifold.stream 库通过 websocket 发送消息:

(defn send []
    (manifold.stream/put! mysocket
         (generate-string
          {:type "unsubscribe"
           :product_ids ["ETH-USD"]
           :channels ["heartbeat"]})))

和 运行 (send) 在 repl 作品中。 但是,当我从客户端发出 http 请求并将发送函数作为我的 reitit 路由的处理程序时,我收到错误消息:

Syntax error macroexpanding at (home.clj:142:3).
    at clojure.lang.Compiler$InvokeExpr.eval(Compiler.java:3711)
    at clojure.lang.Compiler$DefExpr.eval(Compiler.java:457)
    at clojure.lang.Compiler.eval(Compiler.java:7186)
    at clojure.lang.Compiler.load(Compiler.java:7640)
    at clojure.lang.RT.loadResourceScript(RT.java:381)
    at clojure.lang.RT.loadResourceScript(RT.java:372)
    at clojure.lang.RT.load(RT.java:459)
    at clojure.lang.RT.load(RT.java:424)
    at clojure.core$load$fn__6856.invoke(core.clj:6115)
    at clojure.core$load.invokeStatic(core.clj:6114)
    at clojure.core$load.doInvoke(core.clj:6098)
    at clojure.lang.RestFn.invoke(RestFn.java:408)
    at clojure.core$load_one.invokeStatic(core.clj:5897)
    at clojure.core$load_one.invoke(core.clj:5892)
    at clojure.core$load_lib$fn__6796.invoke(core.clj:5937)
    at clojure.core$load_lib.invokeStatic(core.clj:5936)
    at clojure.core$load_lib.doInvoke(core.clj:5917)
    at clojure.lang.RestFn.applyTo(RestFn.java:142)
    at clojure.core$apply.invokeStatic(core.clj:669)
    at clojure.core$load_libs.invokeStatic(core.clj:5974)
    at clojure.core$load_libs.doInvoke(core.clj:5958)
    at clojure.lang.RestFn.applyTo(RestFn.java:137)
    at clojure.core$apply.invokeStatic(core.clj:669)
    at clojure.core$require.invokeStatic(core.clj:5996)
    at clojure.core$require.doInvoke(core.clj:5996)
    at clojure.lang.RestFn.invoke(RestFn.java:421)
    at ring.middleware.reload$reloader$fn__4434.invoke(reload.clj:17)
    at ring.middleware.reload$wrap_reload$fn__4446.invoke(reload.clj:38)
    at selmer.middleware$wrap_error_page$fn__4461.invoke(middleware.clj:18)
    at prone.middleware$wrap_exceptions$fn__4702.invoke(middleware.clj:159)
    at ring.middleware.flash$wrap_flash$fn__8513.invoke(flash.clj:39)
    at ring.middleware.session$wrap_session$fn__8872.invoke(session.clj:108)
    at ring.middleware.keyword_params$wrap_keyword_params$fn__8918.invoke(keyword_params.clj:53)
    at ring.middleware.nested_params$wrap_nested_params$fn__8976.invoke(nested_params.clj:89)
    at ring.middleware.multipart_params$wrap_multipart_params$fn__9108.invoke(multipart_params.clj:171)
    at ring.middleware.params$wrap_params$fn__9132.invoke(params.clj:67)
    at ring.middleware.cookies$wrap_cookies$fn__8823.invoke(cookies.clj:214)
    at ring.middleware.absolute_redirects$wrap_absolute_redirects$fn__9320.invoke(absolute_redirects.clj:47)
    at ring.middleware.resource$wrap_resource_prefer_resources$fn__9168.invoke(resource.clj:25)
    at ring.middleware.content_type$wrap_content_type$fn__9268.invoke(content_type.clj:34)
    at ring.middleware.default_charset$wrap_default_charset$fn__9292.invoke(default_charset.clj:31)
    at ring.middleware.not_modified$wrap_not_modified$fn__9234.invoke(not_modified.clj:61)
    at ring.middleware.x_headers$wrap_x_header$fn__8476.invoke(x_headers.clj:22)
    at ring.middleware.x_headers$wrap_x_header$fn__8476.invoke(x_headers.clj:22)
    at ring.middleware.x_headers$wrap_x_header$fn__8476.invoke(x_headers.clj:22)
    at hedgehog_interview.middleware$wrap_internal_error$fn__9394.invoke(middleware.clj:17)
    at aleph.http.server$handle_request$fn__15012$f__9755__auto____15013.invoke(server.clj:158)
    at clojure.lang.AFn.run(AFn.java:22)
    at io.aleph.dirigiste.Executor$Worker.run(Executor.java:62)
    at manifold.executor$thread_factory$reify__9637$f__9638.invoke(executor.clj:44)
    at clojure.lang.AFn.run(AFn.java:22)
    at java.lang.Thread.run(Thread.java:748)
Caused by: java.net.BindException: Address already in use
    at sun.nio.ch.Net.bind0(Native Method)
    at sun.nio.ch.Net.bind(Net.java:433)
    at sun.nio.ch.Net.bind(Net.java:425)
    at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:223)
    at io.netty.channel.socket.nio.NioServerSocketChannel.doBind(NioServerSocketChannel.java:128)
    at io.netty.channel.AbstractChannel$AbstractUnsafe.bind(AbstractChannel.java:558)
    at io.netty.channel.DefaultChannelPipeline$HeadContext.bind(DefaultChannelPipeline.java:1358)
    at io.netty.channel.AbstractChannelHandlerContext.invokeBind(AbstractChannelHandlerContext.java:501)
    at io.netty.channel.AbstractChannelHandlerContext.bind(AbstractChannelHandlerContext.java:486)
    at io.netty.channel.DefaultChannelPipeline.bind(DefaultChannelPipeline.java:1019)
    at io.netty.channel.AbstractChannel.bind(AbstractChannel.java:254)
    at io.netty.bootstrap.AbstractBootstrap.run(AbstractBootstrap.java:366)
    at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
    at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:465)
    at io.netty.util.concurrent.SingleThreadEventExecutor.run(SingleThreadEventExecutor.java:884)
    at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
    ... 1 more

第142行指的是,:

(def server
  (aleph.http/start-server server-handler {:port 8992}))

为什么我得到的地址已在使用中?

只有您才能回答您的问题。该错误意味着已经有一个进程正在该端口上列出。如果您正在 运行 宁一个 Linux 框,请使用 lsof -i(作为 root 或使用 sudo)找出哪个进程。

最有可能的情况是您已经 运行 您的代码。也就是说,您会发现 Clojure 进程仍在使用该端口。当您忘记在再次执行 start-server 之前停止服务器时,这又很容易发生。根据 Aleph documentation on start-server,您需要在 server var.

上调用 .close

您的源文件定义了一个值为服务器的顶级变量。要定义该变量,它必须启动绑定到指定端口的服务器。您的 wrap-reload 中间件会根据每个请求重新加载应用程序,这意味着它必须重新定义变量,这意味着它会尝试将新服务器绑定到同一端口。

您需要以不那么脆弱的方式定义您的服务器(例如,使用 defonce 以避免在重新加载时重新定义),或者更受控制(例如,改为在 -main 中显式启动它加载命名空间时隐式的)。