-
-
-
- -
- -
-
-
-

Java Examples - Multithreaded Server

-
-
-
Advertisements
- - -
-
-
- Previous Page -
-
-Next Page   -
-
-
-

Problem Description

-

How to create a multithreaded server ?

-

Solution

-

Following example demonstrates how to create a multithreaded server by using ssock.accept() method of Socket class and MultiThreadServer(socketname) method of ServerSocket class.

-
-import java.io.IOException;
-import java.io.PrintStream;
-import java.net.ServerSocket;
-import java.net.Socket;
-
-public class MultiThreadServer implements Runnable {
-   Socket csocket;
-   MultiThreadServer(Socket csocket) {
-      this.csocket = csocket;
-   }
-   public static void main(String args[]) throws Exception { 
-      ServerSocket ssock = new ServerSocket(1234);
-      System.out.println("Listening");
-      
-      while (true) {
-         Socket sock = ssock.accept();
-         System.out.println("Connected");
-         new Thread(new MultiThreadServer(sock)).start();
-      }
-   }
-   public void run() {
-      try {
-         PrintStream pstream = new PrintStream(csocket.getOutputStream());
-         for (int i = 100; i >= 0; i--) {
-            pstream.println(i + " bottles of beer on the wall");
-         }
-         pstream.close();
-         csocket.close();
-      } catch (IOException e) {
-         System.out.println(e);
-      }
-   }
-}
-
-

Result

-

The above code sample will produce the following result.

-
-Listening
-Connected
-
-

Following is an another example of how to create a multithreaded server.

-
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.InputStreamReader;
-import java.io.OutputStreamWriter;
-import java.io.PrintWriter;
-
-import java.net.ServerSocket;
-import java.net.Socket;
-import java.text.SimpleDateFormat;
-import java.util.Calendar;
- 
-public class NewClass {
-   ServerSocket myServerSocket;
-   boolean ServerOn = true;
-   public NewClass() { 
-      try {
-         myServerSocket = new ServerSocket(8888);
-      } catch(IOException ioe) { 
-         System.out.println("Could not create server socket on port 8888. Quitting.");
-         System.exit(-1);
-      } 
-		
-      Calendar now = Calendar.getInstance();
-      SimpleDateFormat formatter = new SimpleDateFormat(
-         "E yyyy.MM.dd 'at' hh:mm:ss a zzz");
-      System.out.println("It is now : " + formatter.format(now.getTime()));
-      
-      while(ServerOn) { 
-         try { 
-            Socket clientSocket = myServerSocket.accept();
-            ClientServiceThread cliThread = new ClientServiceThread(clientSocket);
-            cliThread.start(); 
-         } catch(IOException ioe) { 
-            System.out.println("Exception found on accept. Ignoring. Stack Trace :"); 
-            ioe.printStackTrace(); 
-         }  
-      } 
-      try { 
-         myServerSocket.close(); 
-         System.out.println("Server Stopped"); 
-      } catch(Exception ioe) { 
-         System.out.println("Error Found stopping server socket"); 
-         System.exit(-1); 
-      } 
-   }
-	
-   public static void main (String[] args) { 
-      new NewClass();        
-   } 
-	
-   class ClientServiceThread extends Thread { 
-      Socket myClientSocket;
-      boolean m_bRunThread = true; 
-      public ClientServiceThread() { 
-         super(); 
-      } 
-		
-      ClientServiceThread(Socket s) { 
-         myClientSocket = s; 
-      } 
-		
-      public void run() { 
-         BufferedReader in = null; 
-         PrintWriter out = null; 
-         System.out.println(
-            "Accepted Client Address - " + myClientSocket.getInetAddress().getHostName());
-         try { 
-            in = new BufferedReader(
-               new InputStreamReader(myClientSocket.getInputStream()));
-            out = new PrintWriter(
-               new OutputStreamWriter(myClientSocket.getOutputStream()));
-            
-            while(m_bRunThread) { 
-               String clientCommand = in.readLine(); 
-               System.out.println("Client Says :" + clientCommand);
-               
-               if(!ServerOn) { 
-                  System.out.print("Server has already stopped"); 
-                  out.println("Server has already stopped"); 
-                  out.flush(); 
-                  m_bRunThread = false;
-               } 
-               if(clientCommand.equalsIgnoreCase("quit")) {
-                  m_bRunThread = false;
-                  System.out.print("Stopping client thread for client : ");
-               } else if(clientCommand.equalsIgnoreCase("end")) {
-                  m_bRunThread = false;
-                  System.out.print("Stopping client thread for client : ");
-                  ServerOn = false;
-               } else {
-                  out.println("Server Says : " + clientCommand);
-                  out.flush(); 
-               } 
-            } 
-         } catch(Exception e) { 
-            e.printStackTrace(); 
-         } 
-         finally { 
-            try { 
-               in.close(); 
-               out.close(); 
-               myClientSocket.close(); 
-               System.out.println("...Stopped"); 
-            } catch(IOException ioe) { 
-               ioe.printStackTrace(); 
-            } 
-         } 
-      } 
-   } 
-}
-
-
-
- Previous Page -
-
- Print -
-
-Next Page   -
-
java_networking.htm
-
- -
-
Advertisements
- - -
-
-
-
-
-
- -img - - -img - - -img - - -img - - -img - - -img - -
-
- - -
-
- - -
-
- - -
-
-
-
-
-
- -
-
-
-
- -
-
- -
-
-

© Copyright 2017. All Rights Reserved.

-
-
-
- - -
-
-
-
-
-
-