java ssl socket example

ssl socket connection with multi threading application. 

Server

---

1. 
   
2. package Test2;
3. 
   
4. import java.awt.BorderLayout;
5. import java.awt.event.ActionEvent;
6. import java.awt.event.ActionListener;
7. import java.io.IOException;
8. import java.io.ObjectInputStream;
9. import java.io.ObjectOutputStream;
10. import java.net.InetAddress;
11. import java.security.cert.Certificate;
12. import java.security.cert.X509Certificate;
13. import java.util.ArrayList;
14. 
    
15. import javax.net.ssl.SSLServerSocket;
16. import javax.net.ssl.SSLServerSocketFactory;
17. import javax.net.ssl.SSLSession;
18. import javax.net.ssl.SSLSocket;
19. import javax.swing.JFrame;
20. import javax.swing.JOptionPane;
21. import javax.swing.JScrollPane;
22. import javax.swing.JTextArea;
23. import javax.swing.JTextField;
24. 
    
25. public class Server {
26. public static ArrayList<String> list_user = new ArrayList<String>();
27. public static ArrayList<String> list_verify = new ArrayList<String>();
28. public static int port = 8005;
29. public static void main(String[] args) {
30. list_verify.add("101");
31. list_verify.add("102");
32. list_verify.add("103");
33. list_verify.add("104");
34. list_verify.add("105");
35. try {
36. SSLServerSocketFactory factory=(SSLServerSocketFactory) SSLServerSocketFactory.getDefault();
37.        SSLServerSocket sslserversocket = (SSLServerSocket) factory.createServerSocket(port, 0, InetAddress.getLocalHost());
38.        System.out.println("Server running in :" + InetAddress.getLocalHost() + ":" + port);
39.        String[] suites = sslserversocket.getSupportedCipherSuites();
40.        /*for(String s:suites){
41.         System.out.println(s);
42.        }*/
43.        sslserversocket.setEnabledCipherSuites(suites);
44.        while (true) {
45.        SSLSocket socket=(SSLSocket) sslserversocket.accept();
46. /*       
47.        SSLSession session = ((SSLSocket) socket).getSession();
48.        Certificate[] cchain2 = session.getLocalCertificates();*/
49.       
50.       
51. Runnable accept = new Runnable() {
52. @Override
53. public void run() {
54. JFrame frame = new JFrame("Server");
55. String currentUser="";
56. try {
57. ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
58. String username = (String) ois.readObject();
59.    ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
60. 
    
61. if (list_verify.contains(username)) {
62. if (!list_user.contains(username)) {
63. list_user.add(username);
64. currentUser=username;
65. oos.writeObject("1");
66. System.out.println("connected to : " + username);
67. //JFrame frame = new JFrame("Server");
68. frame.addWindowListener(new java.awt.event.WindowAdapter() {
69.    @Override
70.    public void windowClosing(java.awt.event.WindowEvent windowEvent) {
71.     //frame.dispose();
72.     try {
73. oos.close();
74. ois.close();
75. } catch (IOException e) {
76. 
    
77. e.printStackTrace();
78. }
79.    
80.    }
81. });
82. 
    
83. frame.setVisible(true);
84. JTextField userText = new JTextField();
85. userText.setEditable(false);
86. userText.addActionListener(new ActionListener() {
87. public void actionPerformed(ActionEvent event) {
88. sendMessage(oos, event.getActionCommand());
89. userText.setText("");
90. }
91. });
92. ;
93. 
    
94. frame.add(userText, BorderLayout.NORTH);
95. JTextArea chatWindow = new JTextArea();
96. chatWindow.setEditable(false);
97. frame.add(new JScrollPane(chatWindow));
98. frame.setSize(300, 150);
99. chatWindow.append("connected to : " + username);
100. userText.setEditable(true);
101. 
     
102. do {
103. try {
104. username = (String) ois.readObject();
105. chatWindow.append("\n " + username);
106. } catch (ClassNotFoundException classNotFoundException) {
107. System.out.println("close");
108. chatWindow.append("\n Dont know the Object type ");
109. chatWindow.append("\n connection close.. ");
110. }
111. 
     
112. } while (!username.equals("END"));
113. 
     
114. } else {
115. oos.writeObject("2");
116. }
117. } else {
118. oos.writeObject("0");
119. }
120. 
     
121. } catch (IOException e) {
122. System.out.println("client disconnected ");
123. frame.dispose();
124. list_user.remove(currentUser);
125. //Thread.currentThread().interrupt();
126. // chatWindow.append("Diss");
127. // userText.setEditable(false);
128. // e.printStackTrace();
129. } catch (ClassNotFoundException e) {
130. e.printStackTrace();
131. 
     
132. }
133. 
     
134. }};
135. new Thread(accept).start();
136.        }
137. } catch (IOException e) {
138. JOptionPane.showMessageDialog(null, "Server already running in the same port");
139. System.out.println("Ip and port Already bind");
140. }
141.      
142. 
     
143. }
144. public static void sendMessage(ObjectOutputStream oos, String message) {
145. try {
146. oos.writeObject(message);
147. } catch (IOException e) {
148. e.printStackTrace();
149. }
150. }
151. 
     
152. }

