不能使用 RMI 远程方法
Can't use RMI remote methods
3 天内无法解决此问题。
RMI 在 1 或 2 台 PC 上与本地主机或 192.168.* 一起正常工作,但远程客户端无法使用远程方法。
启动rmiregisry,然后用Naming.rebind()
绑定服务
注册表正在创建成功,我可以获取绑定服务列表,但我什至不能使用任何方法。
正在使用
搜索远程服务
Naming.lookup("rmi://host_ip:1099/qwe).
or
Registry reg = LocateRegistry.getRegistry("host_ip",server);
reg.lookup("qwe")
客户端找到对象但无法使用它的方法。
代码如下:
Server.java:
public class Server extends UnicastRemoteObject{
protected Server() throws RemoteException {
}
public static void main(String[] args) throws InterruptedException, RemoteException {
ServiceServerImpl server = new ServiceServerImpl();
try {
System.setProperty("java.rmi.server.hostname", "host_ip");
Naming.rebind("/qwe", server);
Arrays.asList(Naming.list("rmi://localhost")).forEach(System.out::println);
System.out.println(System.getProperty("java.rmi.server.hostname"));
} catch (Exception e) {
e.printStackTrace();
}
server.startServer();
}
}
服务Server.java:
public interface ServiceServer extends Remote{
String[] getLoginsList() throws RemoteException;
void addLogin(String login) throws RemoteException;
void removeLogin(String login) throws RemoteException;
boolean canConnect(String login) throws RemoteException;
void setConnected(String login) throws RemoteException;
void setDisconnected(String login) throws RemoteException;
}
ServiceServerImpl.java(如果需要):
public class ServiceServerImpl extends UnicastRemoteObject implements ServiceServer {
private ServerSocket socketListener;
private Socket clientSock;
private volatile List<ClientHandler> threadsList = new ArrayList<ClientHandler>();
private volatile Map<String, Boolean> logins = new HashMap<String,Boolean>();
// private Timer timer;
public ServiceServerImpl() throws RemoteException {
}
public void startServer() {
// startTimer();
try {
socketListener = new ServerSocket(5001);
System.out.println("server up...");
while (true) {
clientSock = null;
while (clientSock == null)
clientSock = socketListener.accept();
ClientHandler curClientHandler = new ClientHandler(clientSock, this);
threadsList.add(curClientHandler);
System.out.println("user connected: " + clientSock.getInetAddress());
}
} catch (Exception e) {
System.err.println("Socket exception");
e.printStackTrace();
}
}
public synchronized void removeUserThread(ClientHandler handler) {
try {
threadsList.remove(handler);
} catch (NullPointerException e) {
}
System.out.println("- 1");
}
@Override
public void setConnected(String login){
logins.put(login,true);
}
@Override
public void setDisconnected(String login){
logins.put(login,false);
}
@Override
public boolean canConnect(String login) throws RemoteException{
return logins.keySet().contains(login)&& (!logins.get(login));
}
@Override
public String[] getLoginsList() throws RemoteException {
return this.logins.keySet().toArray(new String[this.logins.size()]);
}
@Override
public void addLogin(String login) throws RemoteException {
logins.put(login, false);
System.out.println("added");
}
@Override
public void removeLogin(String login) throws RemoteException {
logins.remove(login);
}
public Map<String, Boolean> getLogins() {
return logins;
}
public Set<String> getAllowedLogins() {
return logins.keySet();
}
public List<ClientHandler> getThreadsList() {
return threadsList;
}
}
我正在使用 cmd 或 eclipse 启动 rmiregistry,然后启动服务器。
它启动正确,我无法连接本地主机或 192.168.0.*
但它对远程客户端不起作用
尝试使用 .policy 文件 - 仍然无效
我得到下一个错误代码:
Exception in thread "main" java.rmi.ConnectException: Connection refused to host: 192.168.0.83; nested exception is:
java.net.ConnectException: Connection timed out: connect
at sun.rmi.transport.tcp.TCPEndpoint.newSocket(Unknown Source)
at sun.rmi.transport.tcp.TCPChannel.createConnection(Unknown Source)
at sun.rmi.transport.tcp.TCPChannel.newConnection(Unknown Source)
at sun.rmi.server.UnicastRef.invoke(Unknown Source)
at java.rmi.server.RemoteObjectInvocationHandler.invokeRemoteMethod(Unknown Source)
at java.rmi.server.RemoteObjectInvocationHandler.invoke(Unknown Source)
at com.sun.proxy.$Proxy0.canConnect(Unknown Source)
at server.Main.main(Main.java:16)
Caused by: java.net.ConnectException: Connection timed out: connect
at java.net.DualStackPlainSocketImpl.connect0(Native Method)
at java.net.DualStackPlainSocketImpl.socketConnect(Unknown Source)
at java.net.AbstractPlainSocketImpl.doConnect(Unknown Source)
at java.net.AbstractPlainSocketImpl.connectToAddress(Unknown Source)
at java.net.AbstractPlainSocketImpl.connect(Unknown Source)
at java.net.PlainSocketImpl.connect(Unknown Source)
at java.net.SocksSocketImpl.connect(Unknown Source)
at java.net.Socket.connect(Unknown Source)
at java.net.Socket.connect(Unknown Source)
at java.net.Socket.<init>(Unknown Source)
at java.net.Socket.<init>(Unknown Source)
at sun.rmi.transport.proxy.RMIDirectSocketFactory.createSocket(Unknown Source)
at sun.rmi.transport.proxy.RMIMasterSocketFactory.createSocket(Unknown Source)
... 8 more
请帮忙
根据您的描述,您遇到的是一般网络连接问题,并非特定于 RMI。我的建议是搁置 RMI 并使用 netcat 或其他一些通用的 client/server 实现,直到你解决了连接问题,然后再回到 RMI。
我的猜测是,您必须跨越至少两层安全措施。一个是作为 运行 RMI 服务器的 PC 正在阻止所有端口上的连接,或者除了一小部分端口之外的所有端口。您首先需要在 RMI 主机上打开端口 1099(这是默认的 RMI 端口,当然您可以选择其他端口)。如果这样做,您应该能够从同一本地网络(即同一子网 192.168.something.something)上的另一台主机连接到 RMI 主机。
如果连接正常,下一个要跨越的桥是本地网络上的路由器可能阻止来自本地网络外部的流量。请记住,这是一项重要的安全措施。我的建议是避免从外部直接打开到 RMI 主机的连接,因为这存在安全风险。相反,请尝试设置 SSH 隧道,然后使用该隧道将连接从外部传输到 RMI 主机。 SSH 隧道并不太复杂;网络搜索应该会找到解释。
客户端也可能会阻止到端口 1099 的出站连接;您将必须启用这些连接,或使用 SSH 隧道来避免该问题。
早期(大约 1999 年)我建立了一个通过 RMI 进行通信的全球网络(好吧,大约有 4 个站点)。当时网络安全没有任何障碍。所以当然可以通过 RMI 进行远程通信,你只需要通过防火墙。祝你好运,玩得开心。
192.168.X.X
是一个 private/Class C IP 地址,用于在本地网络上标识您的机器。要向 others/internet 用户公开您的服务,您需要在路由器上配置端口转发。它还有助于使用像 NoIP 这样的免费动态 DNS 服务,以确保您的机器即使在重新启动后仍然可以访问(假设您的 ISP 几乎总是会为您分配一个新的动态 public IP 地址)。
整理好之后,确保您没有将 RMI 服务器绑定到 localhost
或 127.0.0.1
,而是绑定到 0.0.0.0
.
您需要:
- 将
java.rmi.server.hostname
设置为您系统的外部 IP地址,即您路由器的public IP地址。
- 通过
super(port)
. 在固定端口号上导出您的远程对象
- 在路由器中为这些端口和端口 1099 安排端口转发。
如何做 (3) router-dependent 与主题无关。
3 天内无法解决此问题。 RMI 在 1 或 2 台 PC 上与本地主机或 192.168.* 一起正常工作,但远程客户端无法使用远程方法。 启动rmiregisry,然后用Naming.rebind()
绑定服务注册表正在创建成功,我可以获取绑定服务列表,但我什至不能使用任何方法。
正在使用
搜索远程服务Naming.lookup("rmi://host_ip:1099/qwe).
or
Registry reg = LocateRegistry.getRegistry("host_ip",server);
reg.lookup("qwe")
客户端找到对象但无法使用它的方法。
代码如下: Server.java:
public class Server extends UnicastRemoteObject{
protected Server() throws RemoteException {
}
public static void main(String[] args) throws InterruptedException, RemoteException {
ServiceServerImpl server = new ServiceServerImpl();
try {
System.setProperty("java.rmi.server.hostname", "host_ip");
Naming.rebind("/qwe", server);
Arrays.asList(Naming.list("rmi://localhost")).forEach(System.out::println);
System.out.println(System.getProperty("java.rmi.server.hostname"));
} catch (Exception e) {
e.printStackTrace();
}
server.startServer();
}
}
服务Server.java:
public interface ServiceServer extends Remote{
String[] getLoginsList() throws RemoteException;
void addLogin(String login) throws RemoteException;
void removeLogin(String login) throws RemoteException;
boolean canConnect(String login) throws RemoteException;
void setConnected(String login) throws RemoteException;
void setDisconnected(String login) throws RemoteException;
}
ServiceServerImpl.java(如果需要):
public class ServiceServerImpl extends UnicastRemoteObject implements ServiceServer {
private ServerSocket socketListener;
private Socket clientSock;
private volatile List<ClientHandler> threadsList = new ArrayList<ClientHandler>();
private volatile Map<String, Boolean> logins = new HashMap<String,Boolean>();
// private Timer timer;
public ServiceServerImpl() throws RemoteException {
}
public void startServer() {
// startTimer();
try {
socketListener = new ServerSocket(5001);
System.out.println("server up...");
while (true) {
clientSock = null;
while (clientSock == null)
clientSock = socketListener.accept();
ClientHandler curClientHandler = new ClientHandler(clientSock, this);
threadsList.add(curClientHandler);
System.out.println("user connected: " + clientSock.getInetAddress());
}
} catch (Exception e) {
System.err.println("Socket exception");
e.printStackTrace();
}
}
public synchronized void removeUserThread(ClientHandler handler) {
try {
threadsList.remove(handler);
} catch (NullPointerException e) {
}
System.out.println("- 1");
}
@Override
public void setConnected(String login){
logins.put(login,true);
}
@Override
public void setDisconnected(String login){
logins.put(login,false);
}
@Override
public boolean canConnect(String login) throws RemoteException{
return logins.keySet().contains(login)&& (!logins.get(login));
}
@Override
public String[] getLoginsList() throws RemoteException {
return this.logins.keySet().toArray(new String[this.logins.size()]);
}
@Override
public void addLogin(String login) throws RemoteException {
logins.put(login, false);
System.out.println("added");
}
@Override
public void removeLogin(String login) throws RemoteException {
logins.remove(login);
}
public Map<String, Boolean> getLogins() {
return logins;
}
public Set<String> getAllowedLogins() {
return logins.keySet();
}
public List<ClientHandler> getThreadsList() {
return threadsList;
}
}
我正在使用 cmd 或 eclipse 启动 rmiregistry,然后启动服务器。 它启动正确,我无法连接本地主机或 192.168.0.* 但它对远程客户端不起作用 尝试使用 .policy 文件 - 仍然无效
我得到下一个错误代码:
Exception in thread "main" java.rmi.ConnectException: Connection refused to host: 192.168.0.83; nested exception is:
java.net.ConnectException: Connection timed out: connect
at sun.rmi.transport.tcp.TCPEndpoint.newSocket(Unknown Source)
at sun.rmi.transport.tcp.TCPChannel.createConnection(Unknown Source)
at sun.rmi.transport.tcp.TCPChannel.newConnection(Unknown Source)
at sun.rmi.server.UnicastRef.invoke(Unknown Source)
at java.rmi.server.RemoteObjectInvocationHandler.invokeRemoteMethod(Unknown Source)
at java.rmi.server.RemoteObjectInvocationHandler.invoke(Unknown Source)
at com.sun.proxy.$Proxy0.canConnect(Unknown Source)
at server.Main.main(Main.java:16)
Caused by: java.net.ConnectException: Connection timed out: connect
at java.net.DualStackPlainSocketImpl.connect0(Native Method)
at java.net.DualStackPlainSocketImpl.socketConnect(Unknown Source)
at java.net.AbstractPlainSocketImpl.doConnect(Unknown Source)
at java.net.AbstractPlainSocketImpl.connectToAddress(Unknown Source)
at java.net.AbstractPlainSocketImpl.connect(Unknown Source)
at java.net.PlainSocketImpl.connect(Unknown Source)
at java.net.SocksSocketImpl.connect(Unknown Source)
at java.net.Socket.connect(Unknown Source)
at java.net.Socket.connect(Unknown Source)
at java.net.Socket.<init>(Unknown Source)
at java.net.Socket.<init>(Unknown Source)
at sun.rmi.transport.proxy.RMIDirectSocketFactory.createSocket(Unknown Source)
at sun.rmi.transport.proxy.RMIMasterSocketFactory.createSocket(Unknown Source)
... 8 more
请帮忙
根据您的描述,您遇到的是一般网络连接问题,并非特定于 RMI。我的建议是搁置 RMI 并使用 netcat 或其他一些通用的 client/server 实现,直到你解决了连接问题,然后再回到 RMI。
我的猜测是,您必须跨越至少两层安全措施。一个是作为 运行 RMI 服务器的 PC 正在阻止所有端口上的连接,或者除了一小部分端口之外的所有端口。您首先需要在 RMI 主机上打开端口 1099(这是默认的 RMI 端口,当然您可以选择其他端口)。如果这样做,您应该能够从同一本地网络(即同一子网 192.168.something.something)上的另一台主机连接到 RMI 主机。
如果连接正常,下一个要跨越的桥是本地网络上的路由器可能阻止来自本地网络外部的流量。请记住,这是一项重要的安全措施。我的建议是避免从外部直接打开到 RMI 主机的连接,因为这存在安全风险。相反,请尝试设置 SSH 隧道,然后使用该隧道将连接从外部传输到 RMI 主机。 SSH 隧道并不太复杂;网络搜索应该会找到解释。
客户端也可能会阻止到端口 1099 的出站连接;您将必须启用这些连接,或使用 SSH 隧道来避免该问题。
早期(大约 1999 年)我建立了一个通过 RMI 进行通信的全球网络(好吧,大约有 4 个站点)。当时网络安全没有任何障碍。所以当然可以通过 RMI 进行远程通信,你只需要通过防火墙。祝你好运,玩得开心。
192.168.X.X
是一个 private/Class C IP 地址,用于在本地网络上标识您的机器。要向 others/internet 用户公开您的服务,您需要在路由器上配置端口转发。它还有助于使用像 NoIP 这样的免费动态 DNS 服务,以确保您的机器即使在重新启动后仍然可以访问(假设您的 ISP 几乎总是会为您分配一个新的动态 public IP 地址)。
整理好之后,确保您没有将 RMI 服务器绑定到 localhost
或 127.0.0.1
,而是绑定到 0.0.0.0
.
您需要:
- 将
java.rmi.server.hostname
设置为您系统的外部 IP地址,即您路由器的public IP地址。 - 通过
super(port)
. 在固定端口号上导出您的远程对象
- 在路由器中为这些端口和端口 1099 安排端口转发。
如何做 (3) router-dependent 与主题无关。