RPCClient.java

// RPCClient.java
import java.io.*;
import java.net.*;
import java.util.Scanner;

public class RPCClient {
    
    private static Socket socket;
    private static PrintWriter out;
    private static BufferedReader in;
    
    public static void main(String[] args) {
        try {
            // Connect to server
            socket = new Socket("localhost", 5000);
            out = new PrintWriter(socket.getOutputStream(), true);
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            
            System.out.println("Connected to RPC Server");
            
            // Call sayHello
            String response = callRemote("HELLO", "Alice");
            System.out.println("Response from server: " + response);
            
            // Call add
            String sum = callRemote("ADD", "5,3");
            System.out.println("5 + 3 = " + sum);
            
            // Send messages to server
            Scanner scanner = new Scanner(System.in);
            System.out.println("\n--- Send Messages to Server ---");
            System.out.println("Type your messages (type 'quit' to stop):");
            
            while (true) {
                System.out.print("> ");
                String message = scanner.nextLine();
                
                if (message.equalsIgnoreCase("quit")) {
                    break;
                }
                
                // Send message to server
                String result = callRemote("SEND", message);
                System.out.println(result);
            }
            
            // Retrieve all messages from server
            System.out.println("\n--- All Messages on Server ---");
            String allMessages = callRemote("GETALL", "");
            
            if (allMessages.equals("No messages")) {
                System.out.println("No messages stored on server");
            } else {
                String[] msgArray = allMessages.split(";;");
                for (int i = 0; i < msgArray.length; i++) {
                    System.out.println((i + 1) + ". " + msgArray[i]);
                }
            }
            
            // Close connection
            callRemote("QUIT", "");
            socket.close();
            scanner.close();
            
        } catch (Exception e) {
            System.err.println("Client error: " + e.getMessage());
            e.printStackTrace();
        }
    }
    
    private static String callRemote(String method, String params) throws IOException {
        String request = params.isEmpty() ? method : method + "|" + params;
        out.println(request);
        return in.readLine();
    }
}