4

我现在至少坚持了 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();
        }
    }
}

我试图模拟一个分布式系统以进行测试，并在虚拟机上运行客户端。主机-VM 网络具有以下规格 - 主机 IP = 192.168.56.1，VM 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 1099
java -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 行中断执行，我试图在第 14 行调用方法传递客户端对象的服务器端对象。

我在任何一个系统上都没有防火墙，两个方向的 ping 都完美无缺。我知道这里肯定存在一些概念问题，当然我误解了关于 RMI 的一些内容。我非常感谢您的帮助。

二进制代码库和源代码都在我学生的服务器上。先感谢您！

4

2 回答 2

4

这就是我要做的事情。

  1. 运行您的服务器应用程序

  2. 找出它用于 RMI 的端口（它是短暂的，因此它应该针对您为服务器创建的每个进程而更改）。

    • 使用 ps -ef 查找 PID
    • 然后 netstat -anp|grep 这应该会给你端口号。它应该绑定到 0.0.0.0

  3. 在客户端 VM 上，使用 nc 或 telnet 验证您可以连接到端口。如果失败，您可能遇到了防火墙/iptables 问题。

  4. 使用wireshark 来验证您的客户端实际上是在尝试连接到您从步骤#2 中学到的端口/IP 组合。

请记住，仅仅因为您可以 ping，并不意味着您可以连接到给定的端口。还要检查“iptables -L”。

此外，命名表示不要放置 URL 的方案组件。格式应该是//host:port/name，所以你也应该检查一下。

于 2013-03-26T23:24:19.467 回答
3

好的，终于解决了。问题是，我java.rmi.server.hostname在两个程序中传递了相同的参数，这意味着客户端和服务器都在这里获得了服务器的地址。事实证明，如果客户端想要导出自己的对象，它必须提供自己的 IP 给java.rmi.server.hostname. 这样一切正常。

所以，总结起来，我必须给服务器 3 个参数：
RMI_IP RMI_port server_hostname

和客户端的 3 个类似参数：
RMI_IP RMI_port client_hostname

于 2013-03-27T13:59:52.383 回答