1. 首頁
  2. 問答
  3. Jetty WebSocketClientSelectorManager - 連接失敗java.io.IOException：無法初始化SSL

Jetty WebSocketClientSelectorManager - 連接失敗java.io.IOException：無法初始化SSL

2015-04-20 50 views
3

我爲所有的代碼道歉，但我很困惑爲什麼這個代碼似乎以前似乎工作，但現在不是。Jetty WebSocketClientSelectorManager - 連接失敗java.io.IOException：無法初始化SSL

我有一個簡單的碼頭WebSockets客戶端，我得到的標題錯誤。關於這一點有趣的是我有一個HTML文件與JavaScript來行使相同的SSL服務器，它工作正常。

互聯網搜索沒有發現太多，因爲它涉及到這個錯誤。

根據碼頭的源代碼，沒有SSL上下文：

 if ("wss".equalsIgnoreCase(scheme)) 
     { 
      // Encrypted "wss://" 
      SslContextFactory sslContextFactory = getSslContextFactory(); 
      if (sslContextFactory != null) 
      { 
       SSLEngine engine = newSSLEngine(sslContextFactory,channel); 
       SslConnection sslConnection = new SslConnection(bufferPool,getExecutor(),endPoint,engine); 
       sslConnection.setRenegotiationAllowed(sslContextFactory.isRenegotiationAllowed()); 
       EndPoint sslEndPoint = sslConnection.getDecryptedEndPoint(); 

       Connection connection = newUpgradeConnection(channel,sslEndPoint,connectPromise); 
       sslEndPoint.setIdleTimeout(connectPromise.getClient().getMaxIdleTimeout()); 
       sslEndPoint.setConnection(connection); 
       return sslConnection; 
      } 
      else 
      { 
       throw new IOException("Cannot init SSL"); 
      } 
     } 
     else 
     { 
      // Standard "ws://" 
      endPoint.setIdleTimeout(connectPromise.getDriver().getPolicy().getIdleTimeout()); 
      return newUpgradeConnection(channel,endPoint,connectPromise); 
     }

下面是執行運行中的回溯：

