RMI createRegistry延迟问题

Question

我在从 JVM 中创建 RMI 注册表时遇到了一个奇怪且间歇性的问题。这些代码将全部在内部网上运行，其想法是能够轻松地在一堆机器上启动服务。

public static <X, Y> void newServer(Function<X, Y> function, String name)
  throws Exception {
  FunctionServer<X, Y> fun = null;
  RemoteFunction<X, Y> stub = null;
  Registry registry = null;
  try {
    fun = new FunctionServer<X, Y>(function);
    stub = (RemoteFunction<X, Y>) UnicastRemoteObject.exportObject(fun, 0);
  }
  catch (RemoteException e1) {
    e1.printStackTrace();
  }

  boolean foundPort = false;
  int port = 1099;
  do {
    try {
      registry = LocateRegistry.createRegistry(port);
      registry.rebind(name, stub);
      // Thread.sleep(100);
      foundPort = true;
    }
    catch (ExportException e) {
      port++;
    }
    catch (Exception e) {
      e.printStackTrace();
      throw e;
    }
  } while (!foundPort);
  if (registry.lookup(name) != null)
    System.out.println("Service " + name + " serving "
        + function.getClass().getCanonicalName() + " on port " + port);   
}

当然有一个非常简单的 main 方法：

FileSystemXmlApplicationContext context =
    new FileSystemXmlApplicationContext(args[0]);
Object obj = context.getBean(args[1]);
if (obj instanceof Function<?, ?>) {
  Function<?, ?> fun = (Function<?, ?>) obj;
  FunctionServer.newServer(fun, args[2]);
}

从命令行调用代码如下：

java -cp daopt.jar -Djava.rmi.server.codebase="file://daopt.jar" ****.*******.remote.FunctionServer spring/rosenbrockServer.xml rosenbrock rosenbrock

但有时，它会默默地失败。它打印成功服务器启动消息，但随后没有 java 进程运行，并且 netstat -anp | grep [portNumber] 没有显示任何内容。值得注意的是，如果我在 newServer 方法中添加延迟，即取消注释该行，

Thread.sleep(100); 

则一切正常。这是否意味着 LocateRegistry.createRegistry 正在启动某种工作线程，该线程在一段时间后抛出异常？这是怎么回事？

困惑，
开发者

Answer 1

使“registry”变量成为静态成员。目前它正在被垃圾收集，从而取消导出它，并允许服务器进行 DGC，从而允许进程退出。

您不需要那个 do/while 循环。使用Registry.REGISTRY_PORT。这就是它的用途。由 IANA 为 RMI 注册管理机构保留。

Answer 2

在 JVM 中使用 LocateRegistry.createRegistry 时，建议使用

final Registry registry = LocateRegistry.createRegistry(port);