socket programs in java

8/9/2019 Socket Programs in Java

1/47

TCP

HELLO

Problem statement:

-----------server side programimport java.io.*;

import java.net.*;public class serverhello

{

Socket s;

public static void main(String arg[])

{try

{

ServerSocket ss=new ServerSocket(2500);

Socket s=ss.accept();

BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));PrintWriter pw=new PrintWriter(new OutputStreamWriter(s.getOutputStream()));

pw.println("hello client");

pw.flush();

}catch(Exception e)

{

}

}

}


2/47

-----------client side program

import java.io.*;

import java.net.*;

public class clienthello

{


{

try

{

Socket s;

String str;

InetAddress add=InetAddress.getByName(null);

s=new Socket(add,2500);

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

System.out.println(str);

}catch(Exception e)

{

}}

}


3/47

OUTPUT:

-------server

CLIENT:

--------client


4/47

IP ADDRESS

Problem statement:

---------------------server side

import java.io.*;

import java.net.*;public class servip

{


{

try

{Socket s;


s=ss.accept();

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

PrintWriter pw=new PrintWriter(new OutputStreamWriter(s.getOutputStream()));

InetAddress a=InetAddress.getLocalHost();pw.println(a.toString());

pw.flush();

}catch(Exception e)

{

}}

}


5/47

---------------client side

import java.io.*;

import java.net.*;

public class clientip

{public static void main(String arg[])

{

try

{

Socket s;InetAddress a=InetAddress.getByName(null);

s=new Socket(a,2566);

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

String str=br.readLine();

System.out.println(str);}

catch(Exception e)

{}

}

}


6/47

OUTPUT:

-------------server

----------client


7/47

FACTORIAL

Problem statement:

------------server side

import java.io.*;

import java.net.*;

public class servfactorial


