Java 类org.springframework.boot.context.embedded.EmbeddedServletContainerException 实例源码

项目：tasfe-framework 文件：NettyEmbeddedServletContainer.java

@Override
public void start() throws EmbeddedServletContainerException {
    ServerBootstrap b = new ServerBootstrap();
    groups(b);
    servletExecutor = new DefaultEventExecutorGroup(50);
    b.childHandler(new NettyEmbeddedServletInitializer(servletExecutor, context));

    // Don't yet need the complexity of lifecycle state, listeners etc, so tell the context it's initialised here
    context.setInitialised(true);

    ChannelFuture future = b.bind(address).awaitUninterruptibly();
    //noinspection ThrowableResultOfMethodCallIgnored
    Throwable cause = future.cause();
    if (null != cause) {
        throw new EmbeddedServletContainerException("Could not start Netty server", cause);
    }
    logger.info(context.getServerInfo() + " started on port: " + getPort());
}

项目：tasfe-framework 文件：NettyEmbeddedServletContainer.java

@Override
public void stop() throws EmbeddedServletContainerException {
    try {
        if (null != bossGroup) {
            bossGroup.shutdownGracefully().await();
        }
        if (null != workerGroup) {
            workerGroup.shutdownGracefully().await();
        }
        if (null != servletExecutor) {
            servletExecutor.shutdownGracefully().await();
        }
    } catch (InterruptedException e) {
        throw new EmbeddedServletContainerException("Container stop interrupted", e);
    }
}

项目：nebo 文件：NettyEmbeddedServletContainer.java

@Override
    public void start() throws EmbeddedServletContainerException {
        ServerBootstrap b = new ServerBootstrap();
        groups(b);
//        servletExecutor = new DefaultEventExecutorGroup(50);
//        b.childHandler(new NettyEmbeddedServletInitializer(servletExecutor, context));
        b.childHandler(new ChannelInitializer() {
            @Override
            protected void initChannel(Channel ch) throws Exception {
                ch.pipeline().addLast(new DispatcherInbound(address, context));
            }
        });
        // Don't yet need the complexity of lifecycle state, listeners etc, so tell the context it's initialised here


        ChannelFuture future = b.bind(address).awaitUninterruptibly();
        //noinspection ThrowableResultOfMethodCallIgnored
        Throwable cause = future.cause();
        if (null != cause) {
            throw new EmbeddedServletContainerException("Could not start Netty server", cause);
        }
        logger.info(context.getServerInfo() + " started on port: " + getPort());
        context.setInitialised(true);
        context.addFilter(HessianConstant.HESSIAN_PATH,new HessianFilter(context));
        ServletNettyHttpSessionManager.start();
    }

项目：nebo 文件：NettyEmbeddedServletContainer.java

@Override
public void stop() throws EmbeddedServletContainerException {
    try {
        if (null != bossGroup) {
            bossGroup.shutdownGracefully().await();
        }
        if (null != workerGroup) {
            workerGroup.shutdownGracefully().await();
        }
        if (null != servletExecutor) {
            servletExecutor.shutdownGracefully().await();
        }
    } catch (InterruptedException e) {
        throw new EmbeddedServletContainerException("Container stop interrupted", e);
    }
}

项目：https-github.com-g0t4-jenkins2-course-spring-boot 文件：TomcatEmbeddedServletContainerFactory.java

private void configureSslTrustStore(AbstractHttp11JsseProtocol<?> protocol, Ssl ssl) {

        if (ssl.getTrustStore() != null) {
            try {
                protocol.setTruststoreFile(
                        ResourceUtils.getURL(ssl.getTrustStore()).toString());
            }
            catch (FileNotFoundException ex) {
                throw new EmbeddedServletContainerException(
                        "Could not load trust store: " + ex.getMessage(), ex);
            }
        }
        protocol.setTruststorePass(ssl.getTrustStorePassword());
        if (ssl.getTrustStoreType() != null) {
            protocol.setTruststoreType(ssl.getTrustStoreType());
        }
        if (ssl.getTrustStoreProvider() != null) {
            protocol.setTruststoreProvider(ssl.getTrustStoreProvider());
        }
    }

项目：https-github.com-g0t4-jenkins2-course-spring-boot 文件：UndertowEmbeddedServletContainer.java

