ReconnectClientExample does not work with wss

[AlexisBrito]

If I merge the SSLClientExample.java and ReconnectClientExample.java, the program will end after it closes the connection with the server, not having a chance to do reconnectBlocking();

Starting from the SSLClientExample.java, after the c.connectBlocking();, if I copy and paste this:

c.send( "hi" );
Thread.sleep( 10 );
c.closeBlocking();

//Disconnect manually and reconnect blocking
c.reconnectBlocking();
c.send( "it's" );
Thread.sleep( 10000 );
c.closeBlocking();
//Disconnect manually and reconnect
c.reconnect();
Thread.sleep( 100 );
c.send( "me" );
Thread.sleep( 100 );
c.closeBlocking();

It will only display "hi", but it should display "hi it's me".

[marci4]

Hello @AlexisBrito,

can your issue be related to #764 ?

Best regards,
Marcel

[marci4]

@AlexisBrito any update?

[AlexisBrito]

Hi @marci4,

Sorry for the delayed reply. I'm not sure it can, since in my code, I'm already creating a socket factory...

I can't really look into this at the moment so I'm going to share the whole code and hopefully you know where the issue is (if there is any):

public class SSLClientExample {

/*
 * Keystore with certificate created like so (in JKS format):
 *
 *keytool -genkey -keyalg RSA -validity 3650 -keystore "keystore.jks" -storepass "storepassword" -keypass "keypassword" -alias "default" -dname "CN=127.0.0.1, OU=MyOrgUnit, O=MyOrg, L=MyCity, S=MyRegion, C=MyCountry"
 */
public static void main( String[] args ) throws Exception {
	WebSocketChatClient c = new WebSocketChatClient( new URI( "wss://localhost:8887" ) );

	// load up the key store
	String STORETYPE = "JKS";
	String KEYSTORE = "C:\\Users\\alexandre.brito\\Documents\\NetBeansProjects\\Java-WebSocket-master2\\target\\keystore.jks";
	String STOREPASSWORD = "storepassword";
	String KEYPASSWORD = "keypassword";

	KeyStore ks = KeyStore.getInstance( STORETYPE );
	File kf = new File( KEYSTORE );
	ks.load( new FileInputStream( kf ), STOREPASSWORD.toCharArray() );

	KeyManagerFactory kmf = KeyManagerFactory.getInstance( "SunX509" );
	kmf.init( ks, KEYPASSWORD.toCharArray() );
	TrustManagerFactory tmf = TrustManagerFactory.getInstance( "SunX509" );
	tmf.init( ks );

	SSLContext sslContext = null;
	sslContext = SSLContext.getInstance( "TLS" );
	sslContext.init( kmf.getKeyManagers(), tmf.getTrustManagers(), null );
	// sslContext.init( null, null, null ); // will use java's default key and trust store which is sufficient unless you deal with self-signed certificates

	SSLSocketFactory factory = sslContext.getSocketFactory();// (SSLSocketFactory) SSLSocketFactory.getDefault();

	c.setSocketFactory( factory );

            c.connectBlocking();
            
	c.send( "hi" );
	Thread.sleep( 10 );
	c.closeBlocking();
            
	//Disconnect manually and reconnect blocking
	c.reconnectBlocking();
	c.send( "it's" );
	Thread.sleep( 10000 );
	c.closeBlocking();
	//Disconnect manually and reconnect
	c.reconnect();
	Thread.sleep( 100 );
	c.send( "me" );
	Thread.sleep( 100 );
	c.closeBlocking();

	BufferedReader reader = new BufferedReader( new InputStreamReader( System.in ) );
	while ( true ) {
		String line = reader.readLine();
		if( line.equals( "close" ) ) {
			c.close();
		} else {
			c.send( line );
		}
	}
}

}

[marci4]

Hey @AlexisBrito,

It simple does not work since there is a System.exit(0) when the client disconnects from the server (see https://github.com/TooTallNate/Java-WebSocket/blob/master/src/main/example/SSLClientExample.java#L63).

Best regards,
marci4

[AlexisBrito]

Hey @marci4,

Thanks a lot! It's working :D

Best regards!