It May Help

1 Chatting

import java.io.*;

import java.net.*;

class KarunClient

{

            public static void main(String args[]) throws Exception

            {

                        try

                        {

                String Schat="";

                String Sstr="";

                        Socket SC = new Socket("localhost",8888);

                        DataInputStream Uinp =new DataInputStream(System.in);

                        DataInputStream Sinp =new DataInputStream(SC.getInputStream());

                        PrintStream PS = new PrintStream(SC.getOutputStream());

                        System.out.println("********************* Client**********************");

                        while(true)

                                    {

                                                    System.out.print("Client : ");

                                                            Schat=Uinp.readLine();

                                                            if(Schat.equals("exit"))

                                                                        break;

                                                            PS.println(Schat);        

                                                            Sstr=Sinp.readLine();

                                                            System.out.println("Server : "+Sstr);

                                                           

                                                              

                                    }

                        }catch(Exception e){System.err.println(e);};   

            }

}

import java.io.*;

import java.net.*;

class KarunServer

{

            public static void main (String args[]) throws Exception

            {

                        try

                        {

                                    String CStr="";

                                    String UStr="";

                                    System.out.println("********************* Server**********************"); 

                                    ServerSocket SS = new ServerSocket(8888);

                                    Socket OS = SS.accept();

                                    DataInputStream Cinp =new DataInputStream(OS.getInputStream());

                                    DataInputStream Uinp =new DataInputStream(System.in);

                                    PrintStream PS = new PrintStream(OS.getOutputStream());

                                    while(true)

                                                {

                                                            CStr=Cinp.readLine();

                                                            System.out.println("Client : " +CStr);

                                                            if(CStr.equals("exit"))

                                                                        break; 

                                                            System.out.print("Server : ");  

                                                            UStr=Uinp.readLine();            

                                                            PS.println(UStr);

                                                             

                                                }

                        }catch(Exception e){System.err.println(e);};

                              

            }

}

2 Down loading

import java.io.*;

import java.net.*;

class client

{

            public static void main(String args[])throws IOException

            {

                        DataInputStream ds= new DataInputStream(System.in);

                       

                        Socket sck= new Socket("localhost",3000);

                       

                        DataInputStream in= new DataInputStream(sck.getInputStream());

                        PrintStream out = new PrintStream(sck.getOutputStream());

                       

                        String fn,receive,dest;

                                               

                        while(true)

                        {

                                    System.out.print("Enter your file name");

                                    fn= ds.readLine();

                       

                                    System.out.print("Enter the destination filename (or path) to transfer:");

                                    dest= ds.readLine();

                       

                                    if(fn.equals("end"))

                                    {

                                                out.println(fn);

                                                break;

                                    }

                                   

                                    File path= new File(dest+"/"+fn);

                                                           

                                    out.println(fn);

                                   

                                    receive = in.readLine();

                                                           

                                    if(receive.equals("null")) break;

                                   

                                    /*StringTokenizer st=new StringTokenizer(rec,"*");

                                    while(st.hasMoreTokens())

                                    {

                                                towrite=towrite+st.nextToken()+"\n";

                                    }*/

                       

                                    FileWriter fw = new FileWriter(path,true);

                                    fw.write(receive);

                                    fw.close();

                                   

                                    //System.out.println(receive);

                                    System.out.println("The file successfuly received in :"+dest);

                        }

            }

}

import java.io.*;

import java.net.*;

class server

{

            public static void main(String args[])throws IOException

            {

                        DataInputStream ds= new DataInputStream(System.in);

                        System.out.println ("waiting for client");

                        ServerSocket ssck= new ServerSocket(3000);

                        Socket sck= ssck.accept();

                        DataInputStream in= new DataInputStream(sck.getInputStream());

                        PrintStream out = new PrintStream(sck.getOutputStream());

                        System.out.println("Server Ready now...");

                        String data;

                        while(true)

                        {

                                    String tosend="";

                                    String fn=in.readLine();

                                   

                                    if(fn.equals("end")) break;

                                   

                                    try        {

                                                BufferedReader br= new BufferedReader(new FileReader(fn));

                                               

                                    while((data=br.readLine())!=null)

                                    {

                                                tosend=tosend+data;//+"*";

                                    }

                                   

                                                out.println(tosend);

                                   

                                                System.out.println("The transferred file name is :"+fn);

                                                System.out.println(tosend);

                                   

                                                }catch(Exception e) {System.out.println ("File not found");}

                        }

            }

}         

3 Database :

import java.net.*;

import java.io.*;

import java.sql.*;

import java.util.*;

class client

{

            public static void main(String a[])

            {

                        String res="";

                        try

                        {

                        Socket cs=new Socket("localhost",8888);

                        System.out.println("Connected with Server...");

                        DataInputStream dis = new DataInputStream(cs.getInputStream());

                        DataInputStream udis = new DataInputStream(System.in);

                        PrintStream ps =new PrintStream(cs.getOutputStream());

                        while(true){

                        System.out.println("Database Server");

                        System.out.println("1:Add Data ");

                        System.out.println("2:View Data ");

                        System.out.println("3:Exit");

                        System.out.print("\n\nEnter the Choice :");

                        int choice=Integer.parseInt(udis.readLine());

                        switch(choice)

                        {

                        case 1:

                                                ps.println("1");

                                                System.out.print("Enter Name : ");

                                                String nam=udis.readLine();

                                                System.out.print("Enter City : ");

                                                String city =udis.readLine();

                                                System.out.print("Enter Age : ");

                                                String age =udis.readLine();

                                                String inp=nam+"@"+city+"@"+age;

                                                ps.println(inp);

                                                break;

                                               

                        case 2:

                                                ps.println("2");

                                                res=dis.readLine();

                                                StringTokenizer Stt =new StringTokenizer(res,"#");

                                                while(Stt.hasMoreTokens())

                                                {

                                                            String temp=Stt.nextToken();

                                                            System.out.println(temp);

                                                }

                                                break;

                        case 3:

                                                ps.println("3");

                                                System.exit(0);            

                        default:

                                                 System.out.print("Enter choice between 1 and 3");

                                                 break;

                         }

                }

              }catch(Exception e){e.getMessage();}

    }

}

