java program for inter process communication over a connection less service (using UDP)

 Program
Setup a inter process communication over a connection less service (using UDP)

 udpserver.java

import  java.io.*;
import java.net.*;
class udpserver
{public static void main(String args[]) throws Exception
{
DatagramSocket serversocket=new DatagramSocket(9876);
byte[] senddata=new byte[1024];
byte[] receivedata=new byte[1024];
while(true)
{
System.out.println("server side");
DatagramPacket receivepacket=new DatagramPacket(receivedata,receivedata.length);
serversocket.receive(receivepacket);
String sentence=new String(recievepacket.getData());

System.out.println("from server:"+replysentence);

InetAddress ipaddress=receivepacket.getAddress();
int port=receivepacket.setPort();

BufferedReader infromuser=new BufferedReader(new InputSreamReader(System.in));
System.out.println("Enter a message:");
String serversentence=infromuser.readLine();

senddata=sentence.getBytes();
DatagramPacket sendpacket=new DatagramPacket(senddata,senddata.length,ipaddress,port);
serversocket.send(sendpacket);

}}}

--------------------------------------------------------------------------------------------------------------

 udpclient.java

import  java.io.*;
import java.net.*;
class udpclient
{public static void main(String args[]) throws Exception
{
DatagramSocket clientsocket=new DatagramSocket();
InetAddress ipaddress=InetAddress.getByName("192.168.1.141");
clientsocket.close();

byte[] senddata=new byte[1024];
byte[] receivedata=new byte[1024];
System.out.println("client side");
BufferedReader infromuser=new BufferedReader(new InputSreamReader(System.in));
System.out.println("Enter a message:");
String sentence=infromuser.readLine();

senddata=sentence.getBytes();
DatagramPacket sendpacket=new DatagramPacket(senddata,senddata.length,ipaddress,9876);
clientsocket.send(sendpacket);

DatagramPacket receivepacket=new DatagramPackeet(receivedata,receivedata.length);
clientsocket.receive(receivepacket);
String replysentence=new String(recievepacket.getData());
System.out.println("from server:"+replysentence);

clientsocket.close();

}}}

java Program to implement multiply by using RMI

Program

java Program to implement multiply by using RMI

server.java

import java.rmi.*;
import java.rmi.server.*;
import java.net.*;
public class Server extends UnicastRemoteObject implements multiply
{
public Server() throws RemoteException
{
}
public static void main(String args[])throws Exception
{
System.out.println("server starts");
Server s=new Server();
Naming.rebind("Server",s);
}
public int multiply(int x1,int y1)
{
return(x1*y1);
}
}

Java Program For Factorial Of A Given Number Using RMI

//Server.java
import java.rmi.*;
import java.rmi.server.*;
public class server extends UnicastRemoteObject implements factorial
{
  public server() throws RemoteException
  {
  }
  public static void main(String args[])throws Exception
  {
    System.out.println("Server starts");
    server s=new server();
    Naming.rebind("Server",s);
  }
  public int factorial(int x)
  {
    int f=1;
    if(x==0||x==1)
    {
       System.out.println("Factorial"+1);
    }
    else
    { 
      while(x>0)
      {
        f=f*x;
        x--;
      }
    }
    return f;
  }
}

Java Program for implement Inter Applet communication In The Distributed System

Aim

Write a java program to implement Inter applet communication in the Distributed System

Program

 FirstApplet.java 

import java.awt.*;
import java.io.*;
import java.awt.event.*;
import javax.swing.*;

/*<applet code="FirstApplet.class"  width=300 height=300 name="first">
</applet>*/
/*<applet code="SecondApplet.class" width=300 height=300 name="second"></applet>*/

public class FirstApplet extends JApplet implements ActionListener
{
JTextArea ta;
JButton b1;
JTextField txt1;

public void init()
{
Container c=getContentPane();
c.setLayout(new FlowLayout(FlowLayout.LEFT));
txt1=new JTextField(20);
b1=new JButton("send");
ta=new JTextArea(20,30);
ta.setEditable(false);
b1.addActionListener(this);
c.add(txt1);
c.add(b1);
c.add(ta);
}
public void actionPerformed(ActionEvent ae)
{
JApplet second=(JApplet)getAppletContext().getApplet("second");
((SecondApplet)second).ta.append("first>"+txt1.getText()+"\n");
ta.append("first>"+txt1.getText()+"\n");
txt1.setText("");
}
}

Bidirectional Datatransfer Using Threads

Aim

Write a program to perform bi directional data transfer using Threads .

Progrram

  thserver.java
import java.io.*;
import java.net.*;
public class thserver implements Runnable
{
Thread t1=null,t2=null;
BufferedReader in,br;
PrintWriter pw;
Socket s;
ServerSocket ser;

public thserver()
{
    try
    {
    int port=8002;
    ser=new ServerSocket(port);
    }

    catch(Exception e)
     {System.out.println("ERROR");}
}

public void run()
{
String msg;
if(Thread.currentThread()==t1)
{
    try
    {
    s=ser.accept();
    br=new BufferedReader(new InputStreamReader(s.getInputStream()));
   
    do
    {
    System.out.println("Enter a message");
    msg=br.readLine();
    System.out.println("Client:"+msg);
    }while(!msg.equals("Quit"));
    System.exit(0);
    }
catch(Exception e)
{
System.out.println("Error running program");
}
}

else
{
    try
    {
    in=new BufferedReader(new InputStreamReader(System.in));
    do
    {
    msg=in.readLine();
    pw=new PrintWriter(s.getOutputStream(),true);
    pw.println(msg);
    }while(!msg.equals("Quit"));
    System.exit(0);
    }
    catch(Exception e)
    {
    System.out.println("Error running program");
    }
}
}

public static void main(String args[])

{
thserver ss=new thserver();
System.out.println("Sever started");
ss.t1=new Thread(ss);
ss.t2=new Thread(ss);
ss.t1.start();
ss.t2.start();
}
}

Welcome to CodeGuru

hi friends ....
A 123arena Project....