apache/dubbo

Support set fixed rmi service port

Open

#6 629 ouverte le 20 août 2020

Voir sur GitHub
 (3 commentaires) (0 réactions) (0 assignés)Java (26 453 forks)batch import
help wantedtype/proposal

Métriques du dépôt

Stars
 (41 524 stars)
Métriques de merge PR
 (Merge moyen 7j 14h) (20 PRs mergées en 30 j)

Description

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);
        }
      }
    };
  }

Guide contributeur