import java.net.*;

import java.io.*;

import java.sql.*;

import java.util.*;

class server

{

            public static void main(String a[])

            {

                        Connection con;

                        Statement stat;

                        try

                        {

                                    System.out.println("Waiting for Client...");

                                    ServerSocket ss= new ServerSocket(8888);

                                    Socket s=ss.accept();

                                    System.out.println("Client Connected");

                                    DataInputStream dis = new DataInputStream(s.getInputStream());

                                    PrintStream ps =new PrintStream(s.getOutputStream());

                                    while(true){

                                    int ch=Integer.parseInt(dis.readLine());

                                    switch(ch)

                                    {

                                    case 1:

                                                            int pk=0;int c=0;

                                                            String inp[] = new String[3];

                                                            Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

                                                            con=DriverManager.getConnection("jdbc:odbc:user","","");

                                                            stat=con.createStatement();

                                                            ResultSet rs = stat.executeQuery("select * from user");

                                                            while(rs.next())

                                                            pk=Integer.parseInt(rs.getString(1));

                                                            pk+=1;

                                                            rs.close();

                                                            con.close();

                                                            stat.close();

                                                            String data=dis.readLine();

                                                            StringTokenizer stt = new StringTokenizer(data,"@");            

                                                            while(stt.hasMoreTokens())

                                                            {

                                                                        inp[c]=stt.nextToken();

                                                                        c++;

                                                            }

                                                            Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

                                                            con=DriverManager.getConnection("jdbc:odbc:user","","");

                                                            stat=con.createStatement();

                                                            int age=Integer.parseInt(inp[2]);

                                                            int cc=stat.executeUpdate("INSERT INTO user (id,name,address,age) VALUES ("+pk+",'"+inp[0]+"','"+inp[1]+"',"+age+")");

                                                    con.close();

                                                            stat.close();

                                                    break;                     

                                    case 2:

                                                            String resq=""; 

                                                            Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

                                                            con=DriverManager.getConnection("jdbc:odbc:user","","");

                                                            stat=con.createStatement();

                                                            rs = stat.executeQuery("select * from user");

                                                            while(rs.next())

                                                            {

                                                                        String temp=rs.getString(1)+"    "+rs.getString(2)+"    "+rs.getString(3)+"    "+rs.getString(4);

                                                                        resq+=temp+"#";

                                                            }

                                                            ps.println(resq);

                                                            con.close();

                                                            stat.close();

                                                            break;

                                    case 3:

                                           System.exit(0);                 

                                    }

                        }

              }catch(Exception e){ e.printStackTrace();}

            }

}

4 – HTML

import java.io.*;

import java.net.*;

class cli

{

  public static void main(String ar[])

  {

    try

    {

      Socket s=new Socket("localhost",8888);

      DataInputStream in =new DataInputStream(System.in);

      DataInputStream din=new DataInputStream(s.getInputStream());

      PrintStream p=new PrintStream(s.getOutputStream());

      String str="",str1="",encrypt="";

      System.out.println("Enter HTML File Name");

      str=in.readLine();

      for(int i=0;i<str.length();i++)

                        {

                                    char ch=str.charAt(i);

                                    encrypt+=(char)((int)ch+2);

                       

                        }

      p.println(encrypt);

      while(str1!=null)

      {

        str1=din.readLine();

        System.out.println(str1);

        }

    }

    catch(Exception e)

    {

   //  System.out.println();

    }

  }

}

import java.io.*;

import java.net.*;

class ser

{

   public static void main(String ar[])

   {

     try

     {

       ServerSocket ss=new ServerSocket(8888);

       Socket s=ss.accept();

       DataInputStream in=new DataInputStream(s.getInputStream());

       PrintStream p=new PrintStream(s.getOutputStream());

       String str,str1,decrypt="";

       str=in.readLine();

            for(int i=0;i<str.length();i++)

                        {

                                    char ch=str.charAt(i);

                                    decrypt+=(char)((int)ch-2);

                       

                        }

       FileReader fr=new FileReader(decrypt);

       System.out.print(decrypt);

       BufferedReader br=new BufferedReader(fr);

       while((str1=br.readLine())!=null)

       {

        System.out.println(str1);

        p.println(str1);

        }

  //     Runtime.getRuntime().exec("c:\\windows\\explorer.exe"+"  "+str);

  Runtime.getRuntime().exec("c:\\WINDOWS\\explorer.exe"+"  "+decrypt);

 

     }

     catch(Exception e)

     {

       System.out.println(e);

     }

   }

}

05 FTP

import java.io.*;

import java.net.*;

import java.util.*;

class client

{

            public static void main (String[] args)throws IOException

                        {

                                    Socket sck=new Socket("localhost",3000);

                                   

                                    DataInputStream ds=new DataInputStream(System.in);

                                   

                                    DataInputStream in=new DataInputStream(sck.getInputStream());

                                    PrintStream out=new PrintStream(sck.getOutputStream());

                                   

                                    String sfilename="";

                                    String dfilename="";

                                   

                                    String rec="";

                                   

                                    while(true)

                                    {

                                               

                                                String towrite="";

                                                System.out.println("Enter the Source file name to transfer:");

                                                sfilename=ds.readLine();

                                               

                                                if(sfilename.equals("end"))

                                                {

                                                            out.println("end");

                                                            break;

                                                }

                                                out.println(sfilename);

                                               

                                                rec=in.readLine();

                                               

                                                /*StringTokenizer st=new StringTokenizer(rec,"*");

                                                while(st.hasMoreTokens())

                                                {

                                                            towrite=towrite+st.nextToken()+"\n";

                                                }*/

                                               

                                                FileWriter fw=new FileWriter("__"+sfilename);

                                                fw.write(rec);

                                                fw.close();

                                                                                               

                                                //System.out.println(towrite);

                                                System.out.println("Files Received and Saved as "+"__"+sfilename);

                                    }

                        }

}

