Программный тест apache zeppelin. WebSockets называет

Question

Попытка использовать родниковую библиотеку websocet для подключения к дирижабль, работающий на порту по умолчанию 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.js r356.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] at 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-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 ...

Когда я пытаюсь подключиться к 8081 (что документы говорят, является WebSocket порт):

java.net.ConnectException: Соединение отклонено at 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 указывает на структуру сообщения сокета.