RPCServer.java

package demo2;

import java.util.*;
import java.net.*;
class RPCServer
{
    DatagramSocket ds;
    DatagramPacket dp;
    String str,methodName,result;
    int val1,val2;
    RPCServer()
    {
        try
        {
            ds= new DatagramSocket(1200);
            byte b[]=new byte[4096];
            while(true)
            {
                dp= new DatagramPacket(b,b.length);
                ds.receive(dp);
                str= new String(dp.getData(),0,dp.getLength());
                if(str.equalsIgnoreCase("q"))
                {
                    System.exit(1);
                }
                else
                {
                    StringTokenizer st=new StringTokenizer(str," ");
                    int i=0;
                    while(st.hasMoreTokens())
                    {
                        String token=st.nextToken();
                        methodName=token;
                        val1= Integer.parseInt(st.nextToken());
                        val2= Integer.parseInt(st.nextToken());
                    }
                }
                System.out.println(str);
                InetAddress ia=InetAddress.getLocalHost();
                if(methodName.equalsIgnoreCase("add"))
                {
                    result="" + add(val1,val2);
                }
                else if(methodName.equalsIgnoreCase("sub")) 
                { 
                    result= "" + sub(val1,val2);
                } 
                else if(methodName.equalsIgnoreCase("mul")) 
                { 
                    result= "" + mul(val1,val2);
                }
                else if(methodName.equalsIgnoreCase("div"))
                {
                    result= "" + div(val1,val2); 
                }
                byte bl[]=result.getBytes(); 
                DatagramSocket ds1 = new DatagramSocket(); 
                DatagramPacket dp1 = new DatagramPacket(bl,bl.length,InetAddress.getLocalHost(),1300);
                System.out.println("result : "+result+"\n"); 
                ds1.send(dp1);
            }
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
    }
    public int add(int val1, int val2)
    {
    return val1+val2;
    }
    public int sub(int val3,int val4)
    {
        return val3-val4;
    }
    public int mul(int val3,int val4)
    {
        return val3*val4;
    }
    public int div(int val3,int val4)
    {
        return val3/val4;
    }
    public static void main(String[] args) 
    { 
        new RPCServer();
    }
}