import java.io.*;

import java.net.*;

class server

{

            public static void main (String[] args)throws IOException

            {

                        ServerSocket ssck=new ServerSocket(3000);

                        Socket sck=ssck.accept();

                       

                                    DataInputStream ds=new DataInputStream(System.in);

                                   

                                    DataInputStream in=new DataInputStream(sck.getInputStream());

                                    PrintStream out=new PrintStream(sck.getOutputStream());

                                   

                                    String filename="";

                                    while(true)

                                    {

                                                String tosend="";

                                                filename=in.readLine();

                                                if(filename.equals("end"))

                                                {

                                                            break;

                                                }

                                                try

                                                {

                                                           

                                                            String c;

                                                            FileReader fr=new FileReader(filename);

                                                            BufferedReader b=new BufferedReader(fr);

                                                           

                                                            while((c=b.readLine())!=null)

                                                            {

                                                                        tosend=tosend+c;//+"*";

                                                            }

                                                           

                                                            System.out.println("Sending files:");

                                                            out.println(tosend);

                                                }

                                                catch(Exception e)

                                                {

                                                            System.out.println("No such files found");

                                                }

                                    }

            }

}

05 FTP

//FtpServer.java

import java.io.*;

import java.net.*;

public class FtpServer

{

     public static void main(String [] args)

     {

          int i=1;

System.out.println("*****************************************");

          System.out.println("*******   FTP SERVER****************");

System.out.println("********************************************");

          System.out.println("Server Started...");

          System.out.println("Waiting for connections...");

          System.out.println(" ");

          try

          {

               ServerSocket s = new ServerSocket(100);

               for(;;)

               {

                    Socket incoming = s.accept();

                    System.out.println("New Client Connected with id " + i+" from "+incoming.getInetAddress().getHostName()+"..." );

                    Thread t = new ThreadedServer(incoming,i);

                    i++;

                    t.start();

               }

          }

          catch(Exception e)

          {

               System.out.println("Error: " + e);

          }

     }

}

class ThreadedServer extends Thread

{

     int n;

     String c,fn,fc;

     String filenm;

     Socket incoming;

     int counter;

     String dirn="c:/FTP SERVER DIRECTORY";

     public ThreadedServer(Socket i,int c)

     {

          incoming=i;

          counter=c;

     }

     public void run()

     {

          try

          {

               BufferedReader in =new BufferedReader(new

InputStreamReader(incoming.getInputStream()));

               PrintWriter out = new

PrintWriter(incoming.getOutputStream(), true);

               OutputStream output=incoming.getOutputStream();

               fn=in.readLine();

               c=fn.substring(0,1);

               if(c.equals("#"))

               {

               n=fn.lastIndexOf("#");

               filenm=fn.substring(1,n);

               FileInputStream fis=null;

               boolean filexists=true;

               System.out.println("Request to download file "+filenm+"recieved from "+incoming.getInetAddress().getHostName()+"...");

               try

                 {

                  fis=new FileInputStream(filenm);

                 }

               catch(FileNotFoundException exc)

                 {

                  filexists=false;

                  System.out.println("FileNotFoundException:"+exc.getMessage());

                 }

                if(filexists)

                {

                 sendBytes(fis, output) ;

                         fis.close();

                }

               }

              else

                 {

                  try

                  {

                  boolean done=true;

                  System.out.println("Request to upload file " +fn+"recieved from "+incoming.getInetAddress().getHostName()+"...");

                  File dir=new File(dirn);

                  if(!dir.exists())

                  {

                   dir.mkdir();

                  }

                  else

                  {}

                    File f=new File(dir,fn);

                    FileOutputStream fos=new FileOutputStream(f);

                    DataOutputStream dops=new DataOutputStream(fos);

                   while(done)

                   {

                    fc=in.readLine();

                    if(fc==null)

                    {

                     done=false;

                    }

                    else

                    {

                     dops.writeChars(fc);

                    // System.out.println(fc);

                    }

                 }

                 fos.close();

                 }

                 catch(Exception ecc)

                 {

                  System.out.println(ecc.getMessage());

                 }

                }

               incoming.close();

          }

          catch(Exception e)

          {

               System.out.println("Error: " + e);

          }

     }

     private static void sendBytes(FileInputStream f,OutputStream op)throws Exception

     {

      byte[] buffer=new byte[1024];

      int bytes=0;

      while((bytes=f.read(buffer))!=-1)

      {

       op.write(buffer,0,bytes);

      }

     }

}

//FtpClient.java

import java.net.*;

import java.io.*;

import java.awt.*;

import java.awt.event.*;

import javax.swing.*;

import java.lang.*;

class FtpClient extends JFrame implements ActionListener

{

 String fn,filenm;

 String fc;

 String dirn="c:/FTP CLIENT DIRECTORY";

 JPanel pnl;

 JLabel lbltle,lblud;

 Font fnt;

 JTextField txtfn;

 JButton btnu,btnd;

 Socket s;

 InputStreamReader in;

 OutputStream out;

 BufferedReader br;

 PrintWriter pw;

 public FtpClient()

