Блог

Здесь я пытаюсь отклонить запрос на уровне сервера jetty, прежде чем перейти к сервлету. Поскольку, согласно приведенной ниже конфигурации, пул потоков имеет 6 минимальных и 10 максимальных потоков параллельного выполнения, и 10 запросов могут быть поставлены в очередь в пуле потоков, где на уровне соединителя может быть поставлено в очередь 55 запросов. таким образом, всего 85, что означает, что если одновременно отправляется 200 запросов, 115 запросов должны быть отклонены. Но даже если я отправлю 1000 запросов одновременно с помощью jmeter. Сервер Jetty обслуживает все запросы. Ниже приведен фрагмент кода.

 Server server = new Server();
QueuedThreadPool threadPool = new QueuedThreadPool();

LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>(15);
ExecutorThreadPool pool = new ExecutorThreadPool(6, 10, 30000, TimeUnit.MILLISECONDS, queue);
server.setThreadPool(pool);

threadPool.setMaxThreads(AssuranceConfiguration.annetAssurancesrvConsumerThread);
server.setThreadPool(threadPool);
if (AssuranceConfiguration.annetAssurancesrvSslRequired)
{
    if (logger.isInfoEnabled())
    {
        logger.info("Going to use HTTPS, Initialising SSL context....");
    }
    SslContextFactory sslContextFactory = new SslContextFactory();
    sslContextFactory.setKeyStore(JettyServer.class.getResource(KEYSTOREFILE).getFile());
    sslContextFactory.setKeyStorePassword(AssuranceConfiguration.annetAssurancesrvKeystoreidentifier);
    sslContextFactory.setKeyManagerPassword(AssuranceConfiguration.annetAssurancesrvKeystoremanagerPassword);
    SslSelectChannelConnector sslConnector = new SslSelectChannelConnector(sslContextFactory);
    sslConnector.setPort(AssuranceConfiguration.annetAssurancesrvPort);
    server.setConnectors(new Connector[] { sslConnector });

}
else
{
    if (logger.isInfoEnabled())
    {
        logger.info("Going to use HTTP, Initialising simple context....");
    }
    SelectChannelConnector simpleConnector = new SelectChannelConnector();
    simpleConnector.setPort(AssuranceConfiguration.annetAssurancesrvPort);
    simpleConnector.setMaxIdleTime(30000);
    simpleConnector.setRequestHeaderSize(8192);
    server.setConnectors(new Connector[] { simpleConnector });
    simpleConnector.setAcceptQueueSize(55);
}