@Override
public void stop() throws EmbeddedServletContainerException {
    synchronized (this.monitor) {
        if (this.started) {
            try {
                this.started = false;
                this.manager.stop();
                this.undertow.stop();
            }
            catch (Exception ex) {
                throw new EmbeddedServletContainerException("Unable to stop undertow",
                        ex);
            }
        }
    }
}

项目：https-github.com-g0t4-jenkins2-course-spring-boot 文件：JettyEmbeddedServletContainerFactory.java

private void configureSslKeyStore(SslContextFactory factory, Ssl ssl) {
    try {
        URL url = ResourceUtils.getURL(ssl.getKeyStore());
        factory.setKeyStoreResource(Resource.newResource(url));
    }
    catch (IOException ex) {
        throw new EmbeddedServletContainerException(
                "Could not find key store '" + ssl.getKeyStore() + "'", ex);
    }
    if (ssl.getKeyStoreType() != null) {
        factory.setKeyStoreType(ssl.getKeyStoreType());
    }
    if (ssl.getKeyStoreProvider() != null) {
        factory.setKeyStoreProvider(ssl.getKeyStoreProvider());
    }
}

项目：https-github.com-g0t4-jenkins2-course-spring-boot 文件：JettyEmbeddedServletContainerFactory.java

private void configureSslTrustStore(SslContextFactory factory, Ssl ssl) {
    if (ssl.getTrustStorePassword() != null) {
        factory.setTrustStorePassword(ssl.getTrustStorePassword());
    }
    if (ssl.getTrustStore() != null) {
        try {
            URL url = ResourceUtils.getURL(ssl.getTrustStore());
            factory.setTrustStoreResource(Resource.newResource(url));
        }
        catch (IOException ex) {
            throw new EmbeddedServletContainerException(
                    "Could not find trust store '" + ssl.getTrustStore() + "'", ex);
        }
    }
    if (ssl.getTrustStoreType() != null) {
        factory.setTrustStoreType(ssl.getTrustStoreType());
    }
    if (ssl.getTrustStoreProvider() != null) {
        factory.setTrustStoreProvider(ssl.getTrustStoreProvider());
    }
}

项目：https-github.com-g0t4-jenkins2-course-spring-boot 文件：JettyEmbeddedServletContainer.java

private void initialize() {
    synchronized (this.monitor) {
        try {
            // Cache and clear the connectors to prevent requests being handled before
            // the application context is ready
            this.connectors = this.server.getConnectors();
            this.server.setConnectors(null);

            // Start the server so that the ServletContext is available
            this.server.start();
            this.server.setStopAtShutdown(false);
        }
        catch (Exception ex) {
            // Ensure process isn't left running
            stopSilently();
            throw new EmbeddedServletContainerException(
                    "Unable to start embedded Jetty servlet container", ex);
        }
    }
}

项目：https-github.com-g0t4-jenkins2-course-spring-boot 文件：TomcatEmbeddedServletContainerFactoryTests.java

@Test
public void primaryConnectorPortClashThrowsIllegalStateException()
        throws InterruptedException, IOException {
    doWithBlockedPort(new BlockedPortAction() {

        @Override
        public void run(int port) {
            TomcatEmbeddedServletContainerFactory factory = getFactory();
            factory.setPort(port);

            try {
                TomcatEmbeddedServletContainerFactoryTests.this.container = factory
                        .getEmbeddedServletContainer();
                TomcatEmbeddedServletContainerFactoryTests.this.container.start();
                fail();
            }
            catch (EmbeddedServletContainerException ex) {
                // Ignore
            }
        }

    });
}

项目：https-github.com-g0t4-jenkins2-course-spring-boot 文件：EndpointWebMvcAutoConfigurationTests.java

@Test
public void specificPortsViaPropertiesWithClash() throws Exception {
    int managementPort = ports.get().management;
    ServerSocket serverSocket = new ServerSocket();
    serverSocket.bind(new InetSocketAddress(managementPort));
    try {
        EnvironmentTestUtils.addEnvironment(this.applicationContext,
                "server.port:" + ports.get().server,
                "management.port:" + ports.get().management);
        this.applicationContext.register(RootConfig.class, EndpointConfig.class,
                BaseConfiguration.class, EndpointWebMvcAutoConfiguration.class,
                ErrorMvcAutoConfiguration.class);
        this.thrown.expect(EmbeddedServletContainerException.class);
        this.applicationContext.refresh();
    }
    finally {
        serverSocket.close();
    }
}