 {

  super("FTP CLIENT");

  pnl=new JPanel(null);

  fnt=new Font("Times New Roman",Font.BOLD,25);

  lbltle=new JLabel("FTP CLIENT");

  lbltle.setFont(fnt);

  lbltle.setBounds(225,35,200,30);

  pnl.add(lbltle);

  lblud=new JLabel("ENTER  FILE-NAME :");

  lblud.setBounds(100,100,150,35);

  pnl.add(lblud);

  txtfn=new JTextField();

  txtfn.setBounds(300,100,200,25);

  pnl.add(txtfn);

  btnu=new JButton("UPLOAD");

  btnu.setBounds(150,200,120,35);

  pnl.add(btnu);

  btnd=new JButton("DOWNLOAD");

  btnd.setBounds(320,200,120,35);

  pnl.add(btnd);

  btnu.addActionListener(this);

  btnd.addActionListener(this);

  getContentPane().add(pnl);

  try

  {

  s=new Socket("localhost",100);

  br=new BufferedReader(new InputStreamReader(s.getInputStream()));

  pw=new PrintWriter(s.getOutputStream(),true);

  out=s.getOutputStream();

  }

  catch(Exception e)

  {

   System.out.println("ExCEPTION :"+e.getMessage());

  }

 }

 public void actionPerformed(ActionEvent e)

 {

  if(e.getSource()==btnu)

  {

   try

   {

   filenm=txtfn.getText();

   pw.println(filenm);

   FileInputStream  fis=new FileInputStream(filenm);

   byte[] buffer=new byte[1024];

   int bytes=0;

   while((bytes=fis.read(buffer))!=-1)

   {

    out.write(buffer,0,bytes);

   }

   fis.close();

  }

  catch(Exception exx)

  {

   System.out.println(exx.getMessage());

  }

  }

  if(e.getSource()==btnd)

  {

   try

   {

   File dir=new File(dirn);

   if(!dir.exists())

   {

    dir.mkdir();

   }

   else{}

   boolean done=true;

   filenm=txtfn.getText();

   fn=new String("#"+filenm+"#");

   //System.out.println(filenm);

   pw.println(fn);

   File f=new File(dir,filenm);

   FileOutputStream fos=new FileOutputStream(f);

   DataOutputStream dops=new DataOutputStream(fos);

   while(done)

   {

     fc=br.readLine();

     if(fc==null)

     {

     done=false;

     }

    else

        {

          dops.writeChars(fc);

       //  System.out.println(fc);

        }

    }

   fos.close();

  }

  catch(Exception exx)

  {}

  }

 }

 public static void main(String args[])

 {

  FtpClient ftpc=new FtpClient();

  ftpc.setSize(600,300);

  ftpc.show();

 }

}

6.Concatenation

client1

import java.net.*;

import java.io.*;

import java.sql.*;

import java.util.*;

class concli1

{

            public static void main(String a[]) throws IOException

            {

                        Socket S1=new Socket(InetAddress.getLocalHost(),7070);

                        System.out.println("Connected with Server1");

                        DataInputStream DIS = new DataInputStream(System.in);

                        DataInputStream DS1 = new DataInputStream(S1.getInputStream());

                        PrintStream PS = new PrintStream(S1.getOutputStream());

                       

                        System.out.print("Enter key1 : ");

                        String k1=DIS.readLine();

                        PS.println(k1.trim());

                        System.out.println(DS1.readLine());

                       

                       

            }

}

client2

import java.net.*;

import java.io.*;

import java.sql.*;

import java.util.*;

class concli2

{

            public static void main(String a[]) throws Exception

            {

                        Socket S2=new Socket(InetAddress.getLocalHost(),7000);

                        System.out.println("Connected with Server1");

                        DataInputStream DIS = new DataInputStream(System.in);

                        DataInputStream DS2 = new DataInputStream(S2.getInputStream());

                        PrintStream PS = new PrintStream(S2.getOutputStream());

                       

                        System.out.print("Enter key1 : ");

                        String k2=DIS.readLine();

                        PS.println(k2.trim());

                        System.out.println(DS2.readLine());

                       

                       

            }

}

server1

import java.net.*;

import java.io.*;

import java.sql.*;

import java.util.*;

class conser1

{

            public static void main(String a[]) throws Exception

            {

                        Socket S1=new Socket(InetAddress.getLocalHost(),7777);

                        System.out.println("Connected with Server2");

                        ServerSocket CSS1 = new ServerSocket(7070);

                        Socket CS1 =CSS1.accept();

                        ServerSocket CSS2 = new ServerSocket(7000);

                        Socket CS2 =CSS2.accept();

                       

                        DataInputStream DIS1 = new DataInputStream(S1.getInputStream());

                        DataInputStream CIS1 = new DataInputStream(CS1.getInputStream());

                        DataInputStream CIS2 = new DataInputStream(CS2.getInputStream());

                        PrintStream PS1 = new PrintStream(S1.getOutputStream());

                        PrintStream PS2 = new PrintStream(CS1.getOutputStream());

                        PrintStream PS3 = new PrintStream(CS2.getOutputStream());

                       

                        String k1=CIS1.readLine();

                        String k2=CIS2.readLine();

                        PS1.println(k1+k2);

                        String res=DIS1.readLine();

                        System.out.println(res);

                        PS2.println(res);

                        PS3.println(res);

                       

            }

}

server2

import java.net.*;

import java.io.*;

import java.sql.*;

import java.util.*;

class server2con

{

            public static void main(String a[]) throws Exception

            {

                        String ans="";

                       

                        ServerSocket SS2 = new ServerSocket(7777);

                        System.out.println("Waiting for Server1...");

                        Socket S2 =SS2.accept();

                        System.out.println("Server1 Connected");

                        DataInputStream DIS2 = new DataInputStream(S2.getInputStream());

                        PrintStream PS2 = new PrintStream(S2.getOutputStream());

                        String inp = DIS2.readLine();

                        Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

                Connection con=DriverManager.getConnection("Jdbc:Odbc:record3","","");

                        Statement stat = con.createStatement();

                String query = "Select name from record3 where regno = '"+inp+"'";

                        ResultSet rs = stat.executeQuery(query);

                        while(rs.next())

                        ans =rs.getString(1);

                        if(ans!="")

                        PS2.println("Record for key "+inp+" is "+ans);

                        else PS2.println("Record Not Found");                       

            }

}

