mirror of
https://github.com/mozilla/gecko-dev.git
synced 2024-10-14 13:55:43 +00:00
Adding JSS SelfServ test client and server.
This commit is contained in:
sandeep.konchady%sun.com
parent
80779dd10e
commit
09666e78db
423
security/jss/org/mozilla/jss/tests/JSS_SelfServClient.java
Executable file
423
security/jss/org/mozilla/jss/tests/JSS_SelfServClient.java
Executable file
@ -0,0 +1,423 @@
|
||||
/* ***** BEGIN LICENSE BLOCK *****
|
||||
* Version: MPL 1.1/GPL 2.0/LGPL 2.1
|
||||
*
|
||||
* The contents of this file are subject to the Mozilla Public License Version
|
||||
* 1.1 (the "License"); you may not use this file except in compliance with
|
||||
* the License. You may obtain a copy of the License at
|
||||
* http://www.mozilla.org/MPL/
|
||||
*
|
||||
* Software distributed under the License is distributed on an "AS IS" basis,
|
||||
* WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
|
||||
* for the specific language governing rights and limitations under the
|
||||
* License.
|
||||
*
|
||||
* The Original Code is Netscape Security Services for Java.
|
||||
*
|
||||
* The Initial Developer of the Original Code is
|
||||
* Netscape Communications Corporation.
|
||||
* Portions created by the Initial Developer are Copyright (C) 2002
|
||||
* the Initial Developer. All Rights Reserved.
|
||||
*
|
||||
* Contributor(s):
|
||||
*
|
||||
* Alternatively, the contents of this file may be used under the terms of
|
||||
* either the GNU General Public License Version 2 or later (the "GPL"), or
|
||||
* the GNU Lesser General Public License Version 2.1 or later (the "LGPL"),
|
||||
* in which case the provisions of the GPL or the LGPL are applicable instead
|
||||
* of those above. If you wish to allow use of your version of this file only
|
||||
* under the terms of either the GPL or the LGPL, and not to allow others to
|
||||
* use your version of this file under the terms of the MPL, indicate your
|
||||
* decision by deleting the provisions above and replace them with the notice
|
||||
* and other provisions required by the GPL or the LGPL. If you do not delete
|
||||
* the provisions above, a recipient may use your version of this file under
|
||||
* the terms of any one of the MPL, the GPL or the LGPL.
|
||||
*
|
||||
* ***** END LICENSE BLOCK ***** */
|
||||
|
||||
package org.mozilla.jss.tests;
|
||||
|
||||
import org.mozilla.jss.ssl.*;
|
||||
import org.mozilla.jss.CryptoManager;
|
||||
import org.mozilla.jss.crypto.*;
|
||||
import org.mozilla.jss.asn1.*;
|
||||
import org.mozilla.jss.pkix.primitive.*;
|
||||
import org.mozilla.jss.pkix.cert.*;
|
||||
import org.mozilla.jss.pkix.cert.Certificate;
|
||||
import org.mozilla.jss.util.PasswordCallback;
|
||||
|
||||
import java.util.Calendar;
|
||||
import java.util.Date;
|
||||
import java.security.*;
|
||||
import java.security.PrivateKey;
|
||||
import java.net.*;
|
||||
import java.io.*;
|
||||
|
||||
public class JSS_SelfServClient {
|
||||
|
||||
private String clientCertNick = null;
|
||||
private String serverHost = "localhost";
|
||||
private boolean TestCertCallBack = false;
|
||||
private boolean success = true;
|
||||
private int fCipher = -1;
|
||||
private int port = 29754;
|
||||
private String EOF = "test";
|
||||
private boolean handshakeCompleted = false;
|
||||
|
||||
private CryptoManager cm = null;
|
||||
private CryptoToken tok = null;
|
||||
private PasswordCallback cb = null;
|
||||
private String fPasswordFile = "passwords";
|
||||
private String fCertDbPath = ".";
|
||||
|
||||
/**
|
||||
* Default Constructor, do not use.
|
||||
*/
|
||||
public JSS_SelfServClient () {
|
||||
}
|
||||
|
||||
/**
|
||||
* Initialize the desired cipher to be set
|
||||
* on the socket.
|
||||
* @param int Cipher
|
||||
*/
|
||||
public void setCipher (int aCipher) {
|
||||
fCipher = aCipher;
|
||||
}
|
||||
|
||||
/**
|
||||
* Initialize the hostname to run the server
|
||||
* @param String ServerName
|
||||
*/
|
||||
public void setHostName (String aHostName) {
|
||||
serverHost = aHostName;
|
||||
}
|
||||
|
||||
/**
|
||||
* Initialize the port to run the server
|
||||
* @param int port
|
||||
*/
|
||||
public void setPort (int aPort) {
|
||||
port = aPort;
|
||||
}
|
||||
|
||||
/**
|
||||
* Initialize the passwords file name
|
||||
* @param String passwords
|
||||
*/
|
||||
public void setPasswordFile (String aPasswordFile) {
|
||||
fPasswordFile = aPasswordFile;
|
||||
}
|
||||
|
||||
/**
|
||||
* Initialize the cert db path name
|
||||
* @param String CertDbPath
|
||||
*/
|
||||
public void setCertDbPath (String aCertDbPath) {
|
||||
fCertDbPath = aCertDbPath;
|
||||
}
|
||||
|
||||
/**
|
||||
* Enable/disable Test Cert Callback.
|
||||
* @param boolean
|
||||
*/
|
||||
public void setTestCertCallback (boolean aTestCertCallback) {
|
||||
TestCertCallBack = aTestCertCallback;
|
||||
}
|
||||
|
||||
/**
|
||||
* Set client certificate
|
||||
* @param String Certificate Nick Name
|
||||
*/
|
||||
public void setClientCertNick (String aClientCertNick) {
|
||||
clientCertNick = aClientCertNick;
|
||||
}
|
||||
|
||||
/**
|
||||
* Return true if handshake is completed
|
||||
* else return false;
|
||||
* @return boolean handshake status
|
||||
*/
|
||||
public boolean isHandshakeCompleted () {
|
||||
return this.handshakeCompleted;
|
||||
}
|
||||
|
||||
/**
|
||||
* Set handshakeCompleted flag to indicate
|
||||
* that the socket handshake is coplete.
|
||||
*/
|
||||
public void setHandshakeCompleted () {
|
||||
this.handshakeCompleted = true;
|
||||
}
|
||||
|
||||
/**
|
||||
* Clear handshakeCompleted flag to indicate
|
||||
* that the system is now ready for another
|
||||
* socket connection.
|
||||
*/
|
||||
public void clearHandshakeCompleted () {
|
||||
this.handshakeCompleted = false;
|
||||
}
|
||||
|
||||
/**
|
||||
* Set EOF for closinng server socket
|
||||
* @param null for closing server socket
|
||||
*/
|
||||
public void setEOF (String fEof) {
|
||||
this.EOF = fEof;
|
||||
}
|
||||
|
||||
/**
|
||||
* ReadWrite thread class that takes a
|
||||
* SSLSocket as input and sleeps
|
||||
* for 2 sec between sending some test
|
||||
* data and receiving.
|
||||
*/
|
||||
private class readWriteThread extends Thread {
|
||||
private SSLSocket clientSock = null;
|
||||
private int socketCntr = 0;
|
||||
|
||||
public readWriteThread (SSLSocket sock, int cntr) {
|
||||
clientSock = sock;
|
||||
socketCntr = cntr;
|
||||
}
|
||||
|
||||
public void run () {
|
||||
|
||||
try {
|
||||
String socketData = null;
|
||||
String inputLine = null;
|
||||
InputStream is = clientSock.getInputStream ();
|
||||
OutputStream os = clientSock.getOutputStream ();
|
||||
BufferedReader bir = new BufferedReader (
|
||||
new InputStreamReader (is));
|
||||
PrintWriter out = new PrintWriter (new BufferedWriter (
|
||||
new OutputStreamWriter (os)));
|
||||
|
||||
while (true) {
|
||||
System.out.println("Writing hi to server on thread " +
|
||||
socketCntr);
|
||||
out.print ("Client saying hi to server\n");
|
||||
out.flush ();
|
||||
inputLine = bir.readLine();
|
||||
System.out.println ("Received " + inputLine +
|
||||
" on thread " + socketCntr);
|
||||
Thread.sleep (1000);
|
||||
}
|
||||
} catch (java.net.SocketTimeoutException e) {
|
||||
System.out.println ("Exception caught\n" + e.getMessage ());
|
||||
e.printStackTrace ();
|
||||
System.exit (1);
|
||||
} catch (IOException e) {
|
||||
System.out.println ("Exception caught\n" + e.getMessage ());
|
||||
e.printStackTrace ();
|
||||
System.exit (1);
|
||||
} catch (Exception e) {
|
||||
System.out.println ("Exception caught\n" + e.getMessage ());
|
||||
e.printStackTrace ();
|
||||
System.exit (1);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Initialize and create a socket connection to
|
||||
* SSLServer using the set parameters.
|
||||
*/
|
||||
public void doIt (int cntr) throws Exception {
|
||||
|
||||
try {
|
||||
CryptoManager.initialize (fCertDbPath);
|
||||
cm = CryptoManager.getInstance ();
|
||||
tok = cm.getInternalKeyStorageToken ();
|
||||
cb = new FilePasswordCallback (fPasswordFile);
|
||||
tok.login (cb);
|
||||
} catch (Exception e) {}
|
||||
|
||||
// connect to the server
|
||||
if ( Constants.debug_level >= 3 )
|
||||
System.out.println ("client about to connect...");
|
||||
|
||||
String hostAddr =
|
||||
InetAddress.getByName (serverHost).getHostAddress ();
|
||||
|
||||
if ( Constants.debug_level >= 3 )
|
||||
System.out.println ("the host " + serverHost +
|
||||
" and the address " + hostAddr);
|
||||
|
||||
SSLCertificateApprovalCallback approvalCallback =
|
||||
new TestCertApprovalCallback ();
|
||||
SSLClientCertificateSelectionCallback certSelectionCallback =
|
||||
new TestClientCertificateSelectionCallback ();
|
||||
|
||||
SSLSocket sock = null;
|
||||
|
||||
if (TestCertCallBack) {
|
||||
if ( Constants.debug_level >= 3 )
|
||||
System.out.println ("calling approvalCallBack");
|
||||
sock = new SSLSocket (InetAddress.getByName (hostAddr),
|
||||
port,
|
||||
null,
|
||||
0,
|
||||
new TestCertApprovalCallback (),
|
||||
null);
|
||||
} else {
|
||||
if ( Constants.debug_level >= 3 )
|
||||
System.out.println ("NOT calling approvalCallBack");
|
||||
sock = new SSLSocket (InetAddress.getByName (hostAddr),
|
||||
port);
|
||||
}
|
||||
|
||||
if ( Constants.debug_level >= 3 )
|
||||
System.out.println ("clientCertNick=" + clientCertNick);
|
||||
sock.setClientCertNickname (clientCertNick);
|
||||
if ( fCipher != -1 ) {
|
||||
sock.setCipherPreference (fCipher, true);
|
||||
}
|
||||
if ( Constants.debug_level >= 3 ) {
|
||||
System.out.println ("Client specified cert by nickname");
|
||||
System.out.println ("client connected");
|
||||
}
|
||||
|
||||
sock.addHandshakeCompletedListener (
|
||||
new HandshakeListener ("client",this));
|
||||
|
||||
sock.forceHandshake ();
|
||||
sock.setSoTimeout(10000);
|
||||
readWriteThread rwThread = new readWriteThread (sock, cntr);
|
||||
rwThread.start ();
|
||||
}
|
||||
|
||||
/**
|
||||
* SSL Handshake Listeren implementation.
|
||||
*/
|
||||
public class HandshakeListener
|
||||
implements SSLHandshakeCompletedListener {
|
||||
private String who;
|
||||
private JSS_SelfServClient boss;
|
||||
public HandshakeListener (String who, JSS_SelfServClient boss) {
|
||||
this.who = who;
|
||||
this.boss = boss;
|
||||
}
|
||||
public void handshakeCompleted (SSLHandshakeCompletedEvent event) {
|
||||
try {
|
||||
String mesg = who + " got a completed handshake ";
|
||||
SSLSecurityStatus status = event.getStatus ();
|
||||
if( status.isSecurityOn () ) {
|
||||
mesg += "(security is ON)";
|
||||
} else {
|
||||
mesg += "(security is OFF)";
|
||||
}
|
||||
if ( Constants.debug_level >= 3 )
|
||||
System.out.println (mesg);
|
||||
} catch(Exception e) {
|
||||
e.printStackTrace ();
|
||||
boss.setFailure ();
|
||||
}
|
||||
setHandshakeCompleted ();
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Set status return value to false.
|
||||
*/
|
||||
public synchronized void setFailure () {
|
||||
success = false;
|
||||
}
|
||||
|
||||
/**
|
||||
* Set status return value to success.
|
||||
*/
|
||||
public synchronized boolean getSuccess () {
|
||||
return success;
|
||||
}
|
||||
|
||||
/**
|
||||
* Main method. Used for unit testing.
|
||||
*/
|
||||
public static void main (String[] args) {
|
||||
|
||||
String certnick = "JSSCATestCert";
|
||||
String testCipher = null;
|
||||
String testhost = "localhost";
|
||||
int testport = 29754;
|
||||
int socketCntr = 10;
|
||||
String certDbPath = null;
|
||||
String passwdFile = null;
|
||||
|
||||
String usage = "\nUSAGE:\n" +
|
||||
"java org.mozilla.jss.tests.JSS_SelfServClient" +
|
||||
" [# sockets] [JSS cipher integer]\n\nOptional:\n" +
|
||||
"[certdb path] [password file] [server host] [server port]\n";
|
||||
|
||||
try {
|
||||
if (args.length <= 0 ||
|
||||
args[0].toLowerCase ().equals ("-h")) {
|
||||
System.out.println (usage);
|
||||
System.exit (0);
|
||||
} else {
|
||||
socketCntr = new Integer (args[0]).intValue ();
|
||||
System.out.println ("Socket Counter = " + socketCntr);
|
||||
}
|
||||
testCipher = (String)args[1];
|
||||
System.out.println ("Test Cipher = " + testCipher);
|
||||
|
||||
if ( args.length >= 3 ) {
|
||||
certDbPath = (String)args[2];
|
||||
passwdFile = (String)args[3];
|
||||
}
|
||||
|
||||
if ( args.length >= 5 ) {
|
||||
testhost = (String)args[4];
|
||||
testport = new Integer (args[5]).intValue ();
|
||||
}
|
||||
} catch (Exception e) {
|
||||
System.out.println ("Unknown exception : " + e.getMessage ());
|
||||
}
|
||||
|
||||
System.out.println ("Client connecting to server ...");
|
||||
|
||||
for ( int j=0; j<socketCntr; j++) {
|
||||
JSS_SelfServClient jssTest = new JSS_SelfServClient ();
|
||||
try {
|
||||
if ( !testhost.equals ("localhost") )
|
||||
jssTest.setHostName (testhost);
|
||||
|
||||
if ( testport != 29754 )
|
||||
jssTest.setPort (testport);
|
||||
|
||||
jssTest.setTestCertCallback (true);
|
||||
jssTest.setClientCertNick (certnick);
|
||||
|
||||
if ( certDbPath != null )
|
||||
jssTest.setCertDbPath (certDbPath);
|
||||
|
||||
if ( passwdFile != null )
|
||||
jssTest.setPasswordFile (passwdFile);
|
||||
|
||||
if ( testCipher != null ) {
|
||||
try {
|
||||
jssTest.setCipher (new Integer (testCipher).intValue ());
|
||||
jssTest.setEOF (testCipher);
|
||||
jssTest.doIt (j);
|
||||
} catch (Exception ex) {
|
||||
System.out.println (ex.getMessage ());
|
||||
ex.printStackTrace ();
|
||||
System.exit(1);
|
||||
}
|
||||
}
|
||||
} catch (Exception ex) {
|
||||
System.out.println (ex.getMessage ());
|
||||
ex.printStackTrace ();
|
||||
System.exit(1);
|
||||
}
|
||||
}
|
||||
System.out.println ("All " + socketCntr + " sockets created. Exiting");
|
||||
// Sleep for 3 min
|
||||
try {
|
||||
Thread.currentThread ().sleep (300*1000);
|
||||
} catch (Exception ex) {
|
||||
System.out.println (ex.getMessage ());
|
||||
}
|
||||
System.exit(0);
|
||||
}
|
||||
}
|
||||
265
security/jss/org/mozilla/jss/tests/JSS_SelfServServer.java
Executable file
265
security/jss/org/mozilla/jss/tests/JSS_SelfServServer.java
Executable file
@ -0,0 +1,265 @@
|
||||
/* ***** BEGIN LICENSE BLOCK *****
|
||||
* Version: MPL 1.1/GPL 2.0/LGPL 2.1
|
||||
*
|
||||
* The contents of this file are subject to the Mozilla Public License Version
|
||||
* 1.1 (the "License"); you may not use this file except in compliance with
|
||||
* the License. You may obtain a copy of the License at
|
||||
* http://www.mozilla.org/MPL/
|
||||
*
|
||||
* Software distributed under the License is distributed on an "AS IS" basis,
|
||||
* WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
|
||||
* for the specific language governing rights and limitations under the
|
||||
* License.
|
||||
*
|
||||
* The Original Code is Netscape Security Services for Java.
|
||||
*
|
||||
* The Initial Developer of the Original Code is
|
||||
* Netscape Communications Corporation.
|
||||
* Portions created by the Initial Developer are Copyright (C) 2002
|
||||
* the Initial Developer. All Rights Reserved.
|
||||
*
|
||||
* Contributor(s):
|
||||
*
|
||||
* Alternatively, the contents of this file may be used under the terms of
|
||||
* either the GNU General Public License Version 2 or later (the "GPL"), or
|
||||
* the GNU Lesser General Public License Version 2.1 or later (the "LGPL"),
|
||||
* in which case the provisions of the GPL or the LGPL are applicable instead
|
||||
* of those above. If you wish to allow use of your version of this file only
|
||||
* under the terms of either the GPL or the LGPL, and not to allow others to
|
||||
* use your version of this file under the terms of the MPL, indicate your
|
||||
* decision by deleting the provisions above and replace them with the notice
|
||||
* and other provisions required by the GPL or the LGPL. If you do not delete
|
||||
* the provisions above, a recipient may use your version of this file under
|
||||
* the terms of any one of the MPL, the GPL or the LGPL.
|
||||
*
|
||||
* ***** END LICENSE BLOCK ***** */
|
||||
|
||||
package org.mozilla.jss.tests;
|
||||
|
||||
import org.mozilla.jss.ssl.*;
|
||||
import org.mozilla.jss.CryptoManager;
|
||||
import org.mozilla.jss.ssl.*;
|
||||
import org.mozilla.jss.crypto.*;
|
||||
import org.mozilla.jss.asn1.*;
|
||||
import org.mozilla.jss.pkix.primitive.*;
|
||||
import org.mozilla.jss.pkix.cert.*;
|
||||
import org.mozilla.jss.pkix.cert.Certificate;
|
||||
import org.mozilla.jss.util.PasswordCallback;
|
||||
|
||||
import org.mozilla.jss.tests.*;
|
||||
|
||||
import java.util.Calendar;
|
||||
import java.util.Date;
|
||||
import java.util.Vector;
|
||||
import java.security.*;
|
||||
import java.security.PrivateKey;
|
||||
import java.net.InetAddress;
|
||||
import java.io.BufferedReader;
|
||||
import java.io.BufferedWriter;
|
||||
import java.io.EOFException;
|
||||
import java.io.InputStreamReader;
|
||||
import java.io.InputStream;
|
||||
import java.io.IOException;
|
||||
import java.io.OutputStream;
|
||||
import java.io.OutputStreamWriter;
|
||||
import java.io.PrintWriter;
|
||||
|
||||
public class JSS_SelfServServer {
|
||||
|
||||
private static Vector jssSupportedCiphers = new Vector ();
|
||||
private static SSLServerSocket serverSock = null;
|
||||
private static SSLSocket sock = null;
|
||||
|
||||
public static void main (String[] args) throws Exception {
|
||||
try {
|
||||
(new JSS_SelfServServer ()).doIt (args);
|
||||
} catch (Exception e) {
|
||||
System.out.println("Exception " + e.getMessage());
|
||||
System.exit(1);
|
||||
}
|
||||
System.exit(0);
|
||||
}
|
||||
|
||||
private String fServerCertNick = null;
|
||||
private String fServerHost = "localhost";
|
||||
private String fPasswordFile = "passwords";
|
||||
private String fCertDbPath = ".";
|
||||
private boolean TestInetAddress = false;
|
||||
private boolean success = true;
|
||||
public static int port = 29754;
|
||||
public static String usage = "\nUSAGE:\njava JSS_SelfServServer"+
|
||||
" [certdb path] [password file]\n"+
|
||||
"[server_host_name] " +
|
||||
"[cert nickname] [testInetAddress: true|false]";
|
||||
|
||||
public void doIt (String[] args) throws Exception {
|
||||
|
||||
if ( args.length < 1 || args[0].toLowerCase ().indexOf ("-h") != -1) {
|
||||
System.out.println (usage);
|
||||
System.exit (1);
|
||||
}
|
||||
|
||||
int socketCntr = 0;
|
||||
try {
|
||||
if (args[0].length () > 0 &&
|
||||
!args[0].equals ("."))
|
||||
fCertDbPath = args[0];
|
||||
if (args[1].length () > 0 &&
|
||||
!args[1].equals ("passwords"))
|
||||
fPasswordFile = args[1];
|
||||
if (args[2].length () > 0 &&
|
||||
!args[2].equals ("localhost"))
|
||||
fServerHost = args[2];
|
||||
if (args[3].length () > 0)
|
||||
fServerCertNick = args[3];
|
||||
} catch (Exception e) {}
|
||||
|
||||
CryptoManager.initialize (fCertDbPath);
|
||||
CryptoManager cm = CryptoManager.getInstance ();
|
||||
CryptoToken tok = cm.getInternalKeyStorageToken ();
|
||||
PasswordCallback cb = new FilePasswordCallback (fPasswordFile);
|
||||
tok.login (cb);
|
||||
|
||||
if (args[4].equalsIgnoreCase ("true") == true) {
|
||||
TestInetAddress = true;
|
||||
}
|
||||
|
||||
// We have to configure the server session ID cache before
|
||||
// creating any server sockets.
|
||||
SSLServerSocket.configServerSessionIDCache (10, 100, 100, null);
|
||||
|
||||
/* enable all the SSL2 cipher suites */
|
||||
for (int i = SSLSocket.SSL2_RC4_128_WITH_MD5;
|
||||
i <= SSLSocket.SSL2_DES_192_EDE3_CBC_WITH_MD5; ++i) {
|
||||
if (i != SSLSocket.SSL2_IDEA_128_CBC_WITH_MD5) {
|
||||
SSLSocket.setCipherPreferenceDefault ( i, true);
|
||||
}
|
||||
}
|
||||
|
||||
/* enable all the SSL3 and TLS cipher suites */
|
||||
for (int i = 0; Constants.jssCipherSuites[i] != 0; ++i) {
|
||||
try {
|
||||
SSLSocket.setCipherPreferenceDefault (
|
||||
Constants.jssCipherSuites[i], true);
|
||||
} catch (Exception ex) {
|
||||
}
|
||||
}
|
||||
|
||||
// open the server socket and bind to the port
|
||||
if ( Constants.debug_level >= 3 )
|
||||
System.out.println ("Server about .... to create socket");
|
||||
|
||||
if (TestInetAddress) {
|
||||
if ( Constants.debug_level >= 3 )
|
||||
System.out.println ("the HostName " + fServerHost +
|
||||
" the Inet Address " +
|
||||
InetAddress.getByName (fServerHost));
|
||||
serverSock = new SSLServerSocket (port, 5,
|
||||
InetAddress.getByName (fServerHost), null , true);
|
||||
} else {
|
||||
if ( Constants.debug_level >= 3 )
|
||||
System.out.println ("Inet set to Null");
|
||||
serverSock = new SSLServerSocket (port, 5, null , null , true);
|
||||
}
|
||||
|
||||
if ( Constants.debug_level >= 3 )
|
||||
System.out.println ("Server created socket");
|
||||
|
||||
//serverSock.setSoTimeout(120 * 1000);
|
||||
serverSock.requireClientAuth (true, true);
|
||||
serverSock.setServerCertNickname (fServerCertNick);
|
||||
if ( Constants.debug_level >= 3 )
|
||||
System.out.println ("Server specified cert by nickname");
|
||||
|
||||
System.out.println ("Server ready to accept connections");
|
||||
while ( true ) {
|
||||
// accept the connection
|
||||
sock = (SSLSocket) serverSock.accept ();
|
||||
sock.addHandshakeCompletedListener (
|
||||
new HandshakeListener ("server", this));
|
||||
socketCntr++;
|
||||
readWriteThread rwThread = new readWriteThread (sock, socketCntr);
|
||||
rwThread.start ();
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* ReadWrite thread class that takes a
|
||||
* SSLSocket as input and sleeps
|
||||
* for 2 sec between sending some test
|
||||
* data and receiving.
|
||||
*/
|
||||
private class readWriteThread extends Thread {
|
||||
private SSLSocket socket = null;
|
||||
private int socketCntr = 0;
|
||||
|
||||
public readWriteThread (SSLSocket sock, int cntr) {
|
||||
this.socket = sock;
|
||||
this.socketCntr = cntr;
|
||||
}
|
||||
|
||||
public void run () {
|
||||
|
||||
try {
|
||||
String socketData = null;
|
||||
String inputLine = null;
|
||||
InputStream is = socket.getInputStream ();
|
||||
OutputStream os = socket.getOutputStream ();
|
||||
BufferedReader bir = new BufferedReader (
|
||||
new InputStreamReader (is));
|
||||
PrintWriter out = new PrintWriter (new BufferedWriter (
|
||||
new OutputStreamWriter (os)));
|
||||
|
||||
while (true) {
|
||||
while ((inputLine = bir.readLine ()) != null) {
|
||||
System.out.println ("Socket" + socketCntr +
|
||||
": Received " + inputLine);
|
||||
System.out.println ("Socket" + socketCntr +
|
||||
": Writing hi back to client");
|
||||
out.print ("Server saying hi on socket " +
|
||||
socketCntr + "\n");
|
||||
out.flush ();
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
System.out.println ("Exception caught\n");
|
||||
e.printStackTrace ();
|
||||
System.exit (1);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
public static class HandshakeListener
|
||||
implements SSLHandshakeCompletedListener {
|
||||
private String who;
|
||||
private JSS_SelfServServer boss;
|
||||
public HandshakeListener (String who, JSS_SelfServServer boss) {
|
||||
this.who = who;
|
||||
this.boss = boss;
|
||||
}
|
||||
public void handshakeCompleted (SSLHandshakeCompletedEvent event) {
|
||||
try {
|
||||
String mesg = who + " got a completed handshake ";
|
||||
SSLSecurityStatus status = event.getStatus ();
|
||||
if( status.isSecurityOn () ) {
|
||||
mesg += "(security is ON)";
|
||||
} else {
|
||||
mesg += "(security is OFF)";
|
||||
}
|
||||
if ( Constants.debug_level >= 3 )
|
||||
System.out.println (mesg);
|
||||
} catch(Exception e) {
|
||||
e.printStackTrace ();
|
||||
boss.setFailure ();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
public synchronized void setFailure () {
|
||||
success = false;
|
||||
}
|
||||
|
||||
public synchronized boolean getSuccess () {
|
||||
return success;
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user