0

가 기본 포트에서 실행, 비행선에 연결하는 스프링 websocet 라이브러리를 사용하려고 전화 8080apache zeppelin 프로그램 테스트. WebSocket을은

내가 사용하는 경우 :

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의-웹 소켓 클라이언트 - IMPL - 9.2.14.v20151106.jar : 9.2.14.v20151106] org.springframework.web.socket.client.standard에서 . StandardWebSocketClient $ 1.call (StandardWebSocketClient.java:152) ~ [스프링 웹 소켓 - 4.2.3.RELEASE.jar : 4.2.3.RELEASE] org.springframework.web.socket.client.standard.StandardWebSocketClient $ 1.call에서 (StandardWebSocketClient.java:149) ~ [스프링 웹 소켓 - 4.2.3.RELEASE.jar : 4.2.3.RELEASE] java.util.concurrent.FutureTask.run (FutureTask.java:266에서 ) ~ [NA : 1.8. 031] java.lang.Thread.run (Thread.java:745) [없음 : 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) ~ [웹 소켓 - 클라이언트 9.2.14. v20151106.jar :

:

내가 8081에 연결을 시도 (어떤 문서가 말하는 것은 웹 소켓 포트입니다) org.eclipse.jetty.we에서 9.2.14.v20151106] ... 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에 연결할 수 있으며 노트북을 만들 수 없습니다.

자동화하고 노트북을위한 테스트 케이스를 쓰고 싶어요.

답변

1

난 당신이 ws://localhost:8080/ws으로 시도 할 수, 당신의 WS URL이 조금 잘못된 것 같다?

업데이트 : Zeppelin 코드베이스 자체에 비슷한 예가 있습니다. 예를 들어, here은 노트를 얻는 방법이고 here은 ws api를 통해 전송 된 조작 된 메시지입니다. 또한 this class은 소켓 메시지의 구조를 가리 킵니다.

+0

도움을 주었지만 여전히 노트북을 나열 할 수 없었습니다. 그러나 그것의 시작. github이나 다른 오픈 소스에 샘플을 가지고 있습니까? – tgkprog

+1

Zeppelin 코드베이스 자체에도 비슷한 예가 있습니다. 예를 들어 [여기] (https://github.com/apache/zeppelin/blob/master/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/repo/zeppelinhub/websocket/ZeppelinClient.java# L225) 메모를 얻는 방법과 [여기] (https://github.com/apache/zeppelin/blob/master/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/repo/zeppelinhub/ websocket/ZeppelinClient.java # L225)는 ws api를 통해 전송 된 조작 된 메시지입니다. –

+0

편집하여 답변에 댓글을 포함시킬 수 있습니까? 다른 사람들을 도울 수 있습니다. 그 코드를 – tgkprog

관련 문제