apache zeppelin 编程测试。 Websockets 调用

Question

尝试使用spring websocet库连接zeppelin，默认端口8080运行。

当我使用时：

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.jsr356.ClientContainer.connectToServer(ClientContainer.java:180) ~[javax-websocket-client-impl-9.2.14.v20151106.jar:9.2.14.v20151106] 在 org.springframework.web.socket.client.standard.StandardWebSocketClient$1.call(StandardWebSocketClient.java:152) ~[spring-websocket-4.2.3.RELEASE.jar:4.2.3.RELEASE] 在 org.springframework.web.socket.client.standard.StandardWebSocketClient$1.call(StandardWebSocketClient.java:149) ~[spring-websocket-4.2.3.RELEASE.jar:4.2.3.RELEASE] 在 java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[na:1.8.0_111] 在 java.lang.Thread.run(Thread.java:745) [na:1.8.0_111] 引起：org.eclipse.jetty.websocket.api.UpgradeException：没有切换协议 在 org.eclipse.jetty.websocket.client.io.UpgradeConnection.validateResponse(UpgradeConnection.java:314) ~[websocket-client-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...

当我尝试连接到 8081（文档说的是 websocket 端口）时：

java.net.ConnectException：连接被拒绝 在 sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.8.0_111] 在 sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) ~[na:1.8.0_111] 在 org.eclipse.jetty.io.SelectorManager.finishConnect(SelectorManager.java:340) ~[jetty-io-9.2.14.v20151106.jar:9.2.14.v20151106]

在浏览器上我可以连接到 8080 而不是做笔记本。

想要为我们的笔记本自动化和编写测试用例。

Answer 1

我猜你的 ws 网址格式有点错误，你可以试试ws://localhost:8080/ws吗？

更新： Zeppelin 代码库本身也有类似的示例，例如获取注释。比如here是获取note的方法，here是通过ws api发送的精心制作的消息。 this class 也指向套接字消息的结构。