回调中的 RMI 连接失败检测

Question

我正在通过 Java RMI 编写一个分布式应用程序。 RMI客户端向RMI服务器注册事件处理程序/回调，服务器在需要时调用客户端的回调函数。现在的问题是，当网络连接失败时（例如，网线拔掉了……），RMI服务器和客户端不会得到通知，并且当尝试调用客户端注册的回调函数时，RMI服务器会失败。RMI服务器也无法将此问题通知 RMI 客户端。更糟糕的是，当网络连接恢复时，RMI 客户端服务仍然会失去与 RMI 服务器的联系，因为没有人通知她重新连接。

我目前的想法是在单独的线程中在 RMI 客户端中实现一个 ping() 方法。 该线程可以定期唤醒并检查服务器。 如果失败，则闹剧重新连接。

还有其他优雅的解决方案吗？希望大家帮忙！

界面

import java.rmi.Remote;
import java.rmi.RemoteException;


public interface MyInterface extends Remote {
    public int RegisterEventHandler(RemoteMyEventHandler eventHandler) throws RemoteException;
    public void unRegisterEventHandler(int eventHandlerId) throws RemoteException;
}

RMI 服务器实现

import java.rmi.RemoteException;
import com.me.MyInterface;

public class MyInterfaceImpl  implements MyInterface {
{
     public void init() {
        try {
            //... initialize RMI server....
            //....
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

   @Override
    public int RegisterEventHandler(RemoteMyEventHandler eventHandler)
            throws RemoteException {
        return MyEventHandlerImp.getInstance().addHandler(eventHandler);
    }

    @Override
    public void unRegisterEventHandler(int eventHandlerId)
            throws RemoteException {
        MyEventHandlerImp.getInstance().removeHandler(eventHandlerId);
    }   
}

//handler.notifyEventSnap(events);

RMI 客户端实现

import java.rmi.NotBoundException;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.util.Properties;
import org.apache.log4j.Logger;
import com.me.MyInterface;

public class MyService implements NotifyHandler{
{
    private MyInterface client;
    private MyEventHandler myEventHandler;

    private void connectToServer() {
        try {
            //...
            Registry registry = LocateRegistry.getRegistry(rmiHost, rmiPort);
            client = (MyInterface) registry.lookup(MyCInterface.class.getName());
        } catch (RemoteException er) {

        } catch (NotBoundException en) {

        } catch (Exception en) {

        } 
    }

    private void startService(){
           //Attach my event handler
            if(client != null)
            {
                myEventHandler = new MyEventHandler();
                myEventHandlerId = client.RegisterEventHandler(myEventHandler);

            }
    }
}

Answer 1

当网络连接失败时（例如网线被拔掉...），RMI服务器和客户端不会收到通知，并且RMI服务器在尝试调用客户端注册的回调函数时失败。

Err，那个是给服务器的通知。服务器只需要注意这一点，然后再试一次。

RMI 服务器也无法将此问题通知给 RMI 客户端。

客户不需要知道。

更糟糕的是，当网络连接恢复时，RMI 客户端服务仍然会失去与 RMI 服务器的联系，因为没有人通知她重新连接。

客户端不必“重新连接”。 RMI 中没有连接或重新连接步骤。只要客户端的 JVM 和远程对象分别保持启动和导出，服务器端的 stub 就保持有效，可以继续被服务器使用。

你正在解决一个非问题。

Answer 2

您似乎正在部分实现客户端/服务器会话。这是服务器可以跟踪以确保客户端有效的令牌。如果服务器与客户端通信时出现错误，则应结束会话并删除对客户端的所有引用。

您的服务器已经使用用于 unRegisterEventHandler 的整数实现会话。您应该在地图之类的地方跟踪这些整数。如果服务器无法连接到客户端，它应该简单地取消注册该客户端并通过从映射中删除它来使会话无效。服务器应删除对客户端的所有引用，并且在创建新会话之前不要尝试与客户端通信。

如果客户端尝试与服务器通信，它应该从服务器获得 InvalidException 异常。这样，客户端可以通过在 catch 块中调用 RegisterEventHandler 来尝试建立新会话。

我参与了一个项目，该项目使用您在 https://code.google.com/p/umuc-team-factor/ 建议的 ping 来解决此问题

所有客户端与服务器的通信都在一个循环的 try catch 块中，例如

private void getSession() {
    while(isRun()) {
        try {
            if(server == null) {
                Logger.getLogger(JobClient.class.getName()).info("Server is null.");
                setupServer();
            }
            UUID sid = server.getSession(this);
            synchronized (this) {
                id = sid;
            }
            Logger.getLogger(JobClient.class.getName()).info("Session id is " + id);
            return;
        } catch (RemoteException ex) {
            Logger.getLogger(JobClient.class.getName()).info("Could not get session from server: " + ex + ". setting up server.");
            setupServer();
        }
    }
}

这会尝试建立与服务器的会话，直到程序停止。

如果抛出 RemoteException，所有服务器与客户端的通信都应该结束客户端的会话。 c.status() 类似于 ping。

List<UUID> endSessions = new ArrayList<UUID>();
for (UUID id : copy.keySet()) {
    ClientCallback c = copy.get(id).client;
    try {
        ClientStatus status = c.status();
        Logger.getLogger(ProcessManager.class.getName()).info("got client status for " + id + ": " + status.getSessionID() + " -" + status.getJobStatus());
        if (status.getSessionID() == null || !status.getSessionID().equals(id)) {
            endSessions.add(id);
        }
    } catch (Exception ex) {
        endSessions.add(id);
        Logger.getLogger(ProcessManager.class.getName()).log(Level.SEVERE, null, ex);
    }
}
for (UUID id : endSessions) {
    try {
        endSession(id);
    } catch (SessionExpiredException ex) {
        Logger.getLogger(ProcessManager.class.getName()).log(Level.SEVERE, null, ex);
    }
}