Клиент Java ActiveMQ не получает сообщения

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

 for(int i = 0; i < numberOfMessages; i++){
                try{
                    String message = generateText(sizeOfMessage);
                    produceMessage(message);
                }
                catch (Exception e) {
                    logger.error("Caught exception while sending message", e);
                }
            }

Это продолжается без проблем, и я подтвердил это проверками на веб-сайте администратора, которые содержат правильное количество ожидающих сообщений.

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

Message message = jmsTemplate.receive();

и он работает для некоторых сообщений (около 20-30), но потом просто блокируется. Мне было предложено, что некоторые символы в сообщении могут быть escape-символами (я использовал случайную строку различной длины, потому что это просто тест производительности, а не отправка какого-либо содержимого), поэтому я изменил все сообщения к той же строке, которая является повторением символа "2", и все равно не повезло. Я использую конфигурацию Spring для загрузки всех компонентов, необходимых для доступа к очереди ActiveMQ, и эта очередь работает на моем локальном хосте.


java jms activemq
person Richard    schedule 24.11.2008    source источник

Ответы (2)


arrow_upward
4
arrow_downward

Пока не так много мнений по этому поводу, но на будущее, если у кого-то есть такая же проблема, я нашел решение. Конфигурация для activeMQ ограничивает объем памяти, используемой отправителями и получателями, прежде чем замедлять их, значения по умолчанию, данные мне, были:

<systemUsage>
            <systemUsage>
                <memoryUsage>
                    <memoryUsage limit="20 mb"/>
                </memoryUsage>
                <storeUsage>
                    <storeUsage limit="1 gb" name="foo"/>
                </storeUsage>
                <tempUsage>
                    <tempUsage limit="100 mb"/>
                </tempUsage>
            </systemUsage>
        </systemUsage>

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

person Richard    schedule 24.11.2008

arrow_upward
0
arrow_downward

Это классическая проблема с обменом сообщениями; что делать с медленными потребителями. FWIW более поздних выпусков ActiveMQ, таких как 5.2, позволяет выполнять буферизацию на диск, а не блокировать производителей при нехватке памяти

person James Strachan    schedule 26.11.2008