{try

{

Socket s;ServerSocket ss=new ServerSocket(2510);

s=ss.accept();



String str;int num,fact=1,i;

while(true)

{str=br.readLine();

num=Integer.parseInt(str);

for(i=1;i


8/47

}

----------client side

import java.io.*;

import java.net.*;public class clientfactorial

{


{

try{

Socket s;

BufferedReader br =new BufferedReader(new InputStreamReader(System.in));

InetAddress a=InetAddress.getByName(null);s=new Socket(a,2510);

PrintWriter pw=new PrintWriter(new OutputStreamWriter(s.getOutputStream()));BufferedReader br1=new BufferedReader(new

InputStreamReader(s.getInputStream()));

String msg=br.readLine();

pw.println(msg);

pw.flush();String str=br1.readLine();


}

catch(Exception e){

}

}}


9/47

OUTPUT:

-----------server

---------client


10/47

PRIME

Problem statement:

-------server side

import java.io.*;

import java.net.*;

class primeserver{


{try

{Socket s;


s=ss.accept();


PrintWriter pw =new PrintWriter(new OutputStreamWriter(s.getOutputStream()));

String str ;int a,i;

while(true)

{str=br.readLine();

a=Integer.parseInt(str);

for(i=2;i


11/47

}

catch(Exception e){}

}

}

--------client side

import java.io.*;import java.net.*;

class primeclient

{

public static void main(String arg[]){

try{

Socket s;

BufferedReader br=new BufferedReader(new InputStreamReader(System.in));

InetAddress a= InetAddress.getByName(null);


PrintWriter pw=new PrintWriter(new OutputStreamWriter(s.getOutputStream()));BufferedReader br1=new BufferedReader(new


String msg=br.readLine();

pw.println(msg);

pw.flush();String str=br1.readLine();


}

catch(Exception e){

}

}}


12/47

OUTPUT:

--------server

-------client


13/47

STRING LENGTH

Problem statement:

-----------server side

import java.io.*;

import java.net.*;class strlenserv

{

public static void main(String arg[]){

try

{

Socket s;ServerSocket ss=new ServerSocket(2001);

s=ss.accept();



int i;String str;


14/47

while(true)

{

str=br.readLine();i=str.length();

pw.println("length of the string is"+i);

pw.flush();}

}

catch(Exception e){

}

}

}

--------client side


public class strlenclient


{

try{

Socket s;

BufferedReader br=new BufferedReader(new

InputStreamReader(System.in));InetAddress a=InetAddress.getByName(null);


PrintWriter pw=new PrintWriter(newOutputStreamWriter(s.getOutputStream()));

BufferedReader br1=new BufferedReader(new

InputStreamReader(s.getInputStream()));String msg=br.readLine();

pw.println(msg);

pw.flush();

String str=br1.readLine();


15/47


}catch(Exception e)

{

}}

}

OUTPUT:

----------server

-----client


16/47

FIBONACCI

Problem statement:

----------server side

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.BufferedReader;import java.io.PrintWriter;

import java.net.Socket;

import java.net.ServerSocket;class Practical_2b_Server

{

Socket s;


{int port=25000;

try{

ServerSocket ss=new ServerSocket(port);System.out.println("\nServer initialised, Waiting for client request");

Socket s=ss.accept();


17/47

Practical_2b_Server server=new Practical_2b_Server(s);

server.displayInformation();

catch(Exception e){

System.out.println("An exception has occurred :" +e);

}}

Practical_2b_Server(Socket s)

{this.s = s;

}

public void displayInformation()

{try

{

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

PrintWriter pw=new PrintWriter(new OutputStreamWriter(s.getOutputStream())) ;String str=br.readLine();

System.out.println ("Number sent from the client " + str);try

{

int term = Integer.parseInt(str);

String result = "";for (int i = 1 ; i


18/47

else

return calcFibo (num - 1) + calcFibo (num - 2);

}}

--------client side

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;import java.io.BufferedReader;

import java.io.PrintWriter;

import java.net.InetAddress;import java.net.Socket;

import java.net.ServerSocket;

class Practical_2b_Client{


{

int port=25000;

Socket s;

String msg="";try

{

BufferedReader br=new BufferedReader(new InputStreamReader(System.in));

InetAddress addr = InetAddress.getByName(null);

s=new Socket(addr,port);PrintWriter pw=new PrintWriter(new OutputStreamWriter(s.getOutputStream()));

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

System.out.print("\nEnter the number of terms : ");


19/47


pw.println(str);

pw.flush();msg=br1.readLine();

System.out.println(msg+"\n");

s.close();}

catch(Exception e)

{System.out.println("An Error has occurred");

}

}

}

OUTPUT:

------server

---------client


20/47

ECHO

Problem statement:

--------server side


import java.util.Calendar;

class echoserver{

static Calendar c= Calendar.getInstance();

public static void main(String arg[]) throws Exception{

Socket s;

ServerSocket ss=new ServerSocket(2006);s=ss.accept();

BufferedReader br=new BufferedReader(new

InputStreamReader(s.getInputStream()));PrintWriter pw=new PrintWriter(new OutputStreamWriter(s.getOutputStream()));


21/47

pw.println("Time: "+c.getTime());

pw.flush();

while(true){

String str2=br.readLine();

System.out.println(str2);if(str2.equals("exit"))

System.exit(0);

}

}}

---------client side

import java.io.*;

import java.net.*;class echoclient

{

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

{Socket s;

InetAddress a=InetAddress.getByName(null);

s=new Socket(a,2006);BufferedReader br=new BufferedReader(new


BufferedReader br1=new BufferedReader(new InputStreamReader(System.in));PrintWriter pw=new PrintWriter(new OutputStreamWriter(s.getOutputStream()));


pw.println(str);

while(true)


22/47

{

String str1=br1.readLine();

pw.println(str1);pw.flush();

if(str1.equals("exit"))

System.exit(0);}

}

}

OUTPUT:

----------server side

-------client side


23/47

DATE TIME

Problem statement :

--------server side

import java.io.*;

import java.net.*;

public class TServer{

public static void main(String args[])

{

try

{

ServerSocket ss = new ServerSocket(2500);while(true)

{

Socket s = ss.accept();


24/47

BufferedReader fromClient = new BufferedReader(new


DataOutputStream toClient = newDataOutputStream(s.getOutputStream());

String msg= fromClient.readLine();

System.out.println("Data from Client"+ msg);

// write data to clientjava.util.Date da = new java.util.Date();

String msgtoclient=da.toString();

toClient.writeBytes(msgtoclient+'\n');s.close();

}

}

catch(Exception e){

System.out.println("Eception e"+e);}

}

}

-------client side


public class TClient

{public static void main(String args[])

{

try{

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

BufferedReader num = new BufferedReader(new InputStreamReader(System.in));

String n= num.readLine();BufferedReader fromServer = new BufferedReader(new


DataOutputStream toServer= newDataOutputStream(s.getOutputStream());

String msg=n+"Please provide datetime";

toServer.writeBytes(msg+'\n');System.out.println("Date from server"+fromServer.readLine());

s.close();

}


25/47

catch(Exception e)

{

}}

}

OUTPUT:

-------server

------client


26/47

UDP

DATETIME

Problem statement ;

--------server side


public class UServer

{static byte send[] = new byte[1024];

static byte rev[] = new byte[1024];

public static void main(String args[])

{try

{


27/47

DatagramSocket ds = new DatagramSocket(6001);

DatagramPacket dp1= new DatagramPacket(rev,rev.length);

ds.receive(dp1);String fromClient = new String(dp1.getData(),0,dp1.getLength());

System.out.println("Data from Client"+fromClient);

// java.util.Date da = new java.util.Date();

String msgtoclient=da.toString();

send= msgtoclient.getBytes();

InetAddress ia= dp1.getAddress();

int port=dp1.getPort();DatagramPacket dp = new

DatagramPacket(send,send.length,ia,port);

ds.send(dp);

// to receive data from server

}

catch(Exception e)

{

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

}

}

--------client side

import java.io.*;

import java.net.*;

public class UClient{

static byte send[] = new byte[1024];

static byte rev[] = new byte[1024];public static void main(String args[])

{

try{

DatagramSocket ds = new DatagramSocket(5001);

String msg="Hi server";

send= msg.getBytes();


28/47

InetAddress ia= InetAddress.getByName("localhost");

int port=6001;

DatagramPacket dp = newDatagramPacket(send,send.length,ia,port);

ds.send(dp);

// to receive data from serverDatagramPacket dp1= new DatagramPacket(rev,rev.length);

ds.receive(dp1);

String fromServer = new String(dp1.getData(),0,dp1.getLength());System.out.println("Data from Server"+fromServer);

}

catch(Exception e){

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

}

}}

OUTPUT:

--------server

------client


29/47

IP ADDRESS

Problem statement:

---------server side


class ipserver

{

static byte send[]=new byte[1024];

static byte rev[]=new byte[1024];public static void main(String arg[]) throws Exception

{DatagramSocket ds=new DatagramSocket(6001);

DatagramPacket dp=new DatagramPacket(rev,rev.length);

ds.receive(dp);String fromClient = new String(dp.getData(),0,dp.getLength());

System.out.println("Data from Client"+fromClient);


30/47

InetAddress a=InetAddress.getLocalHost();

String msgtoclient=a.toString();

send=msgtoclient.getBytes();InetAddress ia=dp.getAddress();

int port=dp.getPort();

DatagramPacket dp1=new DatagramPacket(send,send.length,ia,port);ds.send(dp1);

}

}

-----------client side

import java.io.*;

import java.net.*;

class ipclient{

static byte send[]=new byte[1024];

static byte rev[]=new byte[1024];


{DatagramSocket ds=new DatagramSocket(6002);

String msg="Hi server";

send= msg.getBytes();

InetAddress ia= InetAddress.getByName("localhost");int port=6001;

DatagramPacket dp = new DatagramPacket(send,send.length,ia,port);

ds.send(dp);DatagramPacket dp1= new DatagramPacket(rev,rev.length);

ds.receive(dp1);

String fromServer = new String(dp1.getData(),0,dp1.getLength());System.out.println("Data from Server"+fromServer);

}

}


31/47

OUTPUT:

-------server

--------client


32/47

FACTORIAL

Problem statement :

--------server side

import java.io.*;

import java.net.*;

class udpfacts

{

public static DatagramSocket ds;

public static byte bufferRec[]=new byte[1024];

public static byte bufferSend[]=new byte[1024];public static void main(String arg[]) throws Exception

{

int fact,i,num;

ds= new DatagramSocket(800);

while(true)

{

DatagramPacket rp = new DatagramPacket (bufferRec,


33/47

bufferRec.length);

ds.receive(rp);

String s= new String(rp.getData(),0,rp.getLength());

num=Integer.parseInt(s);

fact=1;for(i=1;i


34/47

sp= new DatagramPacket (bufferSend, num.length(),

ip,800);

ds.send(sp);

rp=new DatagramPacket(bufferRec,bufferRec.length);ds.receive(rp);

String fact=new String(rp.getData(),0,rp.getLength());

System.out.println("Factorial="+fact);

}

}

OUTPUT:

--------server

-------client


35/47

PRIME NUMBER

Problem statement:

---------server side


class udpprimes

{



public static byte bufferSend[]=new byte[1024];


{

int i,num;

String res="";


while(true)

{


36/47

DatagramPacket rp = new DatagramPacket (bufferRec,

bufferRec.length);

ds.receive(rp);

String s= new

String(rp.getData(),0,rp.getLength());

num=Integer.parseInt(s);

for(i=2;i


37/47

InetAddress ip= InetAddress.getByName(null);

BufferedReader b= new BufferedReader(new

InputStreamReader(System.in));

String num =b.readLine();bufferSend=num.getBytes();

sp= new DatagramPacket (bufferSend, num.length(),

ip,800);

ds.send(sp);

rp=new

DatagramPacket(bufferRec,bufferRec.length);

ds.receive(rp);

String s=new


System.out.println(s);

}

}

OUTPUT:

------server

-----client


38/47

STRING LENGTH

Problem statement:

-------server sideimport java.io.*;

import java.net.*;

class udpstrlens

{



public static byte bufferSend[]=new byte[1024];


{

int len;


while(true)

{


39/47

DatagramPacket rp = new DatagramPacket

(bufferRec, bufferRec.length);

ds.receive(rp);

String s= new


len=s.length();s=Long.toString(len);

bufferSend=s.getBytes();


DatagramPacket sp= new DatagramPacket(bufferSend,

s.length(), ip,801);

ds.send(sp);

}

}

}

--------client side

import java.io.*;

import java.net.*;

class udpstrlenc

{


public static DatagramPacket rp;

public static DatagramPacket sp;


{

byte bufferRec[]=new byte[1024];

byte bufferSend[]=new byte[1024];



BufferedReader b= new BufferedReader(new

InputStreamReader(System.in));

String str =b.readLine();

bufferSend=str.getBytes();


40/47

sp= new DatagramPacket (bufferSend, str.length(),

ip,800);

ds.send(sp);

rp=new DatagramPacket(bufferRec,bufferRec.length);ds.receive(rp);

String len=new String(rp.getData(),0,rp.getLength());

System.out.println("Length="+len);

}

}

OUTPUT:

------server


41/47

-------client

ECHO

Problem statement:

------server side

import java.io.*;

import java.net.*;

class UDPHelloServer

{

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

{

DatagramSocket ds= new DatagramSocket(6000);

byte []bufferSend = new byte[102];


42/47

byte []bufferRec = new byte[102];

DatagramPacket rp= new


ds.receive(rp);

String s= new String(rp.getData());String m= "Hello";

bufferSend = m.getBytes();

InetAddress IP =InetAddress.getByName(null);

DatagramPacket sp= new

DatagramPacket(bufferSend,m.length(),IP,6001);

ds.send(sp);

while(true)

{

DatagramPacket rp1= new


ds.receive(rp1);

String c = new

String(rp1.getData(),0,rp1.getLength());

System.out.println(c);

if(c.equals("exit"))

System.exit(0);

}

}

}

-------client side

import java.io.*;

import java.net.*;

class UDPHelloClient

{

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

{

DatagramSocket ds= new DatagramSocket(6001);

byte []bufferSend = new byte[102];

byte []bufferRec = new byte[102];

String s = "";

InetAddress ip = InetAddress.getByName(null);

bufferSend = s.getBytes();


43/47

DatagramPacket sp= new

DatagramPacket(bufferSend,s.length(),ip,6000);

ds.send(sp);

DatagramPacket rp= new


ds.receive(rp);String msg = new String(rp.getData());

System.out.println(msg);

while(true)

{

String str;

BufferedReader br=new BufferedReader( new

InputStreamReader(System.in) );

str = br.readLine();

bufferSend = str.getBytes();

DatagramPacket sp1=new

DatagramPacket(bufferSend,str.length(),ip,6000);ds.send(sp1);

if(str.equals("exit"))

System.exit(0);

}

}

}

OUTPUT:

----server

-----client


44/47

FIBONNACCI

Problem statement:

-----server side

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetAddress;

class fiboserver{

public static void main(String Args[])

{try

{

int port=25000;InetAddress SenderAdd;

byte buffer[] = new byte[256];

String request,response;int Num,SenderPort;

DatagramSocket ServerSocket = new DatagramSocket(port);


45/47

DatagramPacket inDgp,outDgp;

System.out.println("\nServer initialised,waiting for client request.");

inDgp = new DatagramPacket(buffer,buffer.length);ServerSocket.receive(inDgp);

request = new String(inDgp.getData(),0,inDgp.getLength());

SenderAdd = inDgp.getAddress();SenderPort =inDgp.getPort();

System.out.println("Number sent from the client :" + request);

Num= Integer.parseInt(request);response = "";

for (int i = 1 ; i


46/47

{

public static void main(String Args[])

{try

{

int port=25000;InetAddress host = InetAddress.getLocalHost();

byte buffer[] = new byte[256];

String request,response;DatagramSocket ClientSocket = new DatagramSocket();

DatagramPacket inDgp,outDgp;

// Create a BufferedReader to accept input from the console

BufferedReader br = new BufferedReader(new InputStreamReader(System.in));System.out.print("\nPlease enter the number of terms you want to execute till : ");

request = br.readLine();

outDgp = new DatagramPacket(request.getBytes(),request.length(),host,port);

ClientSocket.send(outDgp);// Constructs a datagram packet for receiving a packet.

inDgp = new DatagramPacket(buffer,buffer.length);ClientSocket.receive(inDgp);

response = new String(inDgp.getData(),0,inDgp.getLength());

System.out.print("The Answer From Server : "+ response);

ClientSocket.close();}

catch(Exception e)

{System.out.println("An error has occurred:" +e);

}

}}

OUTPUT:

------server


47/47

------client

socket programs in java

Documents