Client

---

1. 
   
2. package Test2;
3. 
   
4. import java.awt.BorderLayout;
5. import java.awt.event.ActionEvent;
6. import java.awt.event.ActionListener;
7. import java.io.IOException;
8. import java.io.ObjectInputStream;
9. import java.io.ObjectOutputStream;
10. import java.net.UnknownHostException;
11. 
    
12. import javax.net.ssl.HandshakeCompletedEvent;
13. import javax.net.ssl.HandshakeCompletedListener;
14. import javax.net.ssl.SSLSocket;
15. import javax.net.ssl.SSLSocketFactory;
16. import javax.swing.JFrame;
17. import javax.swing.JOptionPane;
18. import javax.swing.JScrollPane;
19. import javax.swing.JTextArea;
20. import javax.swing.JTextField;
21. 
    
22. public class Client {
23. 
    
24. public static void main(String[] args) {
25. String host = "localhost";
26. int port = 8005;
27. String username = JOptionPane.showInputDialog(null, "IP: " + host + ":" + port);
28. JFrame frame = new JFrame("Client");
29. try {
30. 
    
31. SSLSocketFactory factory = (SSLSocketFactory) SSLSocketFactory.getDefault();
32. SSLSocket socket = (SSLSocket) factory.createSocket(host, port);
33. 
    
34. String[] suites = socket.getSupportedCipherSuites();
35. socket.setEnabledCipherSuites(suites);
36. 
    
37. socket.addHandshakeCompletedListener(new MyHandshakeListener());
38. socket.startHandshake();
39. 
    
40. System.out.println("Just connected to " + socket.getRemoteSocketAddress());
41. ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
42. oos.writeObject(username);
43. 
    
44. ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
45. String response = (String) ois.readObject();
46. //JFrame frame = new JFrame("Client");
47. frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
48. frame.setVisible(true);
49. JTextField userText = new JTextField();
50. userText.setEditable(false);
51. userText.addActionListener(new ActionListener() {
52. public void actionPerformed(ActionEvent event) {
53. sendMessage(oos, event.getActionCommand());
54. userText.setText("");
55. }
56. });
57. ;
58. 
    
59. frame.add(userText, BorderLayout.NORTH);
60. JTextArea chatWindow = new JTextArea();
61. chatWindow.setEditable(false);
62. frame.add(new JScrollPane(chatWindow));
63. frame.setSize(300, 150);
64. if (response.equalsIgnoreCase("1")) {
65. chatWindow.append("connected......");
66. userText.setEditable(true);
67. do {
68. try {
69. response = (String) ois.readObject();
70. chatWindow.append("\n " + response);
71. } catch (ClassNotFoundException classNotFoundException) {
72. chatWindow.append("\n Dont know the Object type ");
73. chatWindow.append("\n connection close.. ");
74. }
75. 
    
76. } while (!response.equals(" END"));
77. }
78. if (response.equalsIgnoreCase("0")) {
79. chatWindow.append("\n refused , not authorised....");
80. }
81. if (response.equalsIgnoreCase("2")) {
82. frame.dispose();
83. JOptionPane.showMessageDialog(null, "already connected");
84. }
85. 
    
86. } catch (UnknownHostException e) {
87. // TODO Auto-generated catch block
88. e.printStackTrace();
89. } catch (IOException e) {
90. frame.dispose();
91. }
92.  catch (ClassNotFoundException e) {
93. // TODO Auto-generated catch block
94. e.printStackTrace();
95. }
96. }
97. public static void sendMessage(ObjectOutputStream oos, String message) {
98. try {
99. oos.writeObject(message);
100. } catch (IOException e) {
101. // TODO Auto-generated catch block
102. e.printStackTrace();
103. }
104. }
105. 
     
106. }
107. class MyHandshakeListener implements HandshakeCompletedListener {
108.   public void handshakeCompleted(HandshakeCompletedEvent e) {
109.     System.out.println("Handshake succesful!");
110.     System.out.println("Using cipher suite: " + e.getCipherSuite());
111.   }
112. }
113.