项目：spring-boot-concourse 文件：TomcatEmbeddedServletContainerFactory.java

private void configureSslTrustStore(AbstractHttp11JsseProtocol<?> protocol, Ssl ssl) {

        if (ssl.getTrustStore() != null) {
            try {
                protocol.setTruststoreFile(
                        ResourceUtils.getURL(ssl.getTrustStore()).toString());
            }
            catch (FileNotFoundException ex) {
                throw new EmbeddedServletContainerException(
                        "Could not load trust store: " + ex.getMessage(), ex);
            }
        }
        protocol.setTruststorePass(ssl.getTrustStorePassword());
        if (ssl.getTrustStoreType() != null) {
            protocol.setTruststoreType(ssl.getTrustStoreType());
        }
        if (ssl.getTrustStoreProvider() != null) {
            protocol.setTruststoreProvider(ssl.getTrustStoreProvider());
        }
    }

项目：spring-boot-concourse 文件：JettyEmbeddedServletContainerFactory.java

private void configureSslKeyStore(SslContextFactory factory, Ssl ssl) {
    try {
        URL url = ResourceUtils.getURL(ssl.getKeyStore());
        factory.setKeyStoreResource(Resource.newResource(url));
    }
    catch (IOException ex) {
        throw new EmbeddedServletContainerException(
                "Could not find key store '" + ssl.getKeyStore() + "'", ex);
    }
    if (ssl.getKeyStoreType() != null) {
        factory.setKeyStoreType(ssl.getKeyStoreType());
    }
    if (ssl.getKeyStoreProvider() != null) {
        factory.setKeyStoreProvider(ssl.getKeyStoreProvider());
    }
}

项目：spring-boot-concourse 文件：JettyEmbeddedServletContainerFactory.java

private void configureSslTrustStore(SslContextFactory factory, Ssl ssl) {
    if (ssl.getTrustStorePassword() != null) {
        factory.setTrustStorePassword(ssl.getTrustStorePassword());
    }
    if (ssl.getTrustStore() != null) {
        try {
            URL url = ResourceUtils.getURL(ssl.getTrustStore());
            factory.setTrustStoreResource(Resource.newResource(url));
        }
        catch (IOException ex) {
            throw new EmbeddedServletContainerException(
                    "Could not find trust store '" + ssl.getTrustStore() + "'", ex);
        }
    }
    if (ssl.getTrustStoreType() != null) {
        factory.setTrustStoreType(ssl.getTrustStoreType());
    }
    if (ssl.getTrustStoreProvider() != null) {
        factory.setTrustStoreProvider(ssl.getTrustStoreProvider());
    }
}

项目：spring-boot-concourse 文件：JettyEmbeddedServletContainer.java

private synchronized void initialize() {
    try {
        // Cache and clear the connectors to prevent requests being handled before
        // the application context is ready
        this.connectors = this.server.getConnectors();
        this.server.setConnectors(null);

        // Start the server so that the ServletContext is available
        this.server.start();
        this.server.setStopAtShutdown(false);
    }
    catch (Exception ex) {
        // Ensure process isn't left running
        stopSilently();
        throw new EmbeddedServletContainerException(
                "Unable to start embedded Jetty servlet container", ex);
    }
}

项目：spring-boot-concourse 文件：TomcatEmbeddedServletContainerFactoryTests.java

@Test
public void primaryConnectorPortClashThrowsIllegalStateException()
        throws InterruptedException, IOException {
    doWithBlockedPort(new BlockedPortAction() {

        @Override
        public void run(int port) {
            TomcatEmbeddedServletContainerFactory factory = getFactory();
            factory.setPort(port);

            try {
                TomcatEmbeddedServletContainerFactoryTests.this.container = factory
                        .getEmbeddedServletContainer();
                TomcatEmbeddedServletContainerFactoryTests.this.container.start();
                fail();
            }
            catch (EmbeddedServletContainerException ex) {
                // Ignore
            }
        }

    });
}

项目：spring-boot-concourse 文件：EndpointWebMvcAutoConfigurationTests.java

