Advertisement
MayurTolani

concurrent client server TCP

Apr 24th, 2015
257
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 2.35 KB | None | 0 0
  1. import java.io.*;
  2. import java.nio.*;
  3. import java.net.*;
  4. class ComplexTCPServer extends Thread
  5. {    
  6.     Socket connectionSocket;
  7.     ComplexTCPServer(Socket c)
  8.     {
  9.         connectionSocket=c;
  10.         this.start();      
  11.     }
  12.     public void run()
  13.     {
  14.         String clientSentence;          
  15.         String capitalizedSentence;
  16.         System.out.println("Client Connected");        
  17.         try
  18.         {
  19.             BufferedReader inFromClient = new BufferedReader(new InputStreamReader(connectionSocket.getInputStream()));
  20.             PrintWriter outToClient = new PrintWriter(connectionSocket.getOutputStream());                     
  21.             clientSentence = inFromClient.readLine();            
  22.             System.out.println("Received: " + clientSentence);            
  23.             capitalizedSentence = clientSentence.toUpperCase() + '\n';            
  24.             outToClient.println(capitalizedSentence);        
  25.             outToClient.close();
  26.             inFromClient.close();
  27.         }
  28.         catch(IOException e)
  29.         {
  30.            
  31.         }
  32.    
  33.     }
  34.     public static void main(String argv[]) throws Exception      
  35.     {                
  36.         ServerSocket welcomeSocket = new ServerSocket(6789);          
  37.         System.out.println("Server waiting for Clients");  
  38.         while(true)
  39.         {
  40.             new ComplexTCPServer(welcomeSocket.accept());            
  41.         }
  42.     }
  43. }
  44.  
  45. //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
  46.  
  47. import java.io.*;
  48. import java.net.*;
  49. class SimpleTCPClient
  50. {  
  51.     public static void main(String argv[]) throws Exception  
  52.     {  
  53.         String sentence;  
  54.         String modifiedSentence;  
  55.  
  56.         BufferedReader inFromUser = new BufferedReader( new InputStreamReader(System.in));  
  57.         Socket clientSocket = new Socket("127.0.0.1", 6789);  
  58.         System.out.println("Client Connected with Server");
  59.        
  60.         PrintWriter outToServer = new PrintWriter(clientSocket.getOutputStream(),true);  
  61.         BufferedReader inFromServer = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));  
  62.         System.out.print("Enter A Message ");
  63.         sentence = inFromUser.readLine();          
  64.         outToServer.println(sentence);
  65.         System.out.println("Message Sent to Server");  
  66.        
  67.         modifiedSentence = inFromServer.readLine();  
  68.         System.out.println("Message Received from Server");  
  69.         System.out.println("FROM SERVER: " + modifiedSentence);  
  70.  
  71.         inFromUser.close();
  72.         outToServer.close();
  73.         inFromServer.close();
  74.         clientSocket.close();  
  75.     }
  76. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement