org.apache.catalina.startup.Tomcat.getService()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(9.2k)|赞(0)|评价(0)|浏览(116)

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

Tomcat.getService介绍

[英]Get the service object. Can be used to add more connectors and few other global settings.
[中]获取服务对象。可用于添加更多连接器和少数其他全局设置。

代码示例

代码示例来源：origin: SonarSource/sonarqube

void log(Tomcat tomcat) {
 Connector[] connectors = tomcat.getService().findConnectors();
 for (Connector connector : connectors) {
  if (StringUtils.equalsIgnoreCase(connector.getScheme(), "http")) {
   logHttp(connector);
  } else {
   throw new IllegalArgumentException("Unsupported connector: " + connector);
  }
 }
}

代码示例来源：origin: SonarSource/sonarqube

static void configure(Tomcat tomcat, Props props) {
 Connector httpConnector = newHttpConnector(props);
 tomcat.getService().addConnector(httpConnector);
}

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

private String getPortsDescription(boolean localPort) {
  StringBuilder ports = new StringBuilder();
  for (Connector connector : this.tomcat.getService().findConnectors()) {
    if (ports.length() != 0) {
      ports.append(' ');
    }
    int port = localPort ? connector.getLocalPort() : connector.getPort();
    ports.append(port).append(" (").append(connector.getScheme()).append(')');
  }
  return ports.toString();
}

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

private void checkThatConnectorsHaveStarted() {
  checkConnectorHasStarted(this.tomcat.getConnector());
  for (Connector connector : this.tomcat.getService().findConnectors()) {
    checkConnectorHasStarted(connector);
  }
}

代码示例来源：origin: SonarSource/sonarqube

void configure(Tomcat tomcat, Props props) {
 tomcat.setSilent(true);
 tomcat.getService().addLifecycleListener(new LifecycleLogger(Loggers.get(TomcatAccessLog.class)));
 configureLogbackAccess(tomcat, props);
}

代码示例来源：origin: SonarSource/sonarqube

@Test
public void logHttp() {
 Connector connector = newConnector("HTTP/1.1", "http");
 when(tomcat.getService().findConnectors()).thenReturn(new Connector[] {connector});
 underTest.log(tomcat);
 verify(logger).info("HTTP connector enabled on port 1234");
 verifyNoMoreInteractions(logger);
}

代码示例来源：origin: SonarSource/sonarqube

@Test
public void unsupported_connector() {
 Connector connector = mock(Connector.class, Mockito.RETURNS_DEEP_STUBS);
 when(connector.getProtocol()).thenReturn("SPDY/1.1");
 when(connector.getScheme()).thenReturn("spdy");
 when(tomcat.getService().findConnectors()).thenReturn(new Connector[] {connector});
 try {
  underTest.log(tomcat);
  fail();
 } catch (IllegalArgumentException e) {
  // expected
 }
}

代码示例来源：origin: spring-projects/spring-framework

@Override
public void setup() {
  Connector connector = new Connector(Http11NioProtocol.class.getName());
  connector.setPort(0);
  File baseDir = createTempDir("tomcat");
  String baseDirPath = baseDir.getAbsolutePath();
  this.tomcatServer = new Tomcat();
  this.tomcatServer.setBaseDir(baseDirPath);
  this.tomcatServer.setPort(0);
  this.tomcatServer.getService().addConnector(connector);
  this.tomcatServer.setConnector(connector);
}

代码示例来源：origin: SonarSource/sonarqube

@Test
public void bind_to_specific_address() {
 Properties p = new Properties();
 p.setProperty("sonar.web.port", "9000");
 p.setProperty("sonar.web.host", "1.2.3.4");
 TomcatConnectors.configure(tomcat, new Props(p));
 verify(tomcat.getService())
  .addConnector(argThat(c -> c.getScheme().equals("http") && c.getPort() == 9000 && ((InetAddress) c.getProperty("address")).getHostAddress().equals("1.2.3.4")));
}

代码示例来源：origin: SonarSource/sonarqube

@Test
public void bind_to_all_addresses_by_default() {
 Properties p = new Properties();
 p.setProperty("sonar.web.port", "9000");
 TomcatConnectors.configure(tomcat, new Props(p));
 verify(tomcat.getService()).addConnector(argThat(c -> c.getScheme().equals("http") && c.getPort() == 9000 && ((InetAddress) c.getProperty("address")).getHostAddress().equals("0.0.0.0")));
}

代码示例来源：origin: SonarSource/sonarqube

private void verifyHttpConnector(int expectedPort, Map<String, Object> expectedProps) {
  verify(tomcat.getService()).addConnector(argThat(c -> {
   if (!c.getScheme().equals("http")) {
    return false;
   }
   if (!c.getProtocol().equals(TomcatConnectors.HTTP_PROTOCOL)) {
    return false;
   }
   if (c.getPort() != expectedPort) {
    return false;
   }
   for (Map.Entry<String, Object> expectedProp : expectedProps.entrySet()) {
    if (!expectedProp.getValue().equals(c.getProperty(expectedProp.getKey()))) {
     return false;
    }
   }
   return true;
  }));
 }
}

代码示例来源：origin: SonarSource/sonarqube

@Test
public void test_max_post_size_for_http_connection() {
 Properties properties = new Properties();
 Props props = new Props(properties);
 TomcatConnectors.configure(tomcat, props);
 verify(tomcat.getService()).addConnector(argThat(c -> c.getMaxPostSize() == -1));
}

