【发布时间】:2013-03-26 22:36:13
【问题描述】:
我已经坚持了至少 5 个小时,除了在这里问之外别无他法。我正在编写一个 RMI 应用程序。我希望服务器绑定一个远程对象(此处为NoteBoardImpl),客户端将查找该对象。客户端将其监听器(此处为NoteBoardListener)传递给服务器,监听器也是客户端导出的远程对象。
我在这里准备了一个简单的SSCCE,所以我真的希望有人可以研究一下。所有类都在默认包的同一个文件夹中。我知道这是不鼓励的,我应该将应用程序分成三个罐子,但我想在这里尽可能简单。
远程接口:
import java.rmi.Remote;
import java.rmi.RemoteException;
public interface INoteBoard extends Remote {
public void test(INoteBoardListener listener) throws RemoteException;
}
import java.rmi.Remote;
import java.rmi.RemoteException;
public interface INoteBoardListener extends Remote {
public void onNewText(String text) throws RemoteException;
}
接口实现:
import java.rmi.RemoteException;
public class NoteBoardImpl implements INoteBoard {
@Override
public void test(INoteBoardListener listener) throws RemoteException {
listener.onNewText("server call the listener");
}
}
import java.rmi.RemoteException;
public class NoteBoardListener implements INoteBoardListener {
@Override
public void onNewText(String text) throws RemoteException {
System.out.println(text);
}
}
客户端和服务器:
import java.rmi.Naming;
import java.rmi.server.UnicastRemoteObject;
public class Client {
public static void main(String[] args) {
if (args.length < 2) {
System.out.println("2 arguments required:\nRMI_IP RMI_port");
return;
}
System.setProperty("java.rmi.server.hostname", args[0]);
try {
INoteBoard nb = (INoteBoard) Naming.lookup(String.format("rmi://%s:%s/note", args[0], args[1]));
INoteBoardListener l = (INoteBoardListener) UnicastRemoteObject.exportObject(new NoteBoardListener(), 0);
nb.test(l);
l.onNewText("client invokes listener");
} catch (Exception e) {
e.printStackTrace();
}
}
}
import java.rmi.Naming;
import java.rmi.server.UnicastRemoteObject;
public class Server {
public static void main(String[] args) {
if (args.length < 2) {
System.out.println("2 arguments required:\nRMI_IP RMI_port");
return;
}
System.setProperty("java.rmi.server.hostname", args[0]);
try {
INoteBoard noteBoard = (INoteBoard) UnicastRemoteObject.exportObject(new NoteBoardImpl(), 0);
Naming.rebind(String.format("rmi://%s:%s/note", args[0], args[1]), noteBoard);
} catch (Exception e) {
e.printStackTrace();
}
}
}
我尝试模拟分布式系统以进行测试,并在虚拟机上运行客户端。主机-虚拟机网络具有以下规格 - 主机 IP = 192.168.56.1,虚拟机 IP = 192.168.56.101。
首先,我使用以下命令在本地运行客户端和服务器(事先已启动 rmiregistry 1099)。工作目录是项目的根目录,编译后的类在bin目录:java -cp bin -Djava.rmi.server.codebase=http://student.agh.edu.pl/~grajewsk/bin/ Server 192.168.56.1 1099java -cp bin Client 192.168.56.1 1099
它奏效了。
然后我使用相同的命令在 VM 上运行客户端程序,这是我得到的异常:
java.rmi.ConnectException: Connection refused to host: 192.168.56.1; nested exception is:
java.net.ConnectException: Connection refused
at sun.rmi.transport.tcp.TCPEndpoint.newSocket(TCPEndpoint.java:619)
at sun.rmi.transport.tcp.TCPChannel.createConnection(TCPChannel.java:216)
at sun.rmi.transport.tcp.TCPChannel.newConnection(TCPChannel.java:202)
at sun.rmi.server.UnicastRef.invoke(UnicastRef.java:128)
at java.rmi.server.RemoteObjectInvocationHandler.invokeRemoteMethod(RemoteObjectInvocationHandler.java:194)
at java.rmi.server.RemoteObjectInvocationHandler.invoke(RemoteObjectInvocationHandler.java:148)
at sun.proxy.$Proxy0.test(Unknown Source)
at Client.main(Client.java:14)
Caused by: java.net.ConnectException: Connection refused
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:327)
at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:193)
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:180)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:384)
at java.net.Socket.connect(Socket.java:546)
at java.net.Socket.connect(Socket.java:495)
at java.net.Socket.<init>(Socket.java:392)
at java.net.Socket.<init>(Socket.java:206)
at sun.rmi.transport.proxy.RMIDirectSocketFactory.createSocket(RMIDirectSocketFactory.java:40)
at sun.rmi.transport.proxy.RMIMasterSocketFactory.createSocket(RMIMasterSocketFactory.java:146)
at sun.rmi.transport.tcp.TCPEndpoint.newSocket(TCPEndpoint.java:613)
... 7 more
请注意如何在服务器的注册表中成功查找对象,然后导出客户端远程对象(也成功),并且执行在第 14 行中断,我正在尝试调用传递客户端对象的服务器端对象上的方法。
我在任何一个系统上都没有防火墙,两个方向的 ping 都完美无缺。我知道这里肯定存在一些概念问题,当然我误解了关于 RMI 的一些内容。非常感谢您的帮助。
二进制代码库是on my student's server,以及the source code。提前谢谢!
【问题讨论】:
-
你能从 192.168.56.101 ping 192.168.56.1 吗?
-
是的,正如我所写的“双向 ping 完美无缺”。此外,尽管我在机器上运行服务器,但我可以远程登录到 rmiregistry 和服务器端口,因此我可以在主机或 VM 上运行服务器,并且可以通过远程登录连接到另一台机器的端口。
标签: java jvm client-server virtual-machine rmi