7. cell number

client1

import java.net.*;

import java.io.*;

import java.sql.*;

import java.util.*;

class celclient

{

            public static void main(String a[]) throws Exception

            {

                        Socket S1=new Socket(InetAddress.getLocalHost(),7000);

                        System.out.println("Connected with Server1");

                        DataInputStream DIS = new DataInputStream(System.in);

                        DataInputStream DS1 = new DataInputStream(S1.getInputStream());

                        PrintStream PS = new PrintStream(S1.getOutputStream());

                       

                        System.out.print("Enter Cell no : ");

                        String k1=DIS.readLine();

                        PS.println(k1.trim());

                String res = DS1.readLine();

                        StringTokenizer Stt =new StringTokenizer(res,"#");

                        while(Stt.hasMoreTokens())

                                    {

                                                String temp=Stt.nextToken();

                                                System.out.println(temp);

                                    }

                       

                       

            }

}

server 1

import java.net.*;

import java.io.*;

import java.sql.*;

import java.util.*;

import java.lang.*;

class celserver1

{

            public static void main(String a[]) throws Exception

            {

                        String ans="",total = ""; boolean chk=true;

                        System.out.println("Waiting for Client1...");

                        ServerSocket SS1 = new ServerSocket(7000);

                        Socket S1 =SS1.accept();

                        System.out.println("client Connected");

                        DataInputStream DIS1 = new DataInputStream(S1.getInputStream());

                        PrintStream PS1 = new PrintStream(S1.getOutputStream());

                        String cellno = DIS1.readLine();

                        String firstpart = cellno.substring(0,5);

                        String secondpart = cellno.substring(5,10);

                        Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

                        Connection con=DriverManager.getConnection("Jdbc:Odbc:cellfull","","");

                        Statement stat = con.createStatement();

                        String query = "Select company from cellcomp where compid = '"+firstpart+"'";

                        ResultSet rs = stat.executeQuery(query);

                        while(rs.next())

                        ans =rs.getString(1);

                        if(ans!="")

                        total=" Connection is " +ans+"#";

                        else chk= false;

                        rs.close();

                       

                        query = "Select uname  from cellhalf where cellcode = '"+secondpart+"'";

                        rs = stat.executeQuery(query);

                        while(rs.next())

                        ans =rs.getString(1);

                        if(ans!=""){

                       

                        total=total+" User name is " +ans+"#";

                        System.out.print(total);}

                        else chk = false;

                        rs.close();

                        stat.close();

                        con.close();

                        if (!chk)

                        {

                       

            Socket S2=new Socket(InetAddress.getLocalHost(),7777);

                        System.out.println("Connected with Server2");

                        DataInputStream DS2 = new DataInputStream(S2.getInputStream());

                        PrintStream PS2 = new PrintStream(S2.getOutputStream());

                PS2.println(cellno);

                PS1.println(DS2.readLine());

                        }

                        PS1.println(total);

                       

            }

}

server 2

import java.net.*;

import java.io.*;

import java.sql.*;

import java.util.*;

class celserver2

{

            public static void main(String a[]) throws Exception

            {

                        String ans="";

                        System.out.println("Waiting for Server1...");

                        ServerSocket SS2 = new ServerSocket(7777);

                        Socket S2 =SS2.accept();

                        System.out.println("Server1 Connected");

                        DataInputStream DIS2 = new DataInputStream(S2.getInputStream());

                        PrintStream PS2 = new PrintStream(S2.getOutputStream());

                        String inp = DIS2.readLine();

                        Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

                        Connection con=DriverManager.getConnection("Jdbc:Odbc:cellfull","","");

                        Statement stat = con.createStatement();

                        String query = "Select user from celltable where cellno = '"+inp+"'";

                        ResultSet rs = stat.executeQuery(query);

                        while(rs.next())

                        ans =rs.getString(1);

                        if(ans!=""){

                        PS2.println("Username for  "+inp+"  is "+ans);

                        }

                        else PS2.println("Record Not Found");                       

                        rs.close();

                        stat.close();

                        con.close();

            }

}

8. Balance

client

import java.io.*;

import java.net.*;

class balclinet

{

   public static void main(String ar[])

   {

   try

   {

    Socket s=new Socket("localhost",7777);

    DataInputStream in=new DataInputStream(System.in);

    PrintStream p=new PrintStream(s.getOutputStream());

    DataInputStream din=new DataInputStream(s.getInputStream());

    String str,str1;

    System.out.println("Enter  Account Number");

    str=in.readLine();

    p.println(str);

    System.out.println("====Server Reply=====");

    str1=din.readLine();

    System.out.println(str1);

   }

   catch(Exception e)

   {

    System.out.println(e);

   }

  }

}

server 1

import java.io.*;

import java.net.*;

import java.sql.*;

class balserver1

{

   public static void main(String ar[])

   {

   try

   {

     ServerSocket ss=new ServerSocket(7777);

     Socket s=ss.accept();

     DataInputStream din=new DataInputStream(s.getInputStream());

     PrintStream p=new PrintStream(s.getOutputStream());

     String str,str1="",str2;

     str=din.readLine();

     System.out.println(str);

     int flag=0;

     Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

     Connection con=DriverManager.getConnection("jdbc:odbc:db1");

     Statement smt=con.createStatement();

     ResultSet rs=smt.executeQuery("select * from lab71 where AccuntNo="+str+"");

     while(rs.next())

     {

     str1=rs.getString(1)+" "+rs.getString(2)+" "+rs.getString(3);

     flag=1;

     }

     if(flag==1)

     {

       System.out.println("Record Found");

       p.println(str1);

     }

      else

      {

       Socket s1=new Socket("localhost",7771);

       PrintStream p1=new PrintStream(s1.getOutputStream());

       DataInputStream din1=new DataInputStream(s1.getInputStream());

       System.out.println("Record is Not Available in server1.So Account Number sending to server2");

       p1.println(str);

     

       str2=din1.readLine();

      System.out.println(str2);

       p.println(str2);

      }

   }

   catch(Exception e)

   {

    System.out.println(e);

   }

 }

}

