Sunday, 10 April 2011

it may help more

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
Network Programming






TEXT DISPLAYED WITH DIFF COLOR, SIZE, FONT IN DIFF BACKGROUND


Welcome to Client - Server Lab












MKU MCA



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;i2)
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="";
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="";
System.out.println(res);
}

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

}

}
}

No comments:

Post a Comment