@Test
public void specificPortsViaPropertiesWithClash() throws Exception {
    int managementPort = ports.get().management;
    ServerSocket serverSocket = new ServerSocket();
    serverSocket.bind(new InetSocketAddress(managementPort));
    try {
        EnvironmentTestUtils.addEnvironment(this.applicationContext,
                "server.port:" + ports.get().server,
                "management.port:" + ports.get().management);
        this.applicationContext.register(RootConfig.class, EndpointConfig.class,
                BaseConfiguration.class, EndpointWebMvcAutoConfiguration.class,
                ErrorMvcAutoConfiguration.class);
        this.thrown.expect(EmbeddedServletContainerException.class);
        this.applicationContext.refresh();
    }
    finally {
        serverSocket.close();
    }
}

项目：contestparser 文件：TomcatEmbeddedServletContainer.java

private synchronized void initialize() throws EmbeddedServletContainerException {
    TomcatEmbeddedServletContainer.logger
            .info("Tomcat initialized with port(s): " + getPortsDescription(false));
    try {
        addInstanceIdToEngineName();

        // Remove service connectors to that protocol binding doesn't happen yet
        removeServiceConnectors();

        // Start the server to trigger initialization listeners
        this.tomcat.start();

        // We can re-throw failure exception directly in the main thread
        rethrowDeferredStartupExceptions();

        // Unlike Jetty, all Tomcat threads are daemon threads. We create a
        // blocking non-daemon to stop immediate shutdown
        startDaemonAwaitThread();
    }
    catch (Exception ex) {
        throw new EmbeddedServletContainerException("Unable to start embedded Tomcat",
                ex);
    }
}

项目：contestparser 文件：TomcatEmbeddedServletContainer.java

@Override
public void start() throws EmbeddedServletContainerException {
    try {
        addPreviouslyRemovedConnectors();
        Connector connector = this.tomcat.getConnector();
        if (connector != null && this.autoStart) {
            startConnector(connector);
        }
        // Ensure process isn't left running if it actually failed to start
        if (connectorsHaveFailedToStart()) {
            stopSilently();
            throw new IllegalStateException("Tomcat connector in failed state");
        }
        TomcatEmbeddedServletContainer.logger
                .info("Tomcat started on port(s): " + getPortsDescription(true));
    }
    catch (Exception ex) {
        throw new EmbeddedServletContainerException(
                "Unable to start embedded Tomcat servlet container", ex);
    }
}

项目：contestparser 文件：TomcatEmbeddedServletContainerFactory.java

private void configureSslTrustStore(AbstractHttp11JsseProtocol<?> protocol, Ssl ssl) {
    if (ssl.getTrustStore() != null) {
        try {
            protocol.setTruststoreFile(
                    ResourceUtils.getURL(ssl.getTrustStore()).toString());
        }
        catch (FileNotFoundException ex) {
            throw new EmbeddedServletContainerException(
                    "Could not load trust store: " + ex.getMessage(), ex);
        }
    }
    protocol.setTruststorePass(ssl.getTrustStorePassword());
    if (ssl.getTrustStoreType() != null) {
        protocol.setTruststoreType(ssl.getTrustStoreType());
    }
    if (ssl.getTrustStoreProvider() != null) {
        protocol.setTruststoreProvider(ssl.getTrustStoreProvider());
    }
}

项目：contestparser 文件：TomcatEmbeddedServletContainerFactory.java

/**
 * Returns the absolute temp dir for given web server.
 * @param prefix webserver name
 * @return The temp dir for given web server.
 */
protected File createTempDir(String prefix) {
    try {
        File tempFolder = File.createTempFile(prefix + ".", "." + getPort());
        tempFolder.delete();
        tempFolder.mkdir();
        tempFolder.deleteOnExit();
        return tempFolder;
    }
    catch (IOException ex) {
        throw new EmbeddedServletContainerException(
                "Unable to create Tomcat tempdir. java.io.tmpdir is set to "
                        + System.getProperty("java.io.tmpdir"),
                ex);
    }
}

项目：contestparser 文件：UndertowEmbeddedServletContainer.java

@Override
public synchronized void start() throws EmbeddedServletContainerException {
    try {
        if (!this.autoStart) {
            return;
        }
        if (this.undertow == null) {
            this.undertow = createUndertowServer();
        }
        this.undertow.start();
        this.started = true;
        UndertowEmbeddedServletContainer.logger
                .info("Undertow started on port(s) " + getPortsDescription());
    }
    catch (ServletException ex) {
        throw new EmbeddedServletContainerException(
                "Unable to start embdedded Undertow", ex);
    }
}

项目：contestparser 文件：JettyEmbeddedServletContainerFactory.java