server 2

import java.io.*;

import java.net.*;

import java.sql.*;

class balserver2

{

  public static void main(String ar[])

  {

   try

     {

       ServerSocket ss=new ServerSocket(7771);

       Socket s=ss.accept();

       DataInputStream din=new DataInputStream(s.getInputStream());

       PrintStream p=new PrintStream(s.getOutputStream());

       String str,str1="",str2="";

       str=din.readLine();

       System.out.println(str);

       int flag=0;

       Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

       Connection con=DriverManager.getConnection("jdbc:odbc:db2");

       Statement smt=con.createStatement();

       ResultSet rs=smt.executeQuery("select * from lab72 where AccuntNo="+str+"");

       while(rs.next())

       {

         str1=rs.getString(1)+" "+rs.getString(2)+" "+rs.getString(3);

         flag=1;

       }

       if(flag==1)

       {

          System.out.println("Record Found In server2");

           p.println(str1);

       }

       else

       {

        System.out.println("Record Also not Found in Server2");

        p.println("Record Also not Found in Server2");

       }

      }

      catch(Exception e)

     {

       System.out.println(e);

     }

   }

}

9. Bank

client

import java.net.*;

import java.io.*;

import java.sql.*;

import java.util.*;

class bakcli

{

            public static void main(String a[])

throws Exception

            {

                        String arr[] =new String[3];int

i=0;

                        Socket S1=new

Socket(InetAddress.getLocalHost(),7000);

                        System.out.println("Connected with Server1");

                        DataInputStream DIS = new

DataInputStream(System.in);

                        DataInputStream DS1 = new

DataInputStream(S1.getInputStream());

                        PrintStream PS = new

PrintStream(S1.getOutputStream());

                        System.out.print("Enter credit card no : ");

                        String k1=DIS.readLine();

                PS.println(k1.trim());

                String res = DS1.readLine();

                if(res.equals("Record Not Found"))

                System.out.println("Record Not Found");

                else{

                        StringTokenizer Stt =new

StringTokenizer(res,"#");

                        while(Stt.hasMoreTokens())

                                    {

                                                String

temp=Stt.nextToken();

                                                arr[i]=temp;

                                                i++;

                                    }

                                               

                        System.out.println("Customer name is "+arr[0]);

                        System.out.println("Balance is  "  +arr[1]);

             }

            }

}

server 1

import java.net.*;

import java.io.*;

import java.sql.*;

import java.util.*;

import java.lang.*;

class bankser1

{

            public static void main(String a[]) throws Exception

            {

                        char ch;String encrypt="";

                        System.out.println("Waiting for Client...");

                        ServerSocket SS1 = new ServerSocket(7000);

                        Socket S1 =SS1.accept();

                        System.out.println("client Connected");

                        DataInputStream DIS1 = new DataInputStream(S1.getInputStream());

                        PrintStream PS1 = new PrintStream(S1.getOutputStream());

                        String creditno = DIS1.readLine();      

                        for(int i=0;i<creditno.length();i++)

                        {

                                    ch=creditno.charAt(i);

                                    encrypt+=(char)((int)ch+12);

                       

                        }

                        Socket S2=new Socket(InetAddress.getLocalHost(),7777);

                        System.out.println("Connected with Server2");

                        DataInputStream DS2 = new DataInputStream(S2.getInputStream());

                        PrintStream PS2 = new PrintStream(S2.getOutputStream());

                PS2.println(encrypt);

                String res =DS2.readLine();

                if(res.equals("Record Not Found"))

                {

                  PS1.println("Record Not Found");

                }

                else{

                        String decrypt="";

                        StringTokenizer Stt =new StringTokenizer(res,"+*=");

                        while(Stt.hasMoreTokens())

                                    {

                                                String temp=Stt.nextToken();

                                                for(int i=0;i<temp.length();i++)

                                                {

                                                            ch=temp.charAt(i);

                                                            decrypt+=(char)((int)ch-4);

                                               

                                                }

                                                decrypt+="#";

                        }

              

               System.out.print(decrypt);

               PS1.println(decrypt);

             }        

                       

            }

}

server 2

import java.net.*;

import java.io.*;

import java.sql.*;

import java.util.*;

class bankser2

{

            public static void main(String a[]) throws Exception

            {

                        String ans1="",ans2="";char ch;String encrypt="",decrypt="";

                        System.out.println("Waiting for Server1...");

                        ServerSocket SS2 = new ServerSocket(7777);

                        Socket S2 =SS2.accept();

                        System.out.println("Server1 Connected");

                        DataInputStream DIS2 = new DataInputStream(S2.getInputStream());

                        PrintStream PS2 = new PrintStream(S2.getOutputStream());

                        String inp = DIS2.readLine();

                        for(int i=0;i<inp.length();i++)

                        {

                                    ch=inp.charAt(i);

                                    decrypt+=(char)((int)ch-12);

                       

                        }

                        Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

                        Connection con=DriverManager.getConnection("Jdbc:Odbc:bankcredit","","");

                        Statement stat = con.createStatement();

                        String query = "Select Custname,balance from credittable where creditno = '"+decrypt+"'";

                        ResultSet rs = stat.executeQuery(query);

                        while(rs.next()){

                        ans1 =rs.getString(1);

                        ans2=rs.getString(2);

                        }

                        if(ans1!=""){

                        for(int i=0;i<ans1.length();i++)

                        {

                                    ch=ans1.charAt(i);

                                    encrypt+=(char)((int)ch+4);

                       

                        }

                        encrypt+="+*=";

                        if(ans2!=""){

                        for(int i=0;i<ans2.length();i++)

                        {

                                    ch=ans2.charAt(i);

                                    encrypt+=(char)((int)ch+4);

                       

                        }

                        }

                        PS2.println(encrypt);

                        }

                        else PS2.println("Record Not Found");                       

                        rs.close();

                        stat.close();

                        con.close();

            }

}

