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

HttpServer.getListeners介绍

暂无

代码示例

代码示例来源：origin: uber/AthenaX

public int port() {
  return server.getListeners().iterator().next().getPort();
 }
}

代码示例来源：origin: hugegraph/hugegraph

private int maxThreadPoolSize() {
  Collection<NetworkListener> listeners = this.httpServer.getListeners();
  if (listeners.size() == 0) {
    return -1;
  }
  return listeners.iterator().next().getTransport()
          .getWorkerThreadPoolConfig().getMaxPoolSize();
}

代码示例来源：origin: com.xebialabs.restito/restito

/**
 * Returns the port which the server is running at
 */
public int getPort() {
  return simpleServer.getListeners().iterator().next().getPort();
}

代码示例来源：origin: codice/ddf

/** Returns the port which the server is running at */
@Override
public int getPort() {
 return simpleServer.getListeners().iterator().next().getPort();
}

代码示例来源：origin: bouncestorage/swiftproxy

public int getPort() {
  return server.getListeners().stream().findAny().map(n -> n.getPort()).orElse(0);
}

代码示例来源：origin: javaee/grizzly

protected void rebuildSubTree() {

    for (final NetworkListener l : gws.getListeners()) {
      final NetworkListener currentListener = currentListeners.get(l.getName());
      if (currentListener != l) {
        if (currentListener != null) {
          final Object listenerJmx = listenersJmx.get(l.getName());
          if (listenerJmx != null) {
            mom.deregister(listenerJmx);
          }

          currentListeners.remove(l.getName());
          listenersJmx.remove(l.getName());
        }

        final Object mmJmx = l.createManagementObject();
        mom.register(this, mmJmx, "NetworkListener[" + l.getName() + ']');
        currentListeners.put(l.getName(), l);
        listenersJmx.put(l.getName(), mmJmx);
      }
    }
    
  }
}

代码示例来源：origin: org.testifyproject.junit4/jersey2-system-test

@Override
public ServerInstance<HttpServer> start(TestContext testContext,
    Application application, ResourceConfig resourceConfig) {
  URI uri = URI.create(format(DEFAULT_URI_FORMAT, DEFAULT_SCHEME, DEFAULT_HOST,
      DEFAULT_PORT, DEFAULT_PATH));
  // create and start a new instance of grizzly http server
  HttpServer server =
      GrizzlyHttpServerFactory.createHttpServer(uri, resourceConfig, true);
  Optional<NetworkListener> foundListener = server.getListeners()
      .stream()
      .findFirst();
  ServerInstance serverInstance = null;
  if (foundListener.isPresent()) {
    NetworkListener networkListener = foundListener.get();
    String host = networkListener.getHost();
    int port = networkListener.getPort();
    URI baseURI = URI.create(
        format(DEFAULT_URI_FORMAT, DEFAULT_SCHEME, host, port, DEFAULT_PATH));
    serverInstance = ServerInstanceBuilder.builder()
        .baseURI(baseURI)
        .server(server)
        .property(APP, resourceConfig)
        .property(APP_NAME, testContext.getName())
        .property(SERVER, server)
        .build("jersey", application);
  }
  return serverInstance;
}

代码示例来源：origin: sismics/reader

/**
   * Starts the HTTP server.
   *
   */
  private void startHttpServer() throws Exception {
    String httpRoot = URLDecoder.decode(new File(getClass().getResource("/").getFile()).getAbsolutePath(), "utf-8");
    httpServer = HttpServer.createSimpleServer(httpRoot, "localhost", 9997);
    NetworkListener listener = httpServer.getListeners().iterator().next();
//        listener.setFilterChain(new DefaultFilterChain());

    // Disable file cache to fix https://java.net/jira/browse/GRIZZLY-1350
    ((StaticHttpHandler) httpServer.getServerConfiguration().getHttpHandlers().keySet().iterator().next()).setFileCacheEnabled(false);

    // Add a handler for temporary files
    addTempFileHandler();

    httpServer.start();
  }

代码示例来源：origin: jamesward/jaxrsbars

