同一个标题有几个问题,但没有一个能帮助我解决我的问题。
我一直在尝试按照这里的教程进行操作: https://docs.oracle.com/javase/tutorial/rmi/overview.html
我把所有东西都放在一个项目中,快把自己逼疯了,所以我创建了 3 个独立的项目:
- Server -> 它有 Main (Driver),class:ServerNode 实现了 Compute
- Client -> 它有Main (Driver), class:TestTask implements Task
- Shared -> 它有接口(interface):Task 和接口(interface):Compute
想法是...两个应用程序都需要了解接口(interface)任务(客户端发送到服务器的工作单元)和计算(客户端用来向其发出命令的 ServerNode 接口(interface))。
服务器代码:
System.setProperty("java.security.policy","file:server.policy");
System.out.println(System.getProperty("java.security.policy"));
if (System.getSecurityManager() == null) {
System.setSecurityManager(new SecurityManager());
}
int port = 1099;
try {
LocateRegistry.createRegistry(port);
String name = "Compute"; // Name of the interface
Compute engine = new ServerNode(); // Implementor of Compute interface, ComputeEngine
Compute stub =
(Compute) UnicastRemoteObject.exportObject(engine, 0); // Create the stub the client will use
Registry registry = LocateRegistry.getRegistry(port);
registry.bind(name, stub); // Bind the "Compute" to the stub, so client can access it by "Compute"
System.out.println("ComputeEngine bound");
} catch (Exception e) {
System.err.println("ComputeEngine exception:");
e.printStackTrace();
}
客户端代码:
System.out.println("Entering client");
String lookupName = "localhost";
System.setProperty("java.security.policy","file:client.policy");
System.out.println(System.getProperty("java.security.policy"));
System.setProperty("rmi.server.codebase", "file:/c:/Users/Brian/Documents/RMI_ClientSide/TestTask.class");
System.out.println(System.getProperty("rmi.server.codebase"));
if (System.getSecurityManager() == null) {
System.setSecurityManager(new SecurityManager());
}
try {
String name = "Compute";
Registry registry = LocateRegistry.getRegistry("localhost", 1099);
Compute comp99 = (Compute)registry.lookup("Compute");
System.out.println(comp99.executeTask(new TestTask()));
} catch (Exception e) {
System.err.println("ComputePi exception:");
e.printStackTrace();
}
我被引导相信,从教程 只有客户需要了解 TestTask...它不需要/不应该进入共享。服务器只需要知道接口(interface) Task 并且客户端给它一个该接口(interface)的实现者......我相信在后台服务器从客户端代码库下载具体代码。
我的目录结构是 1.文档/RMI_ServiceSide 2.文档/RMI_ClientSide 3.文档/RMI_Shared
现在我正在服务器代码中以编程方式启动 rmiregister,而不是在命令行上运行它。我不认为那是我的问题,但此时(调试 4 小时后)我不知道。我可以使用该代码启动服务器。
问题出在客户端。当我尝试运行客户端代码时,我得到:
Entering client
file:client.policy
file:/c:/Users/Brian/Documents/RMI_ClientSide/TestTask.class
ComputePi exception:
java.rmi.ServerException: RemoteException occurred in server thread; nested exception is:
java.rmi.UnmarshalException: error unmarshalling arguments; nested exception is:
java.lang.ClassNotFoundException: com.company.TestTask
at sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:355)
at sun.rmi.transport.Transport$1.run(Transport.java:200)
at sun.rmi.transport.Transport$1.run(Transport.java:197)
at java.security.AccessController.doPrivileged(Native Method)
at sun.rmi.transport.Transport.serviceCall(Transport.java:196)
at sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:568)
at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:826)
at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.lambda$run$0(TCPTransport.java:683)
at java.security.AccessController.doPrivileged(Native Method)
at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:682)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
at sun.rmi.transport.StreamRemoteCall.exceptionReceivedFromServer(StreamRemoteCall.java:276)
at sun.rmi.transport.StreamRemoteCall.executeCall(StreamRemoteCall.java:253)
at sun.rmi.server.UnicastRef.invoke(UnicastRef.java:162)
at java.rmi.server.RemoteObjectInvocationHandler.invokeRemoteMethod(RemoteObjectInvocationHandler.java:227)
at java.rmi.server.RemoteObjectInvocationHandler.invoke(RemoteObjectInvocationHandler.java:179)
at com.sun.proxy.$Proxy0.executeTask(Unknown Source)
at com.company.Main.main(Main.java:46)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)
Caused by: java.rmi.UnmarshalException: error unmarshalling arguments; nested exception is:
java.lang.ClassNotFoundException: com.company.TestTask
at sun.rmi.server.UnicastServerRef.dispatch(UnicastServerRef.java:315)
at sun.rmi.transport.Transport$1.run(Transport.java:200)
at sun.rmi.transport.Transport$1.run(Transport.java:197)
at java.security.AccessController.doPrivileged(Native Method)
at sun.rmi.transport.Transport.serviceCall(Transport.java:196)
at sun.rmi.transport.tcp.TCPTransport.handleMessages(TCPTransport.java:568)
at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(TCPTransport.java:826)
at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.lambda$run$0(TCPTransport.java:683)
at java.security.AccessController.doPrivileged(Native Method)
at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(TCPTransport.java:682)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.ClassNotFoundException: com.company.TestTask
好吧,似乎当我尝试执行 TestTask 时,注册表返回它找不到它。我已经尝试了 -Djava.rmi.server.codebase=file:/c:/Users/Brian/Documents/RMI_ClientSide/命令行参数和/或 System.setProperty("rmi.server.codebase ", "文件:/c:/Users/Brian/Documents/RMI_ClientSide/TestTask.class");
绝对没有任何效果......我不知道这是 rmiregistry 的问题还是我没有在我的代码库中找到正确的排列。这一切都在一台机器上,所以我不知道为什么它找不到它。
明确地说……需要的文件: 1. Client -> RMI_ClientSide/bin/.../Main.class and TestTask.class 2. 服务器 -> RMI_ServerSide/bin/..Main.class 和 ServerNode.class 3. Shared -> RMI_Shared/bin/.../RMI_Shared.jar -> 包含Task.class和Compute.class
正如我所说,这是三个独立的项目,但包名称是相同的... package com.company;巧合的是,我在创建每个项目时都没有重命名默认值。我也不知道这是否重要。在将 RMI_Shared.jar 导入服务器和客户端项目时肯定没有……它们都编译得很好。
我发现的另一个答案给人的印象是 Shared 也需要包含 TestTask ......但这没有意义,因为注册表应该在需要时将类定义拉到服务器......这样客户端可以向服务器执行任意代码(这是在这个简单的不安全测试中的目的)。
如果能帮助我运行,我将不胜感激。谢谢!
编辑:添加了指向我的代码库文件夹图像的链接 Codebase directory
请注意,我的项目本身的目录只是 documents/。客户端、服务器和助手。
最佳答案
java.rmi.ServerException: RemoteException occurred in server thread
在服务器上找不到该类。您发送了 com.company.TestTask
的实例,但服务器在其 CLASSPATH 上没有该类,因此无法通过代码库功能找到它。
System.setProperty("rmi.server.codebase", "file:/c:/Users/Brian/Documents/RMI_ClientSide/TestTask.class");
您的代码库字符串错误。它不应包括类文件名或属于其包的任何目录。代码库是 URL 的列表,这些 URL 可以是 JAR 文件,也可以是作为包结构头部的目录。
关于客户端的 Java RMI ClassNotFoundException,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/39400241/