10.complement

client

import java.io.*;

import java.net.*;

import java.util.*;

class compcli

{

   public static void main(String ar[])

   {

     try

     {

       Socket s=new Socket("localhost",7000);

       Socket s1=new Socket("localhost",7100);

       String str,a,b,c="";

       StringTokenizer st;

       DataInputStream in=new DataInputStream(System.in);

       PrintStream p=new PrintStream(s.getOutputStream());

       PrintStream p1=new PrintStream(s1.getOutputStream());

       DataInputStream din=new DataInputStream(s.getInputStream());

       DataInputStream din1=new DataInputStream(s1.getInputStream());

       System.out.println("Enter Five Pair of Values of (A,B)");

       for(int j=1;j<=5;j++)

       {

         System.out.println("Enter "+j+" pair of(A,B)");

         str=in.readLine();

         st=new StringTokenizer(str,",");

         a=st.nextToken();

         b=st.nextToken();

         p.println(b);

         p1.println(a);

         c=din1.readLine();

         System.out.println("=======Server Reply====");

         System.out.println("Value of C is"+ c);

       }

    

  /*     while(true)

       {

        c=din1.readLine();

        System.out.println("Value of C is"+ c);

       }                                       */

     }

     catch(Exception e)

     {

       System.out.println(e);

     }

   }

}

server 1

import java.io.*;

import java.net.*;

class compser1

{

   public static void main(String ar[])

   {

     try

     {

      ServerSocket ss=new ServerSocket(7000);

      Socket s=ss.accept();

      Socket s1=new Socket("localhost",7200);

      DataInputStream din=new DataInputStream(s.getInputStream());

      PrintStream p=new PrintStream(s1.getOutputStream());

      String b,a;

      int i,j,k;

      for(int jk=1;jk<=5;jk++)  //while(b!=null)and initialised b.

      {

        b=din.readLine();

        i=Integer.parseInt(b);

        j=~i+1;

        System.out.println("B value is "+b+" B's 2's Complement is " +j);

        p.println(j);

      }

     }

     catch(Exception e)

     {

       System.out.println();

     }

   }

}

server 2

import java.io.*;

import java.net.*;

class compser2

{

   public static void main(String ar[])

   {

     try

     {

      ServerSocket ss=new ServerSocket(7100);

      Socket s=ss.accept();

      ServerSocket ss1=new ServerSocket(7200);

      Socket s1=ss1.accept();

      DataInputStream din=new DataInputStream(s.getInputStream());

      DataInputStream din1=new DataInputStream(s1.getInputStream());

      PrintStream p=new PrintStream(s.getOutputStream());

      String a="",b,c;

      int i,j,k;

     for(int jk=1;jk<=5;jk++)

      {

       a=din.readLine();

       i=Integer.parseInt(a);

       b=din1.readLine();

       j=Integer.parseInt(b);

       k=i+j;

       System.out.println("A+B's 2's Copliment is"+k);

       p.println(k);

      }

     }

     catch(Exception e)

     {

       System.out.println();

     }

   }

}

11. Mixed Expression

client 1

import java.io.*;

import java.net.*;

import java.util.*;

class mixcli1

{

            public static void main(String s[]) throws Exception

            {

                        DataInputStream inp=new DataInputStream(System.in);

                        Socket ser=new Socket(InetAddress.getLocalHost(),4561);

                        DataInputStream sin=new DataInputStream(ser.getInputStream());

                        PrintStream sout=new PrintStream(ser.getOutputStream());

                        String exp,res;

//                      System.out.println(ser);

                        System.out.print("Enter Expression : ");

                        exp=inp.readLine();

                        sout.println(exp);

                        System.out.println("Expression Sent to the server...");

                        res=sin.readLine();

                        System.out.println("Result : "+res);

            }

}

server 1

import java.io.*;

import java.net.*;

import java.util.*;

class mixser1

{

            public static void main(String s[]) throws Exception

            {

                        ServerSocket ss=new ServerSocket(4561);

                        Socket cli;

                        DataInputStream cin;

                        PrintStream cout;

                        String exp,res;

                        while(true)

                        {

                       

                        cli=ss.accept();

                        cin=new DataInputStream(cli.getInputStream());

                        cout=new PrintStream(cli.getOutputStream());

                        System.out.println("-----------------------------------------------");

                        exp=cin.readLine();

                        System.out.println("Expression : " + exp);

                        res=processExpr(exp);

                        cout.println(res);

                        System.out.println("-----------------------------------------------");

                        }

 }

            public static boolean isFinalExpr(String exp) throws Exception

            {

                        StringTokenizer st=new StringTokenizer(exp,"+-*/");

                        if(st.countTokens()>2)

                                    return false;

                        else

                                    return true;

            }

            public static String processExpr(String exp) throws Exception

