Улучшение производительности записи ActiveMQ

Question

Код в https://github.com/maxant/share/blob/master/DBJMSPerf/src/JMSWriter.java пишет BytesMessages локальному серверу ActiveMQ.

Я управляю только 200 сообщениями в секунду (< 5 миллисекунд за сообщение).

Используя код на https://github.com/maxant/share/blob/master/DBJMSPerf/src/DBWriter.java, который следует очень похожей схеме, я могу написать более 500 сообщений в секунду для базы данных.

В обоих случаях я обрабатываю транзакции самостоятельно, потому что я хочу имитировать фиксацию после каждого сообщения, и я повторно использую соединение, так как хочу имитировать объединение пулов.

Я использую режим постоянной доставки в примере JMS, потому что я пытаюсь проанализировать конструкцию с высокой доступностью - сообщения не могут быть потеряны.

В http://activemq.apache.org/performance.html они цитируют сообщения в десять раз быстрее, чем я могу.

Как повысить производительность сервера ActiveMQ?

Answer 1

Вам необходимо использовать пул соединений для ускорения работы при повторном создании всех ресурсов JMS на отправляемое сообщение, и это медленно.

В пулах соединений на основе JMS очень часто встроен пул сессий/потребителей/производителей, и, следовательно, вы можете сохранить код как есть.

У Apache ActiveMQ есть пул, который вы можете использовать, а также есть один из Spring Framework.