Program-1

Program-1

Client-1

import java.net.*;

import java.io.*;

importjava.sql.*;

importjava.util.*;

class client1

{

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

  {

                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());

   }

}

Client-2          

import java.net.*;

import java.io.*;

importjava.sql.*;

importjava.util.*;

class client2

{

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());

                }

}

Server-1

import java.net.*;

import java.io.*;

importjava.sql.*;

importjava.util.*;

class server1

{

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);

  }

}

Server-2

import java.net.*;

import java.io.*;

importjava.sql.*;

importjava.util.*;

class server2

{

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:record","","");

                Statement stat = con.createStatement();

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

                ResultSetrs = 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");                   

  }

}