本文整理了Java中io.reactivex.netty.protocol.http.server.HttpServer.getServerPort()方法的一些代码示例，展示了HttpServer.getServerPort()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。HttpServer.getServerPort()方法的具体详情如下：
包路径：io.reactivex.netty.protocol.http.server.HttpServer
类名称：HttpServer
方法名：getServerPort

HttpServer.getServerPort介绍

暂无

代码示例

代码示例来源：origin: com.netflix.karyon/karyon3-rxnetty

@Override
  public int getPort() {
    return server.getServerPort();
  }
};

代码示例来源：origin: com.netflix.eureka/eureka2-dashboard

public int serverPort() {
    return server.getServerPort();
  }
}

代码示例来源：origin: com.netflix.eureka2/eureka-test-utils

public int getServerPort() {
  return server.getServerPort();
}

代码示例来源：origin: com.netflix.eureka/eureka2-test-utils

public int getServerPort() {
  return server.getServerPort();
}

代码示例来源：origin: com.mesosphere.mesos.rx.java/mesos-rxjava-test

/**
 * The port the server bound to.
 *
 * @return The port the server bound to.
 */
public int getServerPort() {
  if (started.get()) {
    return server.getServerPort();
  } else {
    throw new IllegalStateException("Server must be started before attempting to get its port");
  }
}

代码示例来源：origin: mesosphere/mesos-rxjava

/**
 * The port the server bound to.
 *
 * @return The port the server bound to.
 */
public int getServerPort() {
  if (started.get()) {
    return server.getServerPort();
  } else {
    throw new IllegalStateException("Server must be started before attempting to get its port");
  }
}

代码示例来源：origin: com.mesosphere.mesos.rx.java/mesos-rxjava-test

/**
 * Start the server and return the port that the server bound to.
 *
 * @return The port the server bound to
 */
public int start() {
  started.compareAndSet(false, true);
  server.start();
  return server.getServerPort();
}

代码示例来源：origin: mesosphere/mesos-rxjava

/**
 * Start the server and return the port that the server bound to.
 *
 * @return The port the server bound to
 */
public int start() {
  started.compareAndSet(false, true);
  server.start();
  return server.getServerPort();
}

代码示例来源：origin: io.reactivex/rxnetty-spectator

@Override
public HttpServerListener forHttpServer(@SuppressWarnings("rawtypes") HttpServer server) {
  return HttpServerListener.newHttpListener(serverMetricNamePrefix + server.getServerPort());
}

代码示例来源：origin: io.reactivex/rxnetty-servo

@Override
public HttpServerListener forHttpServer(@SuppressWarnings("rawtypes") HttpServer server) {
  return HttpServerListener.newHttpListener(serverMetricNamePrefix + server.getServerPort());
}

代码示例来源：origin: com.netflix.rxnetty/rx-netty-servo

@Override
public HttpServerListener forHttpServer(@SuppressWarnings("rawtypes") HttpServer server) {
  return HttpServerListener.newHttpListener(serverMetricNamePrefix + server.getServerPort());
}

代码示例来源：origin: com.netflix.karyon/karyon3-rxnetty

@Inject
  RxNettyHttpServerStarter(RxNettyHttpServerRegistry registry) {
    for (Entry<String, Provider<HttpServer<ByteBuf, ByteBuf>>> entry : registry.getServers().entrySet()) {
      LOG.info("Starting HttpServer '{}'", entry.getKey());
      HttpServer<ByteBuf, ByteBuf> server = entry.getValue().get();
      server.start();
      LOG.info("Started HttpServer '{}' on port {}", entry.getKey(), server.getServerPort());
    }
  }
}

代码示例来源：origin: com.netflix.eureka/eureka2-server

public <I, O> void connectHttpEndpoint(String pathPrefix, RequestHandler<I, O> handler) {
    HttpServer<I, O> backend = RxNetty.newHttpServerBuilder(0, handler).build();
    backend.start();
    backendServers.add(backend);
    proxy.register(ForwardingRule.pathPrefix(backend.getServerPort(), pathPrefix));
    logger.info("Started backend HTTP server on port {} or {}", backend.getServerPort(), handler.getClass().getSimpleName());
  }
}

代码示例来源：origin: com.netflix.eureka/eureka2-dashboard

@PostConstruct
public void start() {
  server = RxNetty.createHttpServer(config.getDashboardPort(),
      RequestHandlerWithErrorMapper.from(
          new MainRequestHandler(config),
          new FileErrorResponseMapper())).start();
  logger.info("Starting HTTP dashboard server on port {}...", server.getServerPort());
}