httpServer.getServerConfiguration().addHttpHandler(new StaticHttpHandler("src/main/webapp"), CONTENT_PATH);
for (NetworkListener networkListener : httpServer.getListeners()) {
  if (System.getenv("FILE_CACHE_ENABLED") == null) {
    networkListener.getFileCache().setEnabled(false);

代码示例来源：origin: ch.squaredesk.nova/websockets

private WebSocketAdapter(Builder builder) {
    super(builder.messageTranscriber, builder.metrics);
    this.metricsCollector = new MetricsCollector(builder.metrics);
    this.httpServer = builder.httpServer;
    if (httpServer !=null) {
//            if (httpServer.isStarted()) {
//                throw new IllegalArgumentException("HttpServer MUST NOT BE STARTED before WebSocketAdapter is created");
//            }
      // TODO: would be cool, if we could somehow find out whether this was already done
      WebSocketAddOn addon = new WebSocketAddOn();
      for (NetworkListener listener : httpServer.getListeners()) {
        listener.registerAddOn(addon);
      }
    }
    this.httpClient = builder.httpClient;
    this.serverEndpointFactory = new ServerEndpointFactory(builder.messageTranscriber);
    this.clientEndpointFactory = new ClientEndpointFactory(builder.messageTranscriber);
  }

代码示例来源：origin: bouncestorage/swiftproxy

public SwiftProxy(Properties properties, BlobStoreLocator locator, URI endpoint) {
  this.endpoint = requireNonNull(endpoint);
  rc = new BounceResourceConfig(properties, locator);
  if (logger.isDebugEnabled()) {
    rc.register(new LoggingFilter(java.util.logging.Logger.getGlobal(), false));
  }
  server = GrizzlyHttpServerFactory.createHttpServer(endpoint, rc, false);
  server.getListeners().forEach(listener -> {
    listener.registerAddOn(new ContentLengthAddOn());
  });
  // allow HTTP DELETE to have payload for multi-object delete
  server.getServerConfiguration().setAllowPayloadForUndefinedHttpMethods(true);
  RuntimeDelegate.setInstance(new RuntimeDelegateImpl(RuntimeDelegate.getInstance()));
}

代码示例来源：origin: com.xebialabs.restito/restito

/**
 * Starts the server
 */
public StubServer run() {
  simpleServer.getServerConfiguration().addHttpHandler(stubsToHandler(), "/");
  try {
    if (secured) {
      for (NetworkListener networkListener : simpleServer.getListeners()) {
        networkListener.setSecure(true);
        SSLEngineConfigurator sslEngineConfig = new SSLEngineConfigurator(getSslConfig(), false, false, false);
        networkListener.setSSLEngineConfig(sslEngineConfig);
      }
    }
    simpleServer.start();
  } catch (Exception e) {
    throw new RuntimeException(e);
  }
  return this;
}

代码示例来源：origin: codice/ddf

/** Starts the server */
@Override
public SecureStubServer run() {
 simpleServer.getServerConfiguration().addHttpHandler(stubsToHandler(), "/");
 try {
  if (isSecured) {
   for (NetworkListener networkListener : simpleServer.getListeners()) {
    networkListener.setSecure(true);
    SSLEngineConfigurator sslEngineConfig =
      new SSLEngineConfigurator(getSslConfig(), false, false, false);
    networkListener.setSSLEngineConfig(sslEngineConfig);
   }
  }
  simpleServer.start();
 } catch (Exception e) {
  throw new IllegalStateException(e);
 }
 return this;
}

代码示例来源：origin: batfish/batfish

Main.class);
int selectedListenPort = server.getListeners().iterator().next().getPort();
URI actualWorkMgrUri =
  UriBuilder.fromUri("http://" + _settings.getWorkBindHost())

代码示例来源：origin: batfish/batfish

int selectedListenPort = server.getListeners().iterator().next().getPort();
URI actualPoolMgrUri =
  UriBuilder.fromUri("http://" + _settings.getPoolBindHost())

代码示例来源：origin: batfish/batfish

Driver.class);
int selectedListenPort = server.getListeners().iterator().next().getPort();
if (_mainSettings.getCoordinatorRegister()) {

代码示例来源：origin: javaee/grizzly

@Override
protected void setUp() throws Exception {
  super.setUp();
  stopHttpServer();
  httpServer = HttpServer.createSimpleServer("./", PORT);
  final Collection<NetworkListener> listeners = httpServer.getListeners();
  for (NetworkListener listener : listeners) {
    listener.registerAddOn(new CometAddOn());
  }
  httpServer.start();
  cometContext = CometEngine.getEngine().register(TEST_TOPIC);
}

代码示例来源：origin: apache/lens

.setUncaughtExceptionHandler(new JerseyProcessingUncaughtExceptionHandler()).build());
NetworkListener listener = server.getListeners().iterator().next();
listener.getTransport().setWorkerThreadPoolConfig(config);
serverList.add(server);