20:32:15.560 [main] INFO c.d.e.w.EspClientMain - client connected, waiting for close 
20:32:15.626 [[email protected]] DEBUG o.e.j.i.SelectorManager - Queued change [email protected]3d828 
20:32:15.627 [[email protected][email protected]/0] DEBUG o.e.j.i.SelectorManager - Selector loop woken up from select, 0/0 selected 
20:32:15.628 [[email protected][email protected]/0] DEBUG o.e.j.i.SelectorManager - Running change [email protected]3d828 
20:32:15.629 [[email protected][email protected]/0] DEBUG o.e.j.i.SelectorManager - Selector loop waiting on select 
20:32:15.630 [[email protected][email protected]/0] DEBUG o.e.j.i.SelectorManager - Selector loop woken up from select, 1/1 selected 
20:32:15.636 [[email protected][email protected]/0] DEBUG o.e.j.w.c.i.WebSocketClientSelectorManager - newEndPoint(java.nio.channels.SocketChannel[connected local=/10.214.156.230:39311 remote=node.dj2.dfdev.biz/10.214.156.230:8443], [email protected] keys=1 selected=1, [email protected]) 
20:32:15.648 [[email protected][email protected]/0] DEBUG o.e.j.i.AbstractEndPoint - onOpen [email protected]{node.dj2.dfdev.biz/10.214.156.230:8443<->39311,Open,in,out,-,-,300000,null}{io=0,kio=0,kro=8} 
20:32:15.648 [[email protected][email protected]/0] DEBUG o.e.j.i.IdleTimeout - [email protected]{node.dj2.dfdev.biz/10.214.156.230:8443<->39311,Open,in,out,-,-,300000,null}{io=0,kio=0,kro=8} idle timeout check, elapsed: 6 ms, remaining: 299994 ms 
20:32:15.649 [[email protected][email protected]/0] DEBUG o.e.j.w.c.i.WebSocketClientSelectorManager - newConnection(java.nio.channels.SocketChannel[connected local=/10.214.156.230:39311 remote=node.dj2.dfdev.biz/10.214.156.230:8443],[email protected]{node.dj2.dfdev.biz/10.214.156.230:8443<->39311,Open,in,out,-,-,300000,null}{io=0,kio=0,kro=8},[email protected]{false,false,null}) 
20:32:15.654 [[email protected][email protected]/0] INFO c.d.e.w.EspClientMain$EspClient - unexpected websockets exception: {} 
java.io.IOException: Cannot init SSL 
    at org.eclipse.jetty.websocket.client.io.WebSocketClientSelectorManager.newConnection(WebSocketClientSelectorManager.java:96) ~[datafascia-emerge-websocket-esp-client-1.0-SNAPSHOT.jar:na] 
    at org.eclipse.jetty.io.SelectorManager$ManagedSelector.createEndPoint(SelectorManager.java:735) [datafascia-emerge-websocket-esp-client-1.0-SNAPSHOT.jar:na] 
    at org.eclipse.jetty.io.SelectorManager$ManagedSelector.processConnect(SelectorManager.java:676) [datafascia-emerge-websocket-esp-client-1.0-SNAPSHOT.jar:na] 
    at org.eclipse.jetty.io.SelectorManager$ManagedSelector.processKey(SelectorManager.java:640) [datafascia-emerge-websocket-esp-client-1.0-SNAPSHOT.jar:na] 
    at org.eclipse.jetty.io.SelectorManager$ManagedSelector.select(SelectorManager.java:607) [datafascia-emerge-websocket-esp-client-1.0-SNAPSHOT.jar:na] 
    at org.eclipse.jetty.io.SelectorManager$ManagedSelector.run(SelectorManager.java:545) [datafascia-emerge-websocket-esp-client-1.0-SNAPSHOT.jar:na] 
    at org.eclipse.jetty.util.thread.NonBlockingThread.run(NonBlockingThread.java:52) [datafascia-emerge-websocket-esp-client-1.0-SNAPSHOT.jar:na] 
    at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:620) [datafascia-emerge-websocket-esp-client-1.0-SNAPSHOT.jar:na] 
    at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:540) [datafascia-emerge-websocket-esp-client-1.0-SNAPSHOT.jar:na] 
    at java.lang.Thread.run(Thread.java:745) [na:1.7.0_71]

我創建的連接源是非常簡單，似乎遵循的例子：

// Run forever and recover lost server connections 
while (true) { 
    WebSocketClient client = new WebSocketClient(); 
    EspClient socket = new EspClient(); 
    try { 
    logger.info("starting client"); 
    client.start(); 
    logger.info("client started"); 
    URI espServerURI = new URI(espURI); 
    logger.info("requesting WebSockets upgrade"); 
    ClientUpgradeRequest request = new ClientUpgradeRequest(); 
    logger.info("WebSockets upgrade complete, connecting"); 
    client.connect(socket, espServerURI, request); 
    logger.info("client connected, waiting for close"); 

    try { 
     socket.awaitClose(); 
    } catch (InterruptedException e) { 
     logger.error("sleep interrupted ...", e); 
    } 
    } catch (Throwable t) { 
    logger.error("could not connect to {}: {}", espURI, t); 
    try { 
     Thread.sleep((long)(10 * DateTimeConstants.MILLIS_PER_SECOND)); 
    } catch (Exception e) { 
     logger.error("sleep interrupted ...", e); 
    } 
    } finally { 
    try { 
     logger.error("unexpected ESP Server termination. Retrying connection: {}", espURI); 
     client.stop(); 
     Thread.sleep((long)(10 * DateTimeConstants.MILLIS_PER_SECOND)); 
    } catch (Exception e) { 
     logger.error("exception stopping the ESP client: {}", e); 
    } 
    } 
}

