Настройка памяти Tomcat и потребления процессора

Question

У меня есть веб-приложение на Java, которое много работает с соглашениями о файлах.
Я использую Tomcat 6 в качестве моего контейнера сервлетов. Когда отправляется много запросов, Tomcat становится очень требовательным к памяти. Интересно, как я могу точно настроить tomcat, чтобы уменьшить потребление памяти. Я также рассматриваю возможность изменения моего контейнера сервлетов.
Что ты предлагаешь?

Answer 1

Вы можете ограничить количество принятых / действующих номеров соединений в конфигурации conf/server.xml.

Есть

<Executor name="tomcatThreadPool" namePrefix="catalina-exec-" 
    maxThreads="16" minSpareThreads="1"/>

и

<Connector executor="tomcatThreadPool"
           port="8080" protocol="HTTP/1.1" 
           connectionTimeout="20000" 
           redirectPort="8443" 
           />

или

<Connector port="8080" protocol="HTTP/1.1" 
           connectionTimeout="20000" 
           redirectPort="8443" 
           maxThreads='16'/>

в файле конфигурации, и это должно вас затормозить.

Редактировать: На основе вашего комментария вы можете переместить обработку в выделенный пул потоков, размер которого зависит от вашего количества процессоров (Runtime.getRuntime().availableProcessors()) (см. ExecutorService и Executors .) Затем можно применить ограниченную LinkedBlockingQueue , чтобы ограничить число ожидающих задач (не забудьте указать RejectedExecutionHandler , чтобы сделать блокировку добавления, когда очередь заполнится) .

Редактировать 2: Добавлены ссылки на классы. Там вы найдете несколько образцов.

Редактировать 3: Пример метода, который я использовал в проекте.

/**
 * Creates a new thread pool based on some attributes
 * @param poolSize the number of worker threads in the thread pool
 * @param poolName the name of the thread pool (for debugging purposes)
 * @param priority the base priority of the worker threads
 * @param capacity the size of the task queue used
 * @return the ExecutorService object
 */
private ExecutorService newPool(int poolSize, 
String poolName, final int priority, int capacity) {
    int cpu = Runtime.getRuntime().availableProcessors();
    ExecutorService result = null;
    if (poolSize != 0) {
        if (poolSize == -1) {
            poolSize = cpu;
        }
        if (capacity <= 0) {
            capacity = Integer.MAX_VALUE;
        }
        result = new ThreadPoolExecutor(poolSize, poolSize, 
                120, TimeUnit.MINUTES, 
                new LinkedBlockingQueue<Runnable>(capacity), 
        new ThreadFactory() {
            @Override
            public Thread newThread(Runnable runnable) {
                Thread t = new Thread(runnable);
                t.setPriority(priority);
                return t;
            }
        }, new RejectedExecutionHandler() {
            @Override
            public void rejectedExecution(Runnable r,
                    ThreadPoolExecutor executor) {
                if (!executor.isShutdown()) {
                    try {
                        executor.getQueue().put(r);
                    } catch (InterruptedException ex) {
                        // give up
                    }
                }
            }
        });
    }
    return result;
}

И вы можете использовать это так:

ExecutorService exec = newPool(-1, "converter pool", Thread.NORM_PRIORITY, 500);
servletContext.setAttribute("converter pool", exec);

А в твоем сервлете

ExecutorService exec = (ExecutorService)servletContext
.getAttribute("converter pool");

exec.submit(new Runnable() {
    public void run() {
        // your code for transformation goes here
    }
}