            {

                        DataInputStream inp=new DataInputStream(System.in);

                        if(isFinalExpr(exp))

                                    return processFinalExpr(exp);

                       

                        StringTokenizer st=new StringTokenizer(exp,"+");

                        String tmp,t,f,s;

                        System.out.println(st.countTokens());

                        if(st.countTokens()==2)

                        {

                                    f=st.nextToken();

                                    s=st.nextToken();

                                    tmp= f + "+" + s;

                                    System.out.println(tmp);                     

                                    t=inp.readLine();

                                    return processExpr(processExpr(f) + "+" + processExpr(s));

                        }

                                   

                        st=new StringTokenizer(exp,"-");

                        if(st.countTokens()==2)

                        {

                                    f=st.nextToken();

                                    s=st.nextToken();

                                    tmp= f + "-" + s;

                                    System.out.println(tmp);                     

                                    t=inp.readLine();

                                    return processExpr(processExpr(f) + "-" + processExpr(s));

                        }

                        st=new StringTokenizer(exp,"*");

                        if(st.countTokens()==2)

                        {

                                    f=st.nextToken();

                                    s=st.nextToken();

                                    tmp= f + "*" + s;

                                    System.out.println(tmp);                     

                                    t=inp.readLine();

                                    return processExpr(processExpr(f) + "*" + processExpr(s));

                        }

                        st=new StringTokenizer(exp,"/");

                        if(st.countTokens()==2)

                        {

                                    f=st.nextToken();

                                    s=st.nextToken();

                                    tmp= f + "/" + s;

                                    System.out.println(tmp);                     

                                    t=inp.readLine();

                                    return processExpr(processExpr(f) + "/" + processExpr(s));

                        }

                        return exp;

            }

            public static String processFinalExpr(String exp) throws Exception

            {

                        String res;

                        StringTokenizer t1=new StringTokenizer(exp,"+-");

                        StringTokenizer t2=new StringTokenizer(exp,"*/");

                        System.out.println(exp);

                        if(t1.countTokens()>1)

                        {

                                    Socket ser2=new Socket(InetAddress.getLocalHost(),4562);

           

                                    DataInputStream s2in=new DataInputStream(ser2.getInputStream());

                                    PrintStream s2out=new PrintStream(ser2.getOutputStream());

                                    System.out.println("Plus or Minus (passed to Server S2)");

                                   

                                    s2out.println(exp);

                                    System.out.println("Expression Sent to the server S2...");

           

                                    res=s2in.readLine();

                                    System.out.println("Result from S2 : "+res);

                        }

                        else if(t2.countTokens()>1)

                        {

                                    Socket ser3=new Socket(InetAddress.getLocalHost(),4563);

           

                                    DataInputStream s3in=new DataInputStream(ser3.getInputStream());

                                    PrintStream s3out=new PrintStream(ser3.getOutputStream());

                                    System.out.println("Multiply or Division (passed to Server S3)");

           

                                    s3out.println(exp);

                                    System.out.println("Expression Sent to the server S3...");

                                    res=s3in.readLine();

                                    System.out.println("Result from S3 : "+res);

                        }

                        else

                        {

                                    res=exp;

                                    System.out.println(res);

                        }

                        return res;

            }

}

server 2

import java.io.*;

import java.net.*;

import java.util.*;

class mixser2

{

            public static void main(String s[]) throws Exception

            {

                        ServerSocket ss=new ServerSocket(4562);

                        Socket cli;

                        DataInputStream cin;

                        PrintStream cout;

                        String exp,res;

                        while(true)

                        {

                        cli=ss.accept();

                        cin=new DataInputStream(cli.getInputStream());

                        cout=new PrintStream(cli.getOutputStream());

                        System.out.println("-----------------------------------------------");

                        exp=cin.readLine();

                        System.out.println("Expression : " + exp);

                        StringTokenizer t1=new StringTokenizer(exp,"+");

                        StringTokenizer t2=new StringTokenizer(exp,"-");

                        if(t1.countTokens()>1)

                        {

                                    int a,b,c;

                                    a=Integer.parseInt(t1.nextToken().trim());

                                    b=Integer.parseInt(t1.nextToken().trim());

                                    c=a+b;

                                    res="" + c;

                                    System.out.println("Result : "+res);

                        }

                        else if(t2.countTokens()>1)

                        {

                                    int a,b,c;

                                    a=Integer.parseInt(t2.nextToken().trim());

                                    b=Integer.parseInt(t2.nextToken().trim());

                                    c=a-b;

                                    res="" + c;

                                    System.out.println("Result : "+res);

                        }

                        else

                        {

                                    res="<Invalid Expression>";

                                    System.out.println(res);

                        }

                        cout.println(res);

                        System.out.println("-----------------------------------------------");

                        }

            }

}

server 3

import java.io.*;

import java.net.*;

import java.util.*;

class S3

{

            public static void main(String s[]) throws Exception

            {

                        ServerSocket ss=new ServerSocket(4563);

                        Socket cli;

                        DataInputStream cin;

                        PrintStream cout;

                        while(true)

                        {

                        cli=ss.accept();

                        cin=new DataInputStream(cli.getInputStream());

                        cout=new PrintStream(cli.getOutputStream());

                        String exp,res;

                        System.out.println("-----------------------------------------------");

                        exp=cin.readLine();

                        System.out.println("Expression : " + exp);

                        StringTokenizer t1=new StringTokenizer(exp,"*");

                        StringTokenizer t2=new StringTokenizer(exp,"/");

                        if(t1.countTokens()>1)

                        {

                                    int a,b,c;

                                    a=Integer.parseInt(t1.nextToken().trim());

                                    b=Integer.parseInt(t1.nextToken().trim());

                                    c=a*b;

                                    res="" + c;

                                    System.out.println("Result : "+res);

                        }

                        else if(t2.countTokens()>1)

                        {

                                    int a,b,c;

                                    a=Integer.parseInt(t2.nextToken().trim());

                                    b=Integer.parseInt(t2.nextToken().trim());

                                    c=a/b;

                                    res="" + c;

                                    System.out.println("Result : "+res);

                        }

                        else

                        {

                                    res="<Invalid Expression>";

                                    System.out.println(res);

                        }

                        cout.println(res);

                        System.out.println("-----------------------------------------------");

                        }

            }

}