How to tell a web socket client to use SSL?

[Colm Dickson]

Hi all.

I have been trying to find out exactly how I can set up a configurator instance to tell the client end point that I wish to connect using SSL.

I think I have to set the properties with a Map of type String, ArrayList<String> but I am struggling knowing what exactly to pass when it comes to SSL.


Does anyone know or have an example of this?

Thanks,

C.

[Stephan van Hulst]

Well, we can't really help you unless we know what you're using to setup websockets.

Can you show us some of your code so far?

[Colm Dickson]

Hi .

Thanks for replying. I have included some of my test class below as a sample.

I can connect to a local websocket running on my machine using thsi test class (and replacing the URI of course) but I have a requirement to connect to another websocket which requires SSL.
I don't know what I have to do in order to do this so I only have my attempt below in the "this.config= section". I don't know what approach to take using the standard javax.websocket api. I hope someone can point me in the right direction.

Thanks.
C

import com.mycom.websockets.client.HelloEndpoint;
import com.mycom.websockets.client.HelloEndpointConfigurator;
import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
import java.security.NoSuchAlgorithmException;
import java.util.Map;
import java.util.Set;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.net.ssl.SSLContext;


import javax.websocket.ClientEndpointConfig;
import javax.websocket.ContainerProvider;
import javax.websocket.DeploymentException;
import javax.websocket.WebSocketContainer;


import org.junit.After;
import org.junit.AfterClass;
import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;


public class SocketsSmokeTest 
{
    WebSocketContainer container;
    private HelloEndpoint endpoint;
    private ClientEndpointConfig config;
    private SSLContext sslContext;


     public SocketsTest() {
        
        try 
         {
           sslContext = SSLContext.getInstance("SSL");
           System.out.println("Protocol = " + sslContext.getProtocol());
         } 
         catch (NoSuchAlgorithmException ex) 
         {
           Logger.getLogger(HelloEndpointConfigurator.class.getName()).log(Level.SEVERE, null, ex);
         }      
    }
    
    
    @Before
    //note noSuchAlgorithm is due to SSLContext.getInstance()
    public void setUp() throws NoSuchAlgorithmException 
    {
        this.container  = ContainerProvider.getWebSocketContainer();
        this.endpoint = new HelloEndpoint();

 
       System.out.println("setting up config");
   

        this.config = (ClientEndpointConfig) ClientEndpointConfig.Builder.create().configurator(new HelloEndpointConfigurator()).build().getUserProperties().put("org.apache.websocket.SSL_CONTEXT", sslContext);
       
       
        System.out.println("config setup complete");
         
        
    }
    

 
    @Test
    public void connectToServer() throws DeploymentException, URISyntaxException, IOException
    {
      System.out.println("Now try to connect to server");
      this.container.connectToServer(this.endpoint, this.config,  new URI("wss://xxxxxxxxxxxxxxxx")); 
      System.out.println("Now try to send message");
      this.endpoint.sendMessage("Hello from client");
    }
}