apache zeppelinプログラムテスト。 WebSocketを私が使用した場合、デフォルトのポートで8080</p> <p>を実行し、ツェッペリンに接続するために、スプリングwebsocetライブラリを使用しようとすると

Question

を呼び出します。

ClientWebSocketContainer container = new ClientWebSocketContainer(
      webSocketClient(), "ws://localhost:8080"); 

取得エラー：

にjava.io.IOException ：接続エラー をorg.eclipse.jetty.websocket.jsr356.ClientContainer.connect（ClientContainer.java:157）〜[javax-websocket-client-impl-9.2.14.v20151106.jar：9.2.14.v20151106] org.eclipse.jetty.websocket.jsでr356.ClientContainer.connectToServer（ClientContainer.java:180）〜[javax-websocket-client-impl-9.2.14.v20151106.jar：9.2.14.v20151106] at org.springframework.web.socket.client.standard。 StandardWebSocketClient $ 1.call（StandardWebSocketClient.java:152）〜[spring-websocket-4.2.3.RELEASE.jar：4.2.3.RELEASE] at org.springframework.web.socket.client.standard.StandardWebSocketClient $ 1.call（ （OpenTable.java:266）〜[na：1.8]。[SpringWebSocketClient.java:149]〜[spring-websocket-4.2.3.RELEASE.jar：4.2.3.RELEASE] のjava.util.concurrent.FutureTask.run 031] java.lang.Thread.run（Thread.java:745）[na：1.8.0_111] 原因：org.eclipse.jetty.websocket.api.UpgradeException：プロトコルを に変更しませんでした。 eclipse.jetty.websocket.client.io.UpgradeConnection.validateResponse（UpgradeConnection.java:314）〜[websocket-clie nt-9.2.14.v20151106.jar：9.2.14.v20151106] （org.eclipse.jetty.websocket.client.io.UpgradeConnection.read（UpgradeConnection.java:241）〜[websocket-client-9.2.14。 v20151106.jar：9.2.14.v20151106] org.eclipse.jetty.weで ...

私は（ドキュメントはWebSocketのポートで言う）8081に接続しよう：

java.net.ConnectException：接続が拒否されました sun.nio.ch.SocketChannelImpl.checkConnect（ネイティブメソッド）〜[na：1.8.0_111] at sun.nio.ch.SocketChannelImpl.finishConnect（SocketChannelImpl.java:717）〜 [na：1.8.0_111] at org.eclipse.jetty.io.Sel ectorManager.finishConnect（SelectorManager.java:340）〜[jetty-io-9.2.14.v20151106.jar：9.2.14.v20151106]

ブラウザでは、ノートブックを作成せずに8080に接続できます。

私たちのノートブックのテストケースを自動化して書きたいと思っています。

Answer 1

あなたのws URLが少し不正確であると思いますが、ws://localhost:8080/wsを試してみることができますか？

更新： Zeppelinコードベース自体にも同様の例があります。たとえば、hereは、ノートを取得する方法で、hereは、ws apiを介して送信される細工されたメッセージです。またthis classはソケットメッセージの構造を指しています。