org.springframework.boot.web.server.WebServer类的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(6.4k)|赞(0)|评价(0)|浏览(296)

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

WebServer介绍

[英]Simple interface that represents a fully configured web server (for example Tomcat, Jetty, Netty). Allows the server to be #start() and #stop().
[中]代表完全配置的web服务器的简单界面(例如Tomcat、Jetty、Netty)。允许服务器#启动()和#停止()。

代码示例

代码示例来源:origin: codecentric/spring-boot-admin

@EventListener
  public void onWebServerInitialized(WebServerInitializedEvent event) {
    String name = event.getApplicationContext().getServerNamespace();
    if ("server".equals(name) || !StringUtils.hasText(name)) {
      localServerPort = event.getWebServer().getPort();
    } else if ("management".equals(name)) {
      localManagementPort = event.getWebServer().getPort();
    }
  }
}

代码示例来源:origin: line/armeria

private void runServer(ReactiveWebServerFactory factory,
            HttpHandler httpHandler,
            Consumer<WebServer> validator) {
  final WebServer server = factory.getWebServer(httpHandler);
  server.start();
  try {
    validator.accept(server);
  } finally {
    server.stop();
  }
}

代码示例来源:origin: org.springframework.boot/spring-boot

private void stopAndReleaseWebServer() {
  WebServer webServer = this.webServer;
  if (webServer != null) {
    try {
      webServer.stop();
      this.webServer = null;
    }
    catch (Exception ex) {
      throw new IllegalStateException(ex);
    }
  }
}

代码示例来源:origin: org.springframework.boot/spring-boot

private WebServer startWebServer() {
  WebServer webServer = this.webServer;
  if (webServer != null) {
    webServer.start();
  }
  return webServer;
}

代码示例来源:origin: org.springframework.boot/spring-boot

public static void stop(ServerManager manager) {
  if (manager != null && manager.server != null) {
    try {
      manager.server.stop();
    }
    catch (Exception ex) {
      throw new IllegalStateException(ex);
    }
  }
}

代码示例来源:origin: org.springframework.boot/spring-boot

public static void start(ServerManager manager,
    Supplier<HttpHandler> handlerSupplier) {
  if (manager != null && manager.server != null) {
    manager.handler = handlerSupplier.get();
    manager.server.start();
  }
}

代码示例来源:origin: alibaba/nacos

@SuppressFBWarnings("ST_WRITE_TO_STATIC_FROM_INSTANCE_METHOD")
@Override
public void onApplicationEvent(WebServerInitializedEvent event) {
  Loggers.SRV_LOG.info("[SERVER-INIT] got port: {}", event.getWebServer().getPort());
  Loggers.SRV_LOG.info("[SERVER-INIT] got path: {}", servletContext.getContextPath());
  serverPort = event.getWebServer().getPort();
  contextPath = servletContext.getContextPath();
  try {
    RaftCore.init();
  } catch (Exception e) {
    Loggers.RAFT.error("[NACOS-RAFT] {} {}", "failed to initialize raft sub system", e);
  }
}

代码示例来源:origin: com.opentable.components/otj-server-core

@EventListener
public void gracefulShutdown(ContextClosedEvent evt) {
  WebServer container = serverHolder().get();
  LOG.debug("Received application context closed event {}. Shutting down...", evt);
  LOG.info("Early shutdown of Jetty connectors on {}", container);
  if (container != null) {
    if(shouldSleepBeforeShutdown) {
      long sleepDurationMillisBeforeShutdown = sleepDurationBeforeShutdown.toMillis();
      LOG.info("Application config requesting sleep for {} ms before Jetty shutdown", sleepDurationMillisBeforeShutdown);
      sleepBeforeJettyShutdown(sleepDurationMillisBeforeShutdown);
    }
    container.stop();
    LOG.info("Jetty is stopped.");
  } else {
    LOG.warn("Never got a Jetty?");
  }
}

