Write a program to implement RPC (Remote Procedure Call)

 Write a program to implement RPC (Remote Procedure Call)

In this example, we make a server (RMIServer.java) to receive input text from client application and replies how many characters it received.

Server Side:

• Create a remote interface. (myInterface.java)
• Create a separate java file to implement the remote interface. (RMIServer.java)
• Register the interface in RMI registry (bind with any name eg: myRMIService)

Client Side:

• In client code, through interface name (in our case myRMIService) create a "fake remote" object reference of server within client. (RMIClient.java)
• Through this reference access the server methods / services

Let us have a detailed look on code:

1. MyInterface.java

1. import java.rmi.*;
2. public interface MyInterface extends Remote
3. {
4.  public String countInput(String input)throws RemoteException;   
5. }

• It simply says about a remote service to accept a string input and gives string output.
• Line no 4  insists that any code implementing this interface should have countInput method.

2. RMIServer.java

1. import java.rmi.*;
2. import java.rmi.server.*;
3. public class RMIServer extends UnicastRemoteObject implements MyInterface
4. { 
5.     public RMIServer()throws RemoteException
6.     { 
7.         System.out.println("Remote Server is running Now.!!"); 
8.     }    
9. public static void main(String arg[])
10. { 
11.     try{ 
12.         RMIServer p=new RMIServer();
13.         Naming.rebind("rmiInterface",p);
14.     }  
15. catch(Exception e)
16. { System.out.println("Exception occurred : "+e.getMessage()); } 
17. }
18. 
    
19.     @Override
20.     public String countInput(String input) throws RemoteException 
21.     {
22.     System.out.println("Received your input "+ input+"  at server!!");
23.         String reply;
24.         reply="You have typed "+ input.length() +"  letters!!";
25.         return reply;
26.     }
27. }

• Line 3 says we are going to implement MyInterface interface
• Line 13 says we register this service with name rmiInterface. Any client can access the services from this class using this name.
• Line 19-27 implements the methods offered by interface.

3. RMIClient.java

1. import java.rmi.*;
2. import java.io.*; 
3. public class RMIClient
4. {   
5.     public static void  main(String args[])
6.     { 
7.         try
8.       { BufferedReader br=new BufferedReader(new InputStreamReader(System.in)); 
9.       MyInterface p=( MyInterface)Naming.lookup("rmiInterface");
10.         System.out.println("Type something..."); 
11.         String input=br.readLine(); 
12.         System.out.println(p.countInput(input)); 
13.             }
14.         catch(Exception e) { 
15.             System.out.println("Exception occurred : "+e.getMessage());
16.         }
17.     } 
18.  } 

Line 9:  Looking for the remote service using the name!

Line 12: Accessing the service using the remote object.

RESULT:

Compile the java files.

Run remote object registry  called  rmiregistry. It is used by RMI servers on the same host to bind remote objects to names.

Run the Server class.

Run the client class. You can see it is prompting for input

Type some text

Input is received by remote server
   

                                          

Client receives reply from remote server