apache/dubbo

Support set fixed rmi service port

Open

#6.629 aberto em 20 de ago. de 2020

Ver no GitHub
 (3 comments) (0 reactions) (0 assignees)Java (26.453 forks)batch import
help wantedtype/proposal

Métricas do repositório

Stars
 (41.524 stars)
Métricas de merge de PR
 (Mesclagem média 7d 14h) (20 fundiu PRs em 30d)

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

Guia do colaborador