代码示例来源:origin: spring-cloud/spring-cloud-sleuth

@Override
public void onApplicationEvent(ServletWebServerInitializedEvent event) {
  this.port = event.getSource().getPort();
}

代码示例来源:origin: spring-cloud/spring-cloud-sleuth

@Override
public void onApplicationEvent(ServletWebServerInitializedEvent event) {
  this.port = event.getSource().getPort();
}

代码示例来源:origin: spring-cloud/spring-cloud-sleuth

@Override
public void onApplicationEvent(ServletWebServerInitializedEvent event) {
  this.port = event.getSource().getPort();
}

代码示例来源:origin: spring-cloud/spring-cloud-sleuth

@Override
public void onApplicationEvent(ServletWebServerInitializedEvent event) {
  this.port = event.getSource().getPort();
}

代码示例来源:origin: spring-cloud-incubator/spring-cloud-alibaba

@EventListener(WebServerInitializedEvent.class)
public void onApplicationEvent(WebServerInitializedEvent event) {
  int serverPort = event.getWebServer().getPort();
  this.ansRegistration.setPort(serverPort);
  log.info("[ Migrate ] change the port to " + serverPort);
  if (!this.running.get()) {
    long s = System.currentTimeMillis();
    log.info("[Migrate] start to registry server to ANS");
    this.serviceRegistry.register(this.ansRegistration);
    log.info("[migrate] end to registry server to ANS cost time with "
        + (System.currentTimeMillis() - s) + " ms.");
    this.running.set(true);
  }
}

代码示例来源:origin: alibaba/nacos

@Override
public void onApplicationEvent(WebServerInitializedEvent event) {
  if (port == 0) {
    port = event.getWebServer().getPort();
    List<String> newList = new ArrayList<String>();
    for (String serverAddrTmp : serverList) {
      newList.add(getFormatServerAddr(serverAddrTmp));
    }
    setServerList(new ArrayList<String>(newList));
  }
}

代码示例来源:origin: spring-cloud/spring-cloud-kubernetes

@EventListener(ServletWebServerInitializedEvent.class)
public void onApplicationEvent(ServletWebServerInitializedEvent event) {
  // TODO: take SSL into account
  int localPort = event.getWebServer().getPort();
  if (this.port.get() == 0) {
    log.info("Updating port to " + localPort);
    this.port.compareAndSet(0,
                localPort);
    start();
  }
}

代码示例来源:origin: alibaba/nacos

@Override
public void onApplicationEvent(WebServerInitializedEvent event) {
  setServerPort(event.getWebServer().getPort());
  setContextPath(servletContext.getContextPath());
}

代码示例来源:origin: org.springframework.boot/spring-boot

@Override
public void onApplicationEvent(WebServerInitializedEvent event) {
  File portFile = getPortFile(event.getApplicationContext());
  try {
    String port = String.valueOf(event.getWebServer().getPort());
    createParentFolder(portFile);
    FileCopyUtils.copy(port.getBytes(), portFile);
    portFile.deleteOnExit();
  }
  catch (Exception ex) {
    logger.warn(String.format("Cannot create port file %s", this.file));
  }
}

代码示例来源:origin: line/armeria

private HttpClient httpClient(WebServer server) {
  return HttpClient.of(clientFactory, "http://example.com:" + server.getPort());
}

代码示例来源:origin: line/armeria

private HttpClient httpsClient(WebServer server) {
  return HttpClient.of(clientFactory, "https://example.com:" + server.getPort());
}

代码示例来源:origin: yu199195/Raincat

@Override
public void onApplicationEvent(final WebServerInitializedEvent event) {
  int port = event.getWebServer().getPort();
  final String host = getHost();
  Address.getInstance()
      .setHost(host)
      .setPort(port)
      .setDomain(String.join(":", host, String.valueOf(port)));
}

相关文章

微信公众号

最新文章

更多