private void configureSslKeyStore(SslContextFactory factory, Ssl ssl) {
    try {
        URL url = ResourceUtils.getURL(ssl.getKeyStore());
        factory.setKeyStoreResource(Resource.newResource(url));
    }
    catch (IOException ex) {
        throw new EmbeddedServletContainerException(
                "Could not find key store '" + ssl.getKeyStore() + "'", ex);
    }
    if (ssl.getKeyStoreType() != null) {
        factory.setKeyStoreType(ssl.getKeyStoreType());
    }
    if (ssl.getKeyStoreProvider() != null) {
        factory.setKeyStoreProvider(ssl.getKeyStoreProvider());
    }
}

项目：contestparser 文件：JettyEmbeddedServletContainerFactory.java

private void configureSslTrustStore(SslContextFactory factory, Ssl ssl) {
    if (ssl.getTrustStorePassword() != null) {
        factory.setTrustStorePassword(ssl.getTrustStorePassword());
    }
    if (ssl.getTrustStore() != null) {
        try {
            URL url = ResourceUtils.getURL(ssl.getTrustStore());
            factory.setTrustStoreResource(Resource.newResource(url));
        }
        catch (IOException ex) {
            throw new EmbeddedServletContainerException(
                    "Could not find trust store '" + ssl.getTrustStore() + "'", ex);
        }
    }
    if (ssl.getTrustStoreType() != null) {
        factory.setTrustStoreType(ssl.getTrustStoreType());
    }
    if (ssl.getTrustStoreProvider() != null) {
        factory.setTrustStoreProvider(ssl.getTrustStoreProvider());
    }
}

项目：contestparser 文件：JettyEmbeddedServletContainer.java

private synchronized void initialize() {
    try {
        // Cache and clear the connectors to prevent requests being handled before
        // the application context is ready
        this.connectors = this.server.getConnectors();
        this.server.setConnectors(null);

        // Start the server so that the ServletContext is available
        this.server.start();
        this.server.setStopAtShutdown(false);
    }
    catch (Exception ex) {
        // Ensure process isn't left running
        stopSilently();
        throw new EmbeddedServletContainerException(
                "Unable to start embedded Jetty servlet container", ex);
    }
}

项目：contestparser 文件：TomcatEmbeddedServletContainerFactoryTests.java

@Test
public void primaryConnectorPortClashThrowsIllegalStateException()
        throws InterruptedException, IOException {
    final int port = SocketUtils.findAvailableTcpPort(40000);

    doWithBlockedPort(port, new Runnable() {

        @Override
        public void run() {
            TomcatEmbeddedServletContainerFactory factory = getFactory();
            factory.setPort(port);

            try {
                TomcatEmbeddedServletContainerFactoryTests.this.container = factory
                        .getEmbeddedServletContainer();
                TomcatEmbeddedServletContainerFactoryTests.this.container.start();
                fail();
            }
            catch (EmbeddedServletContainerException ex) {
                // Ignore
            }
        }

    });

}

项目：contestparser 文件：EndpointWebMvcAutoConfigurationTests.java

@Test
public void specificPortsViaPropertiesWithClash() throws Exception {
    int managementPort = ports.get().management;
    ServerSocket serverSocket = new ServerSocket();
    serverSocket.bind(new InetSocketAddress(managementPort));
    try {
        EnvironmentTestUtils.addEnvironment(this.applicationContext,
                "server.port:" + ports.get().server,
                "management.port:" + ports.get().management);
        this.applicationContext.register(RootConfig.class, EndpointConfig.class,
                BaseConfiguration.class, EndpointWebMvcAutoConfiguration.class,
                ErrorMvcAutoConfiguration.class);
        this.thrown.expect(EmbeddedServletContainerException.class);
        this.applicationContext.refresh();
        this.applicationContext.close();
    }
    finally {
        serverSocket.close();
        assertAllClosed();
    }
}

项目：spring-boot-starter-netty 文件：NettyEmbeddedServletContainer.java

