org.apache.catalina.connector.Connector.getScheme()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(9.9k)|赞(0)|评价(0)|浏览(182)

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

Connector.getScheme介绍

[英]Return the scheme that will be assigned to requests received through this connector. Default value is "http".
[中]返回将分配给通过此连接器接收的请求的方案。默认值为“http”。

代码示例

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

@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 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: org.apache.geronimo.modules/geronimo-tomcat6

public String getScheme() {
  return connector.getScheme();
}

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

public String getScheme() {
  return connector.getScheme();
}

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

/**
 * Gets the network protocol that this connector handles.
 */
public String getProtocol() {
  String protocol = connector.getProtocol();
  if(protocol.indexOf("AJP") > -1) {
    return WebManager.PROTOCOL_AJP;
  } else if(connector.getScheme().equalsIgnoreCase("http")) {
    return WebManager.PROTOCOL_HTTP;
  } else if(connector.getScheme().equalsIgnoreCase("https")) {
    return WebManager.PROTOCOL_HTTPS;
  }
  throw new IllegalStateException("Unknown protocol '"+protocol+"' and scheme '"+connector.getScheme()+"'");
}

代码示例来源：origin: com.github.mjeanroy/junit-servers-tomcat

@Override
public String getScheme() {
  return getConnector().getScheme();
}

代码示例来源：origin: io.fabric8.runtime/fabric8-runtime-container-tomcat-registration

private void initializeConnectors() {
  org.apache.catalina.Service[] services = server.findServices();
  for (org.apache.catalina.Service service : services) {
    for (Connector connector : service.findConnectors()) {
      if (connector.getScheme().equals("http")) {
        httpConnectors.add(connector);
      } else if (connector.getScheme().equals("https")) {
        httpsConnectors.add(connector);
      }
    }
  }
}

代码示例来源：origin: io.fabric8.runtime/fabric-runtime-container-tomcat-registration

private void initializeConnectors() {
  org.apache.catalina.Service[] services = server.findServices();
  for (org.apache.catalina.Service service : services) {
    for (Connector connector : service.findConnectors()) {
      if (connector.getScheme().equals("http")) {
        httpConnectors.add(connector);
      } else if (connector.getScheme().equals("https")) {
        httpsConnectors.add(connector);
      }
    }
  }
}

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

private static String address(final Collection<Connector> connectors, final String host, final String path) {
  final List<String> addresses = new ArrayList<>();
  for (final Connector connector : connectors) {
    final URI address;
    try {
      address = new URI(connector.getScheme(), null, host, connector.getPort(), path, null, null);
    } catch (final Exception e) { // just an URI problem normally...shouldn't occur
      LOGGER.error("can't add container for path " + path, e);
      continue;
    }
    addresses.add(address.toString());
  }
  return HttpUtil.selectSingleAddress(addresses);
}

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

private static String address(final Collection<Connector> connectors, final String host, final String path) {
  final List<String> addresses = new ArrayList<String>();
  for (final Connector connector : connectors) {
    final URI address;
    try {
      address = new URI(connector.getScheme(), null, host, connector.getPort(), path, null, null);
    } catch (final Exception e) { // just an URI problem normally...shouldn't occur
      LOGGER.error("can't add container for path " + path, e);
      continue;
    }
    addresses.add(address.toString());
  }
  return HttpUtil.selectSingleAddress(addresses);
}

代码示例来源：origin: org.apache.openejb/tomee-webservices

private static String address(final Collection<Connector> connectors, final String host, final String path) {
  List<String> addresses = new ArrayList<String>();
  for (Connector connector : connectors) {
    URI address;
    try {
      address = new URI(connector.getScheme(), null, host, connector.getPort(), path, null, null);
    } catch (Exception e) { // just an URI problem normally...shouldn't occur
      LOGGER.error("can't add container for path " + path, e);
      continue;
    }
    addresses.add(address.toString());
  }
  return HttpUtil.selectSingleAddress(addresses);
}

代码示例来源：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.apache.openejb/openejb-tomcat-catalina

public List<String> setWsContainer(String virtualHost, String contextRoot, String servletName, HttpListener wsContainer) throws Exception {
  if (virtualHost == null) virtualHost = engine.getDefaultHost();
  Container host = engine.findChild(virtualHost);
  if (host == null) {
    throw new IllegalArgumentException("Invalid virtual host '" + virtualHost + "'.  Do you have a matchiing Host entry in the server.xml?");
  }
  Context context = (Context) host.findChild("/" + contextRoot);
  if (context == null) {
    throw new IllegalArgumentException("Could not find web application context " + contextRoot + " in host " + host.getName());
  }
  Wrapper wrapper = (Wrapper) context.findChild(servletName);
  if (wrapper == null) {
    throw new IllegalArgumentException("Could not find servlet " + contextRoot + " in web application context " + context.getName());
  }
  setWsContainer(context, wrapper, wsContainer);
  // add service locations
  List<String> addresses = new ArrayList<String>();
  for (Connector connector : connectors) {
    for (String mapping : wrapper.findMappings()) {
      URI address = new URI(connector.getScheme(), null, host.getName(), connector.getPort(), "/" + contextRoot + mapping, null, null);
      addresses.add(address.toString());
    }
  }
  return addresses;
}

代码示例来源：origin: com.github.bordertech.lde/lde-tomcat

/**
 * @return the base URL (with context)
 */
@Override
public String getBaseUrl() {
  // Check is running
  Tomcat tom = getServer();
  if (tom == null) {
    return null;
  }
  // Get parts of URL
  String host = "localhost";
  String scheme = tom.getConnector().getScheme();
  int port = tom.getConnector().getPort();
  String contextPath = getContextPath();
  // Build URL
  return scheme + "://" + host + ":" + port + contextPath;
}

代码示例来源：origin: org.switchyard/switchyard-deploy-jboss-as7

/**
 * Return the address.
 * 
 * @return An address string
 */
public String getAddress() {
  String hostAddress = null;
  Connector connector = ServerUtil.getDefaultConnector();
  if (connector.getProtocolHandler() instanceof Http11Protocol) {
    Http11Protocol protocol = (Http11Protocol) connector.getProtocolHandler();
    InetAddress address = protocol.getAddress();
    hostAddress = address.getHostAddress();
   } else {
     ExtensionLogger.ROOT_LOGGER.unableToDetermineHostAddress();
     hostAddress = ServerUtil.getDefaultHost().getHost().findAliases()[0];
   }
  
  return connector.getScheme() + "://" + hostAddress + ":" + connector.getPort() + "/" + _contextName;
}

代码示例来源：origin: jboss-switchyard/release

/**
 * Return the address.
 * 
 * @return An address string
 */
public String getAddress() {
  String hostAddress = null;
  Connector connector = ServerUtil.getDefaultConnector();
  if (connector.getProtocolHandler() instanceof Http11Protocol) {
    Http11Protocol protocol = (Http11Protocol) connector.getProtocolHandler();
    InetAddress address = protocol.getAddress();
    hostAddress = address.getHostAddress();
   } else {
     ExtensionLogger.ROOT_LOGGER.unableToDetermineHostAddress();
     hostAddress = ServerUtil.getDefaultHost().getHost().findAliases()[0];
   }
  
  return connector.getScheme() + "://" + hostAddress + ":" + connector.getPort() + "/" + _contextName;
}

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

Connector

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Connector类方法

    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com