apache/dubbo

Support set fixed rmi service port

Open

#6,629 opened on 2020年8月20日

GitHub で見る
 (3 comments) (0 reactions) (0 assignees)Java (26,453 forks)batch import
help wantedtype/proposal

Repository metrics

Stars
 (41,524 stars)
PR merge metrics
 (平均マージ 7d 14h) (30d で 20 merged PRs)

説明

Rmi protocal will choose a random port as the service port. Sometimes we need to use a fixed port to ensure it is accessable from other service instance. Could add a parameter to support setting this port?

Here is my current code to set the service port.

org.apache.dubbo.rpc.protocol.rmi.RmiProtocol

  @Override
  protected <T> Runnable doExport(final T impl, Class<T> type, URL url) throws RpcException {
    RmiServiceExporter rmiServiceExporter = createExporter(impl, type, url, false);
    RmiServiceExporter genericServiceExporter =
        createExporter(impl, GenericService.class, url, true);

    // Here is the code to set the fixed service port.
    String servicePort = System.getProperty("dubbo.protocal.rmi.serviceport");
    if (servicePort != null && !servicePort.isEmpty()) {
      rmiServiceExporter.setServicePort(Integer.valueOf(servicePort));
    }

    return new Runnable() {
      @Override
      public void run() {
        try {
          rmiServiceExporter.destroy();
          genericServiceExporter.destroy();
        } catch (Throwable e) {
          logger.warn(e.getMessage(), e);
        }
      }
    };
  }

コントリビューターガイド