@Override
public void start() throws EmbeddedServletContainerException {
    ServerBootstrap b = new ServerBootstrap();
    groups(b);
    servletExecutor = new DefaultEventExecutorGroup(50);
    b.childHandler(new NettyEmbeddedServletInitializer(servletExecutor, context));

    // Don't yet need the complexity of lifecycle state, listeners etc, so tell the context it's initialised here
    context.setInitialised(true);

    ChannelFuture future = b.bind(address).awaitUninterruptibly();
    //noinspection ThrowableResultOfMethodCallIgnored
    Throwable cause = future.cause();
    if (null != cause) {
        throw new EmbeddedServletContainerException("Could not start Netty server", cause);
    }
    logger.info(context.getServerInfo() + " started on port: " + getPort());
}

项目：spring-boot-starter-netty 文件：NettyEmbeddedServletContainer.java

@Override
public void stop() throws EmbeddedServletContainerException {
    try {
        if (null != bossGroup) {
            bossGroup.shutdownGracefully().await();
        }
        if (null != workerGroup) {
            workerGroup.shutdownGracefully().await();
        }
        if (null != servletExecutor) {
            servletExecutor.shutdownGracefully().await();
        }
    } catch (InterruptedException e) {
        throw new EmbeddedServletContainerException("Container stop interrupted", e);
    }
}

项目：https-github.com-g0t4-jenkins2-course-spring-boot 文件：TomcatEmbeddedServletContainer.java

private void startConnector(Connector connector) {
    try {
        for (Container child : this.tomcat.getHost().findChildren()) {
            if (child instanceof TomcatEmbeddedContext) {
                ((TomcatEmbeddedContext) child).deferredLoadOnStartup();
            }
        }
    }
    catch (Exception ex) {
        TomcatEmbeddedServletContainer.logger.error("Cannot start connector: ", ex);
        throw new EmbeddedServletContainerException(
                "Unable to start embedded Tomcat connectors", ex);
    }
}

项目：https-github.com-g0t4-jenkins2-course-spring-boot 文件：TomcatEmbeddedServletContainerFactory.java

private void configureSslKeyStore(AbstractHttp11JsseProtocol<?> protocol, Ssl ssl) {
    try {
        protocol.setKeystoreFile(ResourceUtils.getURL(ssl.getKeyStore()).toString());
    }
    catch (FileNotFoundException ex) {
        throw new EmbeddedServletContainerException(
                "Could not load key store: " + ex.getMessage(), ex);
    }
    if (ssl.getKeyStoreType() != null) {
        protocol.setKeystoreType(ssl.getKeyStoreType());
    }
    if (ssl.getKeyStoreProvider() != null) {
        protocol.setKeystoreProvider(ssl.getKeyStoreProvider());
    }
}

项目：https-github.com-g0t4-jenkins2-course-spring-boot 文件：UndertowEmbeddedServletContainer.java

@Override
public void start() throws EmbeddedServletContainerException {
    synchronized (this.monitor) {
        try {
            if (!this.autoStart) {
                return;
            }
            if (this.undertow == null) {
                this.undertow = createUndertowServer();
            }
            this.undertow.start();
            this.started = true;
            UndertowEmbeddedServletContainer.logger
                    .info("Undertow started on port(s) " + getPortsDescription());
        }
        catch (Exception ex) {
            if (findBindException(ex) != null) {
                List<Port> failedPorts = getConfiguredPorts();
                List<Port> actualPorts = getActualPorts();
                failedPorts.removeAll(actualPorts);
                if (failedPorts.size() == 1) {
                    throw new PortInUseException(
                            failedPorts.iterator().next().getNumber());
                }
            }
            throw new EmbeddedServletContainerException(
                    "Unable to start embedded Undertow", ex);
        }
    }
}

项目：spring-boot-concourse 文件：TomcatEmbeddedServletContainer.java

private void startConnector(Connector connector) {
    try {
        for (Container child : this.tomcat.getHost().findChildren()) {
            if (child instanceof TomcatEmbeddedContext) {
                ((TomcatEmbeddedContext) child).deferredLoadOnStartup();
            }
        }
    }
    catch (Exception ex) {
        TomcatEmbeddedServletContainer.logger.error("Cannot start connector: ", ex);
        throw new EmbeddedServletContainerException(
                "Unable to start embedded Tomcat connectors", ex);
    }
}

项目：spring-boot-concourse 文件：TomcatEmbeddedServletContainerFactory.java