客戶端類是花園品種：

 /** 
     * The Emerge ESP WebSockets Client 
     */ 
     public static class EspClient extends WebSocketAdapter { 
    private Logger logger = LoggerFactory.getLogger(EspClient.class); 
    private final String pingMessage = "I am still here"; 
    private final ByteBuffer pingBuffer = ByteBuffer.wrap(pingMessage.getBytes()); 

    private final CountDownLatch closeLatch; 

    // Setup the JMS queues 
    private static AbstractApplicationContext context = 
     new ClassPathXmlApplicationContext("applicationContext.xml"); 
    private static JmsConnector jmsEspConnection = 
     (JmsConnector) context.getBean("JmsEspMessageBean"); 

    /** 
    * Setup the synchronization 
    */ 
    public EspClient() { 
     this.closeLatch = new CountDownLatch(1); 
    } 

    /** 
    * Synchronizes on the countdown latch. 
    */ 
    public void awaitClose() throws InterruptedException { 
     this.closeLatch.await(); 
    } 

    @Override 
    public void onWebSocketClose(int statusCode, String reason) { 
     logger.error("ESP Server session closed: {}, {}", statusCode, reason); 
     espSession = null; 
     this.closeLatch.countDown(); 
    } 

    @Override 
    public void onWebSocketConnect(Session session) { 
     logger.info("Connected: {}", session); 
     espSession = session; 
     readAndSendMessage(); 
    } 

    @Override 
    public void onWebSocketError(Throwable cause) { 
     logger.info("unexpected websockets exception: {}", cause); 
     espSession = null; 
    } 

    @Override 
    public void onWebSocketBinary(byte[] payload, int offset, int len) { 
     logger.info("unexpected binary message received"); 
    } 

    @Override 
    public void onWebSocketText(String message) { 
     if (message != null) { 
     logger.info("received ESP Server response: {}", message); 
     } 
    } 
    /** 
    * Reads a message from the ESP queue and sends it to the ESP server. 
    */ 
    private void readAndSendMessage() { 
     while (espSession != null) { 
     String message = jmsEspConnection.receiveTextMessage((long)(4 * DateTimeConstants.MILLIS_PER_MINUTE)); 
     if (message != null) { 
      logger.info("read message: {}", message); 
      sendMessage(message); 
     } else { 
      logger.info("no message available, sending keepalive message"); 
      try { 
      espSession.getRemote().sendPing(pingBuffer); 
      } catch (IOException e) { 
      logger.error("error sending keepalive message to ESP Server: {}", e); 
      } 
     } 
     } 
     logger.error("ESP Server connection lost"); 
    } 

    /** 
    * Sends a message to the ESP server. 
    */ 
    private void sendMessage(String message) { 
     if (espSession != null) { 
     try { 
      espSession.getRemote().sendString(message); 
     } catch (Exception e) { 
      logger.error("error sending sensor message to ESP Server: {}", e); 
      espSession = null; 
     } 
     } 
    } 
    }

來源

2015-04-20 John Edwards

回答

12

您需要在構造函數中提供SslContextFactory。

又名：

SslContextFactory ssl = new SslContextFactory(); 
// Configure ssl for your client here, such as 
// what ciphers and protocols are available, 
// what client certificates to use, 
// what CA's you want to validate against, 
// what your blacklist behavior is, 
// your truststore location and access, 
// your keystore location and access, 
// caching, CRL, OCSP, renegotiation, etc ... 

WebSocketClient client = new WebSocketClient(ssl);

來源

2015-04-20 22:10:10

+0

謝謝！添加SSL上下文後，我能夠處理超過20K的等待消息。我的HTML測試中的JavaScript如何在沒有SSL上下文的情況下工作？它是內置到JavaScript？你可以告訴我這是新的。 –

+0

非常感謝！ – vikingsteve

相關問題

 相關問題