org.apache.catalina.Service.findConnectors()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(6.8k)|赞(0)|评价(0)|浏览(95)

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

Service.findConnectors介绍

[英]Find and return the set of Connectors associated with this Service.
[中]查找并返回与此服务关联的连接器集。

代码示例

代码示例来源: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: 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: org.springframework.boot/spring-boot

private void removeServiceConnectors() {
  for (Service service : this.tomcat.getServer().findServices()) {
    Connector[] connectors = service.findConnectors().clone();
    this.serviceConnectors.put(service, connectors);
    for (Connector connector : connectors) {
      service.removeConnector(connector);
    }
  }
}

代码示例来源:origin: stackoverflow.com

Server server = ServerFactory.getServer();
   Service[] services = server.findServices();
   for (Service service : services) {
     for (Connector connector : service.findConnectors()) {
       ProtocolHandler protocolHandler = connector.getProtocolHandler();
       if (protocolHandler instanceof Http11Protocol
         || protocolHandler instanceof Http11AprProtocol
         || protocolHandler instanceof Http11NioProtocol) {
         serverPort = connector.getPort();
         System.out.println("HTTP Port: " + connector.getPort());
       }
     }
   }

代码示例来源: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

@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: 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 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: line/armeria

@Test
public void verifySingleConnector() {
  // Relevant to Tomcat 9.0
  assertThat(applicationContext).isInstanceOf(WebServerApplicationContext.class);
  WebServer webServer = ((WebServerApplicationContext) applicationContext).getWebServer();
  assertThat(webServer).isInstanceOf(TomcatWebServer.class);
  assertThat(((TomcatWebServer) webServer).getTomcat()
                      .getEngine()
                      .getService()
                      .findConnectors()).hasSize(1);
}

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

final Connector[] connectors = expectedService.findConnectors();
if (connectors == null || Arrays.stream(connectors).noneMatch(c -> c == expectedConnector)) {
  throw new TomcatServiceException("A configurator should never remove the default connector.");

代码示例来源:origin: stackoverflow.com

for (Connector connector : service.findConnectors()) {
  System.out.println(connector);
  String uriEncoding = connector.getURIEncoding();

代码示例来源:origin: psi-probe/psi-probe

@Override
public void setWrapper(Wrapper wrapper) {
 Valve valve = createValve();
 if (wrapper != null) {
  host = (Host) wrapper.getParent().getParent();
  Engine engine = (Engine) host.getParent();
  Service service = engine.getService();
  connectors = service.findConnectors();
  try {
   deployerOName =
     new ObjectName(host.getParent().getName() + ":type=Deployer,host=" + host.getName());
  } catch (MalformedObjectNameException e) {
   logger.trace("", e);
  }
  host.getPipeline().addValve(valve);
  mbeanServer = ManagementFactory.getPlatformMBeanServer();
 } else if (host != null) {
  host.getPipeline().removeValve(valve);
 }
}

代码示例来源:origin: org.apache.meecrowave/meecrowave-core

private Connector findFirstConnector() {
  return Stream.of(tomcat.getServer().findServices())
      .flatMap(s -> Stream.of(s.findConnectors()))
      .findFirst()
      .orElse(null);
}

代码示例来源:origin: org.apache.meecrowave/meecrowave-core

private void server(final Server s) {
  server = s;
  connector = server != null && server.findServices().length > 0 && server.findServices()[0].findConnectors().length > 0 ?
      server.findServices()[0].findConnectors()[0] : null;
}

代码示例来源:origin: org.apache.tomcat/tomcat-catalina

private Connector[] getConnectors() {
    Engine e = (Engine) host.getParent();
    Service s = e.getService();
    return s.findConnectors();
  }
}

代码示例来源:origin: org.apache.geronimo.modules/geronimo-tomcat6

public void doStart() throws Exception {
  Connector[] connectors = server.getService(null).findConnectors();
  for (Connector conn : connectors) {
    
    this.buildConnectorGBean(classLoader, kernel, conn, container);
  }
}

代码示例来源: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: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core

private Connector[] getConnectors() {
    Engine e = (Engine) host.getParent();
    Service s = e.getService();
    return s.findConnectors();
  }
}

代码示例来源:origin: org.apache.openejb/openejb-tomcat-catalina

public TomcatWsRegistry() {
  StandardServer standardServer = (StandardServer) ServerFactory.getServer();
  for (Service service : standardServer.findServices()) {
    if (service.getContainer() instanceof Engine) {
      connectors = Arrays.asList(service.findConnectors());
      engine = (Engine) service.getContainer();
      break;
    }
  }
}

代码示例来源:origin: org.apache.tomee/tomee-jaxrs

public TomcatRsRegistry() {
  for (final Service service : TomcatHelper.getServer().findServices()) {
    if (service.getContainer() instanceof Engine) {
      connectors = Arrays.asList(service.findConnectors());
      break;
    }
  }
  hosts = SystemInstance.get().getComponent(Hosts.class);
}

相关文章