private void configureSslKeyStore(AbstractHttp11JsseProtocol<?> protocol, Ssl ssl) {
    try {
        protocol.setKeystoreFile(ResourceUtils.getURL(ssl.getKeyStore()).toString());
    }
    catch (FileNotFoundException ex) {
        throw new EmbeddedServletContainerException(
                "Could not load key store: " + ex.getMessage(), ex);
    }
    if (ssl.getKeyStoreType() != null) {
        protocol.setKeystoreType(ssl.getKeyStoreType());
    }
    if (ssl.getKeyStoreProvider() != null) {
        protocol.setKeystoreProvider(ssl.getKeyStoreProvider());
    }
}

项目：spring-boot-concourse 文件：UndertowEmbeddedServletContainer.java

@Override
public synchronized void start() throws EmbeddedServletContainerException {
    try {
        if (!this.autoStart) {
            return;
        }
        if (this.undertow == null) {
            this.undertow = createUndertowServer();
        }
        this.undertow.start();
        this.started = true;
        UndertowEmbeddedServletContainer.logger
                .info("Undertow started on port(s) " + getPortsDescription());
    }
    catch (Exception ex) {
        if (findBindException(ex) != null) {
            List<Port> failedPorts = getConfiguredPorts();
            List<Port> actualPorts = getActualPorts();
            failedPorts.removeAll(actualPorts);
            if (failedPorts.size() == 1) {
                throw new PortInUseException(
                        failedPorts.iterator().next().getNumber());
            }
        }
        throw new EmbeddedServletContainerException(
                "Unable to start embedded Undertow", ex);
    }
}

项目：spring-boot-concourse 文件：UndertowEmbeddedServletContainer.java

@Override
public synchronized void stop() throws EmbeddedServletContainerException {
    if (this.started) {
        try {
            this.started = false;
            this.manager.stop();
            this.undertow.stop();
        }
        catch (Exception ex) {
            throw new EmbeddedServletContainerException("Unable to stop undertow",
                    ex);
        }
    }
}

项目：contestparser 文件：TomcatEmbeddedServletContainer.java

private void startConnector(Connector connector) {
    try {
        for (Container child : this.tomcat.getHost().findChildren()) {
            if (child instanceof TomcatEmbeddedContext) {
                ((TomcatEmbeddedContext) child).deferredLoadOnStartup();
            }
        }
    }
    catch (Exception ex) {
        TomcatEmbeddedServletContainer.logger.error("Cannot start connector: ", ex);
        throw new EmbeddedServletContainerException(
                "Unable to start embedded Tomcat connectors", ex);
    }
}

项目：contestparser 文件：TomcatEmbeddedServletContainerFactory.java

private void configureSslKeyStore(AbstractHttp11JsseProtocol<?> protocol, Ssl ssl) {
    try {
        protocol.setKeystoreFile(ResourceUtils.getURL(ssl.getKeyStore()).toString());
    }
    catch (FileNotFoundException ex) {
        throw new EmbeddedServletContainerException(
                "Could not load key store: " + ex.getMessage(), ex);
    }
    if (ssl.getKeyStoreType() != null) {
        protocol.setKeystoreType(ssl.getKeyStoreType());
    }
    if (ssl.getKeyStoreProvider() != null) {
        protocol.setKeystoreProvider(ssl.getKeyStoreProvider());
    }
}

项目：contestparser 文件：UndertowEmbeddedServletContainer.java

@Override
public synchronized void stop() throws EmbeddedServletContainerException {
    if (this.started) {
        try {
            this.started = false;
            this.manager.stop();
            this.undertow.stop();
        }
        catch (Exception ex) {
            throw new EmbeddedServletContainerException("Unable to stop undertow",
                    ex);
        }
    }
}

项目：contestparser 文件：TomcatEmbeddedServletContainerFactoryTests.java

@Test
public void additionalConnectorPortClashThrowsIllegalStateException()
        throws InterruptedException, IOException {
    final int port = SocketUtils.findAvailableTcpPort(40000);

    doWithBlockedPort(port, new Runnable() {

        @Override
        public void run() {
            TomcatEmbeddedServletContainerFactory factory = getFactory();
            Connector connector = new Connector(
                    "org.apache.coyote.http11.Http11NioProtocol");
            connector.setPort(port);
            factory.addAdditionalTomcatConnectors(connector);

            try {
                TomcatEmbeddedServletContainerFactoryTests.this.container = factory
                        .getEmbeddedServletContainer();
                TomcatEmbeddedServletContainerFactoryTests.this.container.start();
                fail();
            }
            catch (EmbeddedServletContainerException ex) {
                // Ignore
            }
        }

    });

}