微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

janus-gateway:java.lang.IllegalStateException:子流源不能实现一次以上

如何解决janus-gateway:java.lang.IllegalStateException:子流源不能实现一次以上

我正在使用janus网关,当我从浏览器中命中时,其路由工作正常

http://192.168.1.4:8088/janus/info

但是代码抛出异常 这是我的代码

val responseFuture: Future[HttpResponse] = Http().singleRequest(HttpRequest(uri = "http://192.168.1.4:8088/janus/info"))
    
  responseFuture
      .onComplete {
        case Success(res) => println("we got http response" + res)
          log.info("get session id response " + Unmarshal(res).to[String])
          val strjson = Unmarshal(res).to[String]
        case Failure(e: Exception) => log.error("something wrong",e)
      }
  }

这是我得到的例外情况

[info] Running janusgateway.rest.GetStartedWithJanus 
18:13:21.169 734 [default-akka.actor.default-dispatcher-4] Slf4jLogger INFO - Slf4jLogger started
we got http responseHttpResponse(200 OK,List(Connection: Keep-Alive,Access-Control-Max-Age: 86400,Access-Control-Allow-Origin: *,Date: Wed,02 Sep 2020 13:13:22 GMT),httpentity.Chunked(application/json),HttpProtocol(HTTP/1.1))
18:13:22.451 2016 [default-akka.actor.default-dispatcher-5] GetStartedWithJanus$ INFO - get session id response Future(<not completed>)
java.lang.IllegalStateException: Substream Source cannot be materialized more than once
    at akka.stream.impl.fusing.SubSource$$anon$13.setCB(StreamOfStreams.scala:792)
    at akka.stream.impl.fusing.SubSource$$anon$13.preStart(StreamOfStreams.scala:802)
    at akka.stream.impl.fusing.GraphInterpreter.init(GraphInterpreter.scala:306)
    at akka.stream.impl.fusing.GraphInterpreterShell.init(ActorgraphInterpreter.scala:593)
    at akka.stream.impl.fusing.ActorgraphInterpreter.tryInit(ActorgraphInterpreter.scala:701)
    at akka.stream.impl.fusing.ActorgraphInterpreter.preStart(ActorgraphInterpreter.scala:750)
    at akka.actor.Actor.aroundPreStart(Actor.scala:545)
    at akka.actor.Actor.aroundPreStart$(Actor.scala:545)
    at akka.stream.impl.fusing.ActorgraphInterpreter.aroundPreStart(ActorgraphInterpreter.scala:690)
    at akka.actor.ActorCell.create(ActorCell.scala:637)
    at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:509)
    at akka.actor.ActorCell.systemInvoke(ActorCell.scala:531)
    at akka.dispatch.MailBox.processAllSystemMessages(MailBox.scala:294)
    at akka.dispatch.MailBox.run(MailBox.scala:229)
    at akka.dispatch.MailBox.exec(MailBox.scala:242)
    at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
    at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
    at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
    at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
    at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:177)

我在本地计算机上部署了janus,并且我是一个初学者,上面的异常似乎janus没有响应请求

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。