代码示例来源：origin: com.netflix.eureka2/eureka-dashboard

@PostConstruct
public void start() {
  server = RxNetty.createHttpServer(config.getDashboardPort(),
      RequestHandlerWithErrorMapper.from(
          new MainRequestHandler(config),
          new FileErrorResponseMapper())).start();
  logger.info("Starting HTTP dashboard server on port {}...", server.getServerPort());
}

代码示例来源：origin: com.netflix.karyon/karyon-governator

@SuppressWarnings("rawtypes")
  @Inject
  public void setInjector(Injector injector) {
    HttpServerConfig config = (HttpServerConfig) injector.getInstance(serverConfigKey);

    RequestHandler router = injector.getInstance(routerKey);

    GovernatorHttpInterceptorSupport<I, O> interceptorSupport = injector.getInstance(interceptorSupportKey);
    interceptorSupport.finish(injector);
    HttpRequestHandler<I, O> httpRequestHandler = new HttpRequestHandler<I, O>(router, interceptorSupport);

    HttpServerBuilder<I, O> builder = KaryonTransport.newHttpServerBuilder(config.getPort(), httpRequestHandler);

    if (config.requiresThreadPool()) {
      builder.withRequestProcessingThreads(config.getThreadPoolSize());
    }

    if (injector.getExistingBinding(pipelineConfiguratorKey) != null) {
      builder.appendPipelineConfigurator(injector.getInstance(pipelineConfiguratorKey));
    }

    if (injector.getExistingBinding(metricEventsListenerFactoryKey) != null) {
      builder.withMetricEventsListenerFactory(injector.getInstance(metricEventsListenerFactoryKey));
    }

    httpServer = builder.build().start();
    logger.info("Starting server {} on port {}...", nameAnnotation.value(), httpServer.getServerPort());
  }
}

代码示例来源：origin: com.netflix.karyon/karyon2-governator

@SuppressWarnings("rawtypes")
  @Inject
  public void setInjector(Injector injector) {
    HttpServerConfig config = (HttpServerConfig) injector.getInstance(serverConfigKey);

    RequestHandler router = injector.getInstance(routerKey);

    GovernatorHttpInterceptorSupport<I, O> interceptorSupport = injector.getInstance(interceptorSupportKey);
    interceptorSupport.finish(injector);
    HttpRequestHandler<I, O> httpRequestHandler = new HttpRequestHandler<I, O>(router, interceptorSupport);

    HttpServerBuilder<I, O> builder = KaryonTransport.newHttpServerBuilder(config.getPort(), httpRequestHandler);

    if (config.requiresThreadPool()) {
      builder.withRequestProcessingThreads(config.getThreadPoolSize());
    }

    if (injector.getExistingBinding(pipelineConfiguratorKey) != null) {
      builder.appendPipelineConfigurator(injector.getInstance(pipelineConfiguratorKey));
    }

    if (injector.getExistingBinding(metricEventsListenerFactoryKey) != null) {
      builder.withMetricEventsListenerFactory(injector.getInstance(metricEventsListenerFactoryKey));
    }

    httpServer = builder.build().start();
    logger.info("Starting server {} on port {}...", nameAnnotation.value(), httpServer.getServerPort());
  }
}

代码示例来源：origin: com.netflix.karyon2/karyon-governator

@SuppressWarnings("rawtypes")
  @Inject
  public void setInjector(Injector injector) {
    HttpServerConfig config = (HttpServerConfig) injector.getInstance(serverConfigKey);

    RequestHandler router = injector.getInstance(routerKey);

    GovernatorHttpInterceptorSupport<I, O> interceptorSupport = injector.getInstance(interceptorSupportKey);
    interceptorSupport.finish(injector);
    HttpRequestHandler<I, O> httpRequestHandler = new HttpRequestHandler<I, O>(router, interceptorSupport);

    HttpServerBuilder<I, O> builder = KaryonTransport.newHttpServerBuilder(config.getPort(), httpRequestHandler);

    if (config.requiresThreadPool()) {
      builder.withRequestProcessingThreads(config.getThreadPoolSize());
    }

    if (injector.getExistingBinding(pipelineConfiguratorKey) != null) {
      builder.appendPipelineConfigurator(injector.getInstance(pipelineConfiguratorKey));
    }

    if (injector.getExistingBinding(metricEventsListenerFactoryKey) != null) {
      builder.withMetricEventsListenerFactory(injector.getInstance(metricEventsListenerFactoryKey));
    }

    httpServer = builder.build().start();
    logger.info("Starting server {} on port {}...", nameAnnotation.value(), httpServer.getServerPort());
  }
}