首先,您必须设置一个服务器,其方法或对象可以被任何远程客户端访问 下面是服务器的示例代码。
import java.rmi.Remote;
import java.rmi.RemoteException;
public interface MyCalc extends Remote{
int add(int a, int b) throws RemoteException;
}
import java.rmi.RemoteException;
public class MyCalcImpl implements MyCalc {
@Override
public int add(int a, int b) throws RemoteException {
return (a + b);
}
}
Run Code Online (Sandbox Code Playgroud)
在服务器机器上启动 rmi 注册表,这样您就可以将您的对象注册到此注册表,并且最好在您放置类的地方运行它,否则您将获得 ClassNotFound。
rmiregistry 1099
Run Code Online (Sandbox Code Playgroud)
注意:如果端口已被使用,您可能需要更改端口。
使用名称“计算器”向 rmi 注册表注册您的对象。
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.rmi.server.UnicastRemoteObject;
public class MyRMIServer {
public static void main(String[] args) throws Exception {
System.setProperty("java.security.policy","file:///tmp/test.policy");
if (System.getSecurityManager() == null) {
System.setSecurityManager(new SecurityManager());
}
try {
String name = "Calculator";
MyCalc engine = new MyCalcImpl();
MyCalc stub = (MyCalc) UnicastRemoteObject.exportObject(engine, 0);
Registry registry = LocateRegistry.getRegistry(1099);
System.out.println("Registering Calculator Object");
registry.rebind(name, stub);
} catch (Exception e) {
System.err.println("Exception:" + e);
e.printStackTrace();
}
}
}
Run Code Online (Sandbox Code Playgroud)
注意:要运行该程序,您必须设置一个安全策略文件并为此创建一个文件,例如 test.policy 并复制以下内容。
grant {
permission java.security.AllPermission;
permission java.net.SocketPermission "localhost:1099", "connect, resolve";
permission java.net.SocketPermission "127.0.0.1:1099", "connect, resolve";
permission java.net.SocketPermission "localhost:80", "connect, resolve";
};
Run Code Online (Sandbox Code Playgroud)
您可以根据您的情况更改 IP 和端口。
启动服务器后,假设您的服务器的 IP 地址是 11.11.11.11,那么您可以在服务器上调用 MyCalc 的 add()。因此,在您的客户端机器上,您的客户端代码将如下所示:
将 MyCalc 类从服务器复制到客户端计算机,以便您可以在编译客户端代码时将其设置为类路径。
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
public class MyRMIClient {
public static void main(String args[]) {
System.setProperty("java.security.policy","file:///tmp/test.policy");
if (System.getSecurityManager() == null) {
System.setSecurityManager(new SecurityManager());
}
try {
String name = "Calculator";
String serverIP = "11.11.11.11"; // or localhost if client and server on same machine.
int serverPort = 1099;
Registry registry = LocateRegistry.getRegistry(serverIP, serverPort);
MyCalc mycalc = (MyCalc) registry.lookup(name);
int result = mycalc.add(10, 20);
System.out.println("Result:" + result);
} catch (Exception e) {
System.err.println("ComputePi exception:");
e.printStackTrace();
}
}
}
Run Code Online (Sandbox Code Playgroud)
编译和测试客户端的代码。
编辑:编辑以删除对 rmi 编译器 (rmic) 的依赖