代码示例来源：origin: SonarSource/sonarqube

@Test
public void fail_with_IAE_on_unsupported_protocol() {
 Connector connector = newConnector("AJP/1.3", "ajp");
 when(tomcat.getService().findConnectors()).thenReturn(new Connector[] {connector});
 expectedException.expect(IllegalArgumentException.class);
 expectedException.expectMessage("Unsupported connector: Connector[AJP/1.3-1234]");
 
 underTest.log(tomcat);
}

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

@Override
public WebServer getWebServer(ServletContextInitializer... initializers) {
  Tomcat tomcat = new Tomcat();
  File baseDir = (this.baseDirectory != null) ? this.baseDirectory
      : createTempDir("tomcat");
  tomcat.setBaseDir(baseDir.getAbsolutePath());
  Connector connector = new Connector(this.protocol);
  tomcat.getService().addConnector(connector);
  customizeConnector(connector);
  tomcat.setConnector(connector);
  tomcat.getHost().setAutoDeploy(false);
  configureEngine(tomcat.getEngine());
  for (Connector additionalConnector : this.additionalTomcatConnectors) {
    tomcat.getService().addConnector(additionalConnector);
  }
  prepareContext(tomcat.getHost(), initializers);
  return getTomcatWebServer(tomcat);
}

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

@Override
public WebServer getWebServer(HttpHandler httpHandler) {
  Tomcat tomcat = new Tomcat();
  File baseDir = (this.baseDirectory != null) ? this.baseDirectory
      : createTempDir("tomcat");
  tomcat.setBaseDir(baseDir.getAbsolutePath());
  Connector connector = new Connector(this.protocol);
  tomcat.getService().addConnector(connector);
  customizeConnector(connector);
  tomcat.setConnector(connector);
  tomcat.getHost().setAutoDeploy(false);
  configureEngine(tomcat.getEngine());
  TomcatHttpHandlerAdapter servlet = new TomcatHttpHandlerAdapter(httpHandler);
  prepareContext(tomcat.getHost(), servlet);
  return new TomcatWebServer(tomcat, getPort() >= 0);
}

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

@Override
  protected void configure(ServerBuilder sb) throws Exception {
    // Prepare Tomcat instances.
    tomcatWithWebApp = new Tomcat();
    tomcatWithWebApp.setPort(0);
    tomcatWithWebApp.setBaseDir("build" + File.separatorChar +
                  "tomcat-" + UnmanagedTomcatServiceTest.class.getSimpleName() + "-1");
    tomcatWithWebApp.addWebapp("", WebAppContainerTest.webAppRoot().getAbsolutePath());
    TomcatUtil.engine(tomcatWithWebApp.getService(), "foo").setName("tomcatWithWebApp");
    tomcatWithoutWebApp = new Tomcat();
    tomcatWithoutWebApp.setPort(0);
    tomcatWithoutWebApp.setBaseDir("build" + File.separatorChar +
                    "tomcat-" + UnmanagedTomcatServiceTest.class.getSimpleName() + "-2");
    assertThat(TomcatUtil.engine(tomcatWithoutWebApp.getService(), "bar")).isNotNull();
    // Start the Tomcats.
    tomcatWithWebApp.start();
    tomcatWithoutWebApp.start();
    // Bind them to the Server.
    sb.serviceUnder("/empty/", TomcatService.forConnector("someHost", new Connector()))
     .serviceUnder("/some-webapp-nohostname/",
            TomcatService.forConnector(tomcatWithWebApp.getConnector()))
     .serviceUnder("/no-webapp/", TomcatService.forTomcat(tomcatWithoutWebApp))
     .serviceUnder("/some-webapp/", TomcatService.forTomcat(tomcatWithWebApp));
  }
};

代码示例来源：origin: org.sonarsource.sonarqube/sonar-server

void log(Tomcat tomcat) {
 Connector[] connectors = tomcat.getService().findConnectors();
 for (Connector connector : connectors) {
  if (StringUtils.equalsIgnoreCase(connector.getScheme(), "http")) {
   logHttp(connector);
  } else {
   throw new IllegalArgumentException("Unsupported connector: " + connector);
  }
 }
}

代码示例来源：origin: myrrix/myrrix-recommender

private void configureTomcat(Tomcat tomcat, Connector connector) {
 tomcat.setBaseDir(noSuchBaseDir.getAbsolutePath());
 tomcat.setConnector(connector);
 tomcat.getService().addConnector(connector);
}

代码示例来源：origin: org.sonarsource.sonarqube/sonar-server

void configure(Tomcat tomcat, Props props) {
 tomcat.setSilent(true);
 tomcat.getService().addLifecycleListener(new LifecycleLogger(Loggers.get(TomcatAccessLog.class)));
 configureLogbackAccess(tomcat, props);
}

代码示例来源：origin: apache/ofbiz-framework

public boolean start() throws ContainerException {
  try {
    tomcat.start();
  } catch (LifecycleException e) {
    throw new ContainerException(e);
  }
  for (Connector con: tomcat.getService().findConnectors()) {
    Debug.logInfo("Connector " + con.getProtocol() + " @ " + con.getPort() + " - " +
      (con.getSecure() ? "secure" : "not-secure") + " [" + con.getProtocolHandlerClassName() + "] started.", module);
  }
  Debug.logInfo("Started " + ServerInfo.getServerInfo(), module);
  return true;
}

内容来源于网络，如有侵权